Skip to content

Commit

Permalink
[FSTORE-1624] Fix confluent kafka logging (#416)
Browse files Browse the repository at this point in the history
  • Loading branch information
bubriks authored Nov 28, 2024
1 parent 432c71f commit d730311
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/hsfs/engine/python.py
Original file line number Diff line number Diff line change
Expand Up @@ -1493,6 +1493,7 @@ def _write_dataframe_kafka(
# make sure producer blocks and everything is delivered
if not feature_group._multi_part_insert:
producer.flush()
del producer
progress_bar.close()

# start materialization job if not an external feature group, otherwise return None
Expand Down

0 comments on commit d730311

Please sign in to comment.