init

logicalclocks · Nov 20, 2024 · 66aae45 · 66aae45
1 parent 0d0757d
commit 66aae45
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/hsfs/engine/python.py b/python/hsfs/engine/python.py
@@ -1511,7 +1511,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(