update codes

901911a0 · 赵建伟 · a3420aae · 901911a0
Commit 901911a0 authored Apr 11, 2020 by 赵建伟
Hide whitespace changes
Inline Side-by-side

Showing with 0 additions and 1 deletion

CtrEstimatePfrOperator.java ...va/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java +0 -1

No files found.
--- a/src/main/java/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java
+++ b/src/main/java/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java
@@ -162,7 +162,6 @@ public class CtrEstimatePfrOperator implements BaseOperator{
                .unorderedWait(map, new TidbMysqlAsyncPfrSource(jerryJdbcUrl,jerryUsername,jerryPassword), 1, TimeUnit.MINUTES, 1000)
                .uid("tidbAsyncDataStream")
                .setParallelism(parallelism);
-        tidbAsyncDataStream.print();

        tidbAsyncDataStream
        .addSink(new CtrEstimatePfrMysqlSink(outJdbcUrl, maxRetry, retryInteral))