(flink-cdc) branch master updated: [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` (#4272)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 8e9474f6d [minor][hotfix] Update configOption name from 
`sink.job.id.prefix` to `job.id.prefix` (#4272)
8e9474f6d is described below

commit 8e9474f6d4090d0eba2ec05f7c7d717faed3beba
Author: Kunni <decq12y...@gmail.com>
AuthorDate: Thu Feb 12 10:30:38 2026 +0800

    [minor][hotfix] Update configOption name from `sink.job.id.prefix` to 
`job.id.prefix` (#4272)
---
 .../flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java     | 4 ++--
 .../flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java     | 4 ++--
 .../flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java
index c08565294..3bdbc924d 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java
@@ -107,7 +107,7 @@ public class IcebergDataSinkFactory implements 
DataSinkFactory {
             }
         }
         String jobIdPrefix =
-                
context.getFactoryConfiguration().get(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX);
+                
context.getFactoryConfiguration().get(IcebergDataSinkOptions.JOB_ID_PREFIX);
 
         return new IcebergDataSink(
                 catalogOptions,
@@ -147,7 +147,7 @@ public class IcebergDataSinkFactory implements 
DataSinkFactory {
         options.add(IcebergDataSinkOptions.SINK_COMPACTION_ENABLED);
         options.add(IcebergDataSinkOptions.SINK_COMPACTION_COMMIT_INTERVAL);
         options.add(IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM);
-        options.add(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX);
+        options.add(IcebergDataSinkOptions.JOB_ID_PREFIX);
         return options;
     }
 }
diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java
index f989909fa..57bdd887b 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java
@@ -80,8 +80,8 @@ public class IcebergDataSinkOptions {
                             "The parallelism for file compaction, default 
value is -1, which means that compaction parallelism is equal to sink writer 
parallelism.");
 
     @Experimental
-    public static final ConfigOption<String> SINK_JOB_ID_PREFIX =
-            key("sink.job.id.prefix")
+    public static final ConfigOption<String> JOB_ID_PREFIX =
+            key("job.id.prefix")
                     .stringType()
                     .defaultValue("cdc")
                     .withDescription(
diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java
index 848fd2584..10f89e16d 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java
@@ -57,7 +57,7 @@ public class IcebergDataSinkFactoryTest {
         Configuration conf = Configuration.fromMap(ImmutableMap.<String, 
String>builder().build());
         conf.set(IcebergDataSinkOptions.WAREHOUSE, "/tmp/warehouse");
         conf.set(IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM, 4);
-        conf.set(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX, "FlinkCDC");
+        conf.set(IcebergDataSinkOptions.JOB_ID_PREFIX, "FlinkCDC");
         DataSink dataSink =
                 sinkFactory.createDataSink(
                         new FactoryHelper.DefaultContext(