Skip to content

Commit 7613e70

Browse files
voonhouscshuo
authored andcommitted
Checkpoint 56 - Address comments 2
1 parent 625bb36 commit 7613e70

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/coordinator/MultiTableStreamWriteOperatorCoordinator.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -286,7 +286,6 @@ boolean shouldTriggerCompaction() {
286286

287287
public MultiTableStreamWriteOperatorCoordinator(Configuration conf, Context context) {
288288
super(conf, context);
289-
conf.setString("fs.file.impl", "org.apache.hadoop.fs.LocalFileSystem");
290289
this.baseConfig = conf;
291290
LOG.info(
292291
"MultiTableStreamWriteOperatorCoordinator initialized for operator: {} with config: {}",

0 commit comments

Comments
 (0)