This is an automated email from the ASF dual-hosted git repository.

wesm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/master by this push:
     new bf138a8  ARROW-4576: [Python] Fix error during benchmarks
bf138a8 is described below

commit bf138a848e6c52fc9372b3fc7c5001dbd7f70bab
Author: Antoine Pitrou <[email protected]>
AuthorDate: Fri Feb 15 00:52:04 2019 -0600

    ARROW-4576: [Python] Fix error during benchmarks
    
    Author: Antoine Pitrou <[email protected]>
    
    Closes #3650 from pitrou/ARROW-4576-py-benchmarks-fix and squashes the 
following commits:
    
    67e8069d1 <Antoine Pitrou> ARROW-4576:  Fix error during benchmarks
---
 python/benchmarks/streaming.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/python/benchmarks/streaming.py b/python/benchmarks/streaming.py
index 2012141..c0c63e6 100644
--- a/python/benchmarks/streaming.py
+++ b/python/benchmarks/streaming.py
@@ -62,7 +62,7 @@ class StreamReader(object):
         stream_writer = pa.RecordBatchStreamWriter(sink, schema)
         for batch in batches:
             stream_writer.write_batch(batch)
-        self.source = sink.get_result()
+        self.source = sink.getvalue()
 
     def time_read_to_dataframe(self, *args):
         reader = pa.RecordBatchStreamReader(self.source)

Reply via email to