增加休眠时间

src/main/java/com/winhc/data/DataPull.java

@@ -173,6 +173,7 @@ public class DataPull {
         for (SinkTask task : tasks) {
             task.close();
         }
+        Thread.sleep(3000);
         executor.shutdownNow();
         long totalNum = tasks.stream().map(SinkTask::getProcessNum).reduce(0L, Long::sum);
         logger.info("{} all {} thread process finish | total count {} | total cost {} ms", ds, numThread, totalNum, (System.currentTimeMillis() - start));