Skip to content

Commit 12fbeb4

Browse files
committed
[minor][hotfix] Update configOption name from sink.job.id.prefix to job.id.prefix.
1 parent 7a83225 commit 12fbeb4

4 files changed

Lines changed: 6 additions & 6 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ public DataSink createDataSink(Context context) {
107107
}
108108
}
109109
String jobIdPrefix =
110-
context.getFactoryConfiguration().get(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX);
110+
context.getFactoryConfiguration().get(IcebergDataSinkOptions.JOB_ID_PREFIX);
111111

112112
return new IcebergDataSink(
113113
catalogOptions,
@@ -147,7 +147,7 @@ public Set<ConfigOption<?>> optionalOptions() {
147147
options.add(IcebergDataSinkOptions.SINK_COMPACTION_ENABLED);
148148
options.add(IcebergDataSinkOptions.SINK_COMPACTION_COMMIT_INTERVAL);
149149
options.add(IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM);
150-
options.add(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX);
150+
options.add(IcebergDataSinkOptions.JOB_ID_PREFIX);
151151
return options;
152152
}
153153
}

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,8 +80,8 @@ public class IcebergDataSinkOptions {
8080
"The parallelism for file compaction, default value is -1, which means that compaction parallelism is equal to sink writer parallelism.");
8181

8282
@Experimental
83-
public static final ConfigOption<String> SINK_JOB_ID_PREFIX =
84-
key("sink.job.id.prefix")
83+
public static final ConfigOption<String> JOB_ID_PREFIX =
84+
key("job.id.prefix")
8585
.stringType()
8686
.defaultValue("cdc")
8787
.withDescription(

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactoryTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ void testCreateDataSink() {
5757
Configuration conf = Configuration.fromMap(ImmutableMap.<String, String>builder().build());
5858
conf.set(IcebergDataSinkOptions.WAREHOUSE, "/tmp/warehouse");
5959
conf.set(IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM, 4);
60-
conf.set(IcebergDataSinkOptions.SINK_JOB_ID_PREFIX, "FlinkCDC");
60+
conf.set(IcebergDataSinkOptions.JOB_ID_PREFIX, "FlinkCDC");
6161
DataSink dataSink =
6262
sinkFactory.createDataSink(
6363
new FactoryHelper.DefaultContext(

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/resources/log4j2-test.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
# Set root logger level to ERROR to not flood build logs
1818
# set manually to INFO for debugging purposes
19-
rootLogger.level=ERROR
19+
rootLogger.level=INFO
2020
rootLogger.appenderRef.test.ref = TestLogger
2121

2222
appender.testlogger.name = TestLogger

0 commit comments

Comments
 (0)