From d211136d3cc1c266719be0087333fa247ec11b7a Mon Sep 17 00:00:00 2001 From: Rodrigo Meneses Date: Mon, 26 Aug 2024 11:39:40 -0700 Subject: [PATCH] Introduces the new IcebergSink based on the new V2 Flink Sink Abstraction Co-authored-by: Liwei Li Co-authored-by: Kyle Bendickson Co-authored-by: Peter Vary --- .../main/java/org/apache/iceberg/flink/sink/IcebergSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java b/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java index d1555b271920..30f1ceeac5f8 100644 --- a/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java +++ b/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java @@ -424,7 +424,7 @@ public Builder equalityFieldColumns(List columns) { /** * Set the uid suffix for IcebergSink operators. Note that IcebergSink internally consists of * multiple operators (like writer, committer, aggregator). Actual operator uid will be - * prepended with a prefix like "Sink Committer: $uidSuffix". + * appended with a suffix like "Sink Committer: $uidSuffix". * *

Flink auto generates operator uid if not set explicitly. It is a recommended