Skip to content

Commit e405d13

Browse files
Update FlinkPipelineComposerITCase.java
1 parent fadc1e8 commit e405d13

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1504,8 +1504,8 @@ void testMergingDecimalWithVariousPrecisions(ValuesDataSink.SinkApi sinkApi) thr
15041504
"DataChangeEvent{tableId={}, before=[], after=[108, Zen, 19, 888888888.8888888888888888888], op=INSERT, meta=()}")
15051505
.map(
15061506
s ->
1507-
s.replace(
1508-
"{}",
1507+
s.replaceFirst(
1508+
"\\{}",
15091509
"default_namespace.default_schema.default_everything_merged"))
15101510
.toArray(String[]::new);
15111511

0 commit comments

Comments
 (0)