[arrow-rs] branch master updated: Ends ParquetRecordBatchStream when polling on StreamState::Error (#3404)

[viirya]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 513d543cf Ends ParquetRecordBatchStream when polling on 
StreamState::Error (#3404)
513d543cf is described below

commit 513d543cf99d0622661c2824d735d4f4bf17c0d3
Author: Liang-Chi Hsieh <vii...@gmail.com>
AuthorDate: Wed Dec 28 15:25:41 2022 -0800

    Ends ParquetRecordBatchStream when polling on StreamState::Error (#3404)
    
    * Remove unnecessary StreamState
    
    * Return None for StreamState::Error
---
 parquet/src/arrow/async_reader/mod.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/parquet/src/arrow/async_reader/mod.rs 
b/parquet/src/arrow/async_reader/mod.rs
index cbaa2bf6b..e93c85580 100644
--- a/parquet/src/arrow/async_reader/mod.rs
+++ b/parquet/src/arrow/async_reader/mod.rs
@@ -568,7 +568,7 @@ where
                         return Poll::Ready(Some(Err(e)));
                     }
                 },
-                StreamState::Error => return Poll::Pending,
+                StreamState::Error => return Poll::Ready(None), // Ends the 
stream as error happens.
             }
         }
     }