Commit 171c930e by WangJinfeng

update Datatory logic

parent 9011af37
......@@ -171,7 +171,7 @@ public class Datatory3SMain {
}
private static String dropPartition(String part) {
String dropSql = "ALTER TABLE dwh.sss_tracking_insight_daily DROP PARTITION @part";
String dropSql = "ALTER TABLE dwh.sss_tracking_insight_daily ON CLUSTER cluster_1st DROP PARTITION @part";
return dropSql.replace("@part", part);
}
......
......@@ -172,7 +172,7 @@ public class DatatoryAdnMain {
}
private static String dropPartition(String part) {
String dropSql = "ALTER TABLE dwh.adn_tracking_insight_daily DROP PARTITION @part";
String dropSql = "ALTER TABLE dwh.adn_tracking_insight_daily ON CLUSTER cluster_1st DROP PARTITION @part";
return dropSql.replace("@part", part);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment