修改连接数

src/main/java/com/dsk/flink/dsc/common/sink/MysqlDataSlideSink.java

@@ -39,7 +39,7 @@ public class MysqlDataSlideSink extends RichSinkFunction<Tuple6<String,String,St
 
     @Override
     public void open(Configuration parameters) throws Exception {
-        executorService = new ThreadPoolExecutor(5, 10, 60,
+        executorService = new ThreadPoolExecutor(5, 5, 60,
                 TimeUnit.SECONDS,
                 new LinkedBlockingDeque<>(QUEUE_CAPACITY),
                 new ThreadPoolExecutor.CallerRunsPolicy());

src/main/java/com/dsk/flink/dsc/common/sink/MysqlDataTransferSink.java

@@ -34,7 +34,7 @@ public class MysqlDataTransferSink extends RichSinkFunction<String> {
 
     @Override
     public void open(Configuration parameters) throws Exception {
-        executorService = new ThreadPoolExecutor(8, 20, 60,
+        executorService = new ThreadPoolExecutor(5, 5, 60,
                 TimeUnit.SECONDS,
                 new LinkedBlockingDeque<>(QUEUE_CAPACITY),
                 new ThreadPoolExecutor.CallerRunsPolicy());