会员标签4.0

src/main/java/com/gic/spark/datasource/entity/DataSourceSharding.java

@@ -47,7 +47,6 @@ public class DataSourceSharding extends DataSourceEntity {
     @Override
     public String getSourceKey() {
         this.checkShardingConfigInit();
-        System.out.println("shardingConfig==>"+shardingConfig);
         System.out.println("name==>"+sourceType.getName()+" ,id==>"+shardingConfig.get_id()+" ,targetTable==>"+targetTable);
         return sourceType.getName() + "_" + shardingConfig.get_id() + "_" + targetTable;
     }
@@ -55,7 +54,7 @@ public class DataSourceSharding extends DataSourceEntity {
     @Override
     public String getHiveTableName() {
         this.checkShardingConfigInit();
-        return getSchema()+"." + shardingConfig.get_id() + "_" + targetTable;
+        return getSchema()+"." + shardingConfig.get_id().replaceAll("\\.", "_") + "_" + targetTable;
     }
 
     @Override