diff --git a/odps/readers.py b/odps/readers.py index 022d3d5..030d31c 100644 --- a/odps/readers.py +++ b/odps/readers.py @@ -358,7 +358,7 @@ def __next__(self): self._load_columns() values = self._readline() - if values is None: + if values is None or len(values) == 0: raise StopIteration if self._filtered_col_idxes: