[FSTORE-1615] Inserting into streaming FG fails after cluster upgrade (…

…#408)
logicalclocks · Nov 21, 2024 · b026acc · b026acc
1 parent 3ec2248
commit b026acc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/hsfs/engine/python.py b/python/hsfs/engine/python.py
@@ -1387,7 +1387,7 @@ def _write_dataframe_kafka(
                 topic_name=feature_group._online_topic_name,
                 feature_store_id=feature_group.feature_store_id,
                 offline_write_options=offline_write_options,
-                high=True,
+                high=False,
             )
             now = datetime.now(timezone.utc)
             feature_group.materialization_job.run(