Add small change

ismailhammounou · Mar 16, 2024 · 6a7d5a4 · 6a7d5a4
1 parent f89b550
commit 6a7d5a4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/db2ixf/ixf.py b/src/db2ixf/ixf.py
@@ -278,7 +278,7 @@ def __parse_data_record(self) -> OrderedDict:
  f"data type {col_type}"
  raise UnknownDataTypeException(msg)
 
- collected_data: Any = collector(
+ collected_data = collector(
  c, self.current_data_record["IXFDCOLS"], pos
  )
  self.current_row[col_name] = collected_data
@@ -523,6 +523,7 @@ def __iter_pyarrow_record_batch(
 
  if batch:
  yield to_pyarrow_record_batch(batch, self.pyarrow_schema)
+ batch.clear()
 
  def iter_pyarrow_record_batch(
  self,