code style

JNSimba · Sep 3, 2024 · 4ceb2fd · 4ceb2fd
1 parent 0f1615b
commit 4ceb2fd
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/...pache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java b/...pache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java
@@ -123,7 +123,11 @@ public boolean schemaChange(JsonNode recordRoot) {
                     String dorisTbl = getCreateTableIdentifier(recordRoot);
                     changeContext.getTableMapping().put(cdcTbl, dorisTbl);
                     this.tableMapping = changeContext.getTableMapping();
-                    LOG.info("create table ddl status: {}, add tableMapping {},{}", status, cdcTbl, dorisTbl);
+                    LOG.info(
+                            "create table ddl status: {}, add tableMapping {},{}",
+                            status,
+                            cdcTbl,
+                            dorisTbl);
                 }
             } else if (eventType.equals(EventType.ALTER)) {
                 Tuple2<String, String> dorisTableTuple = getDorisTableTuple(recordRoot);

diff --git a/...ava/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java b/...ava/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java
@@ -83,7 +83,11 @@ public boolean schemaChange(JsonNode recordRoot) {
                     String dorisTbl = getCreateTableIdentifier(recordRoot);
                     changeContext.getTableMapping().put(cdcTbl, dorisTbl);
                     this.tableMapping = changeContext.getTableMapping();
-                    LOG.info("create table ddl status: {}, add tableMapping {},{}", status, cdcTbl, dorisTbl);
+                    LOG.info(
+                            "create table ddl status: {}, add tableMapping {},{}",
+                            status,
+                            cdcTbl,
+                            dorisTbl);
                 }
             } else if (eventType.equals(EventType.ALTER)) {
                 Tuple2<String, String> dorisTableTuple = getDorisTableTuple(recordRoot);