This is an automated email from the ASF dual-hosted git repository.
etudenhoefner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new cb25b98f45 Docs: Fix Flink configuration example doc. (#8564)
cb25b98f45 is described below
commit cb25b98f45d3f97566df0e18302ec53c2fa0cbe0
Author: Yujiang Zhong <[email protected]>
AuthorDate: Fri Sep 15 15:07:11 2023 +0800
Docs: Fix Flink configuration example doc. (#8564)
---
docs/flink-configuration.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/flink-configuration.md b/docs/flink-configuration.md
index 37db16c363..1877de2a6d 100644
--- a/docs/flink-configuration.md
+++ b/docs/flink-configuration.md
@@ -87,7 +87,7 @@ IcebergSource.forRowData()
.tableLoader(TableLoader.fromCatalog(...))
.assignerFactory(new SimpleSplitAssignerFactory())
.streaming(true)
-
.streamingStartingStrategy(StreamingStartingStrategy.INCREMENTAL_FROM_LATEST_SNAPSHOT)
+
.streamingStartingStrategy(StreamingStartingStrategy.INCREMENTAL_FROM_SNAPSHOT_ID)
.startSnapshotId(3821550127947089987L)
.monitorInterval(Duration.ofMillis(10L)) // or .set("monitor-interval",
"10s") \ set(FlinkReadOptions.MONITOR_INTERVAL, "10s")
.build()
