Skip to content

C
ctr-estimate
Commit 334c5b10 authored by 赵建伟's avatar 赵建伟
Browse files
Options

update codes

parent 0bc95401
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
src/main/java/com/gmei/data/ctr/operator/CtrEstimateTagOperator.java
View file @ 334c5b10
...@@ -168,7 +168,7 @@ public class CtrEstimateTagOperator implements BaseOperator{ ...@@ -168,7 +168,7 @@ public class CtrEstimateTagOperator implements BaseOperator{
.uid("zhengxingAsyncDataStream") .uid("zhengxingAsyncDataStream")
.setParallelism(parallelism); .setParallelism(parallelism);
DataStream<DeviceCurrentEstimateTagTmp> asyncDataStream = tidbAsyncDataStream.union(zhengxingAsyncDataStream); DataStream<DeviceCurrentEstimateTagTmp> asyncDataStream = tidbAsyncDataStream.union(zhengxingAsyncDataStream);
asyncDataStream.print(); //asyncDataStream.print();
asyncDataStream asyncDataStream
.addSink(new CtrEstimateTagMysqlSink(outJdbcUrl, maxRetry, retryInteral)) .addSink(new CtrEstimateTagMysqlSink(outJdbcUrl, maxRetry, retryInteral))
......
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