소스 검색

修改带qc的表名,不会去掉qc的bug

15135239248@163.com 2 년 전
부모
커밋
af59801d9c
1개의 변경된 파일5개의 추가작업 그리고 0개의 파일을 삭제
  1. 5 0
      src/main/java/com/qucheng/game/data/oldsystem/sink/CdcMysqlTablesSink.java

+ 5 - 0
src/main/java/com/qucheng/game/data/oldsystem/sink/CdcMysqlTablesSink.java

@@ -64,6 +64,11 @@ public class CdcMysqlTablesSink extends RichSinkFunction<TransportMap> {
         }
         String tableName = tableNameMap.get(value.getTableName());
         tableName = StringUtils.isBlank(tableName) ? value.getTableName() : tableName;
+
+        if(tableName.contains("qc_")){
+            tableName = tableName.replaceAll("qc_","");
+        }
+
         List<String> primaryKeys = value.getPrimaryKeys();
         Map<String, Object> data = value.getAfter();
         if (Envelope.Operation.DELETE == value.getOperation()) {