会员标签4.0

src/main/java/com/gic/spark/tag/TagProcessManager.java

@@ -265,7 +265,7 @@ public class TagProcessManager {
         SparkSession sparkSession=SparkEnvManager.getInstance().getSparkSession();
         Dataset<Row>tagGroupInfoDataset=sparkSession.createDataFrame(tagGroupInfoRDD,TagGroupInfo.class);
         tagGroupInfoDataset.createOrReplaceTempView("tag_group_info_tmp");
-        sparkSession.sql(String.format("INSERT overwrite table tag.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,enterprise_id,tag_group_info from tag_group_info_tmp", enterpriseId));
+        sparkSession.sql(String.format("INSERT overwrite table '%s'.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,enterprise_id,tag_group_info from tag_group_info_tmp",isProduction?"tag4_prod":"tag4_test", enterpriseId));
 
     }