@@ -801,17 +801,21 @@ def get_chunk(self, rows=None):
801
801
# done with first read, next time raise StopIteration
802
802
self ._first_chunk = False
803
803
804
+ columns = list (self .orig_columns )
804
805
if len (content ) == 0 : # pragma: no cover
805
806
if self .index_col is not None :
806
807
if np .isscalar (self .index_col ):
807
808
index = Index ([], name = self .index_name )
809
+ columns .pop (self .index_col )
808
810
else :
809
811
index = MultiIndex .from_arrays ([[]] * len (self .index_col ),
810
812
names = self .index_name )
813
+ for n in self .index_col :
814
+ columns .pop (n )
811
815
else :
812
816
index = Index ([])
813
817
814
- return DataFrame (index = index , columns = self . columns )
818
+ return DataFrame (index = index , columns = columns )
815
819
816
820
alldata = self ._rows_to_cols (content )
817
821
data = self ._exclude_implicit_index (alldata )
@@ -824,7 +828,6 @@ def get_chunk(self, rows=None):
824
828
825
829
data = _convert_to_ndarrays (data , self .na_values , self .verbose )
826
830
827
- columns = list (self .orig_columns )
828
831
if self .parse_dates is not None :
829
832
data , columns = self ._process_date_conversion (data )
830
833
0 commit comments