From de8fb39e23cd1ccc5752ee03375b77047b1e5f64 Mon Sep 17 00:00:00 2001 From: Zzm0809 Date: Wed, 25 Sep 2024 15:50:45 +0000 Subject: [PATCH] Spotless Apply --- .../java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java index d109317101..abc975a0ee 100644 --- a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java +++ b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java @@ -278,19 +278,19 @@ public int partition(String key, int numPartitions) { mapOperator.name("PartitionByPrimarykey"); } - protected void executeCatalogStatement(CustomTableEnvironment customTableEnvironment) {}; + protected void executeCatalogStatement(CustomTableEnvironment customTableEnvironment) {} + ; /** * replace view name middle to under line for flink use view name * @param viewName view name * @return view name */ - public static String replaceViewNameMiddleLineToUnderLine( String viewName) { - if (!viewName.isEmpty() & viewName.contains("-")){ + public static String replaceViewNameMiddleLineToUnderLine(String viewName) { + if (!viewName.isEmpty() & viewName.contains("-")) { logger.warn("the view name [{}] contains '-', replace '-' to '_' for flink use view name", viewName); return viewName.replaceAll("-", "_"); } return viewName; } - }