Fix the issue where the table name contains a dash line, causing the …

…entire database synchronization to fail to execute

Signed-off-by: Zzm0809 <934230207@qq.com>

dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/AbstractSqlSinkBuilder.java

@@ -279,15 +279,14 @@ public int partition(String key, int numPartitions) {
     }
 
     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("-")) {
+        if (!viewName.isEmpty() && viewName.contains("-")) {
             logger.warn("the view name [{}] contains '-', replace '-' to '_' for flink use view name", viewName);
             return viewName.replaceAll("-", "_");
         }