[FSTORE-1615] Inserting into streaming FG fails after cluster upgrade (logicalclocks#409)

bubriks · web-flow · commit b8c3b3b9085b · 2024-11-21T11:07:30.000+02:00
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(

Original file line number	Diff line number	Diff line change
`@@ -1511,7 +1511,7 @@ def _write_dataframe_kafka(`
`1511`	`1511`	`topic_name=feature_group._online_topic_name,`
`1512`	`1512`	`feature_store_id=feature_group.feature_store_id,`
`1513`	`1513`	`offline_write_options=offline_write_options,`
`1514`		`- high=True,`
	`1514`	`+ high=False,`
`1515`	`1515`	`)`
`1516`	`1516`	`now = datetime.now(timezone.utc)`
`1517`	`1517`	`feature_group.materialization_job.run(`