Commit d914a41f authored by 赵建伟's avatar 赵建伟

update codes

parent 31450647
...@@ -61,7 +61,7 @@ public class CtrEstimateMain { ...@@ -61,7 +61,7 @@ public class CtrEstimateMain {
// 执行处理核心逻辑 // 执行处理核心逻辑
new CtrEstimateClkOperator(MaidianDataStream,jdbcUrl,maxRetry,retryInteral,parallelism).run(); new CtrEstimateClkOperator(MaidianDataStream,jdbcUrl,maxRetry,retryInteral,parallelism).run();
new CtrEstimateTagOperator(MaidianDataStream,jdbcUrl,maxRetry,retryInteral,parallelism).run(); //new CtrEstimateTagOperator(MaidianDataStream,jdbcUrl,maxRetry,retryInteral,parallelism).run();
// 常驻执行 // 常驻执行
env.execute("ctr-estimate"); env.execute("ctr-estimate");
......
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