fix compile error

dapeng · dapeng · commit 8521aecf4b86 · 2020-06-23T10:09:07.000+08:00
diff --git a/tidb/tidb-side/tidb-async-side/src/main/java/com/dtstack/flink/sql/side/tidb/TidbAsyncReqRow.java b/tidb/tidb-side/tidb-async-side/src/main/java/com/dtstack/flink/sql/side/tidb/TidbAsyncReqRow.java
@@ -72,7 +72,5 @@ public void open(Configuration parameters) throws Exception {
         vo.setFileResolverCachingEnabled(false);
         Vertx vertx = Vertx.vertx(vo);
         setRdbSqlClient(JDBCClient.createNonShared(vertx, tidbClientConfig));
-        setExecutor(new ThreadPoolExecutor(50, 50, 0, TimeUnit.MILLISECONDS,
-                new LinkedBlockingQueue<>(10000), new DTThreadFactory("TidbAsyncExec"), new ThreadPoolExecutor.CallerRunsPolicy()));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,5 @@ public void open(Configuration parameters) throws Exception {`
`72`	`72`	`vo.setFileResolverCachingEnabled(false);`
`73`	`73`	`Vertx vertx = Vertx.vertx(vo);`
`74`	`74`	`setRdbSqlClient(JDBCClient.createNonShared(vertx, tidbClientConfig));`
`75`		`- setExecutor(new ThreadPoolExecutor(50, 50, 0, TimeUnit.MILLISECONDS,`
`76`		`- new LinkedBlockingQueue<>(10000), new DTThreadFactory("TidbAsyncExec"), new ThreadPoolExecutor.CallerRunsPolicy()));`
`77`	`75`	`}`
`78`	`76`	`}`