Explorar o código

Merge remote-tracking branch 'origin/master'

ZHAOXIAN hai 1 ano
pai
achega
ab1edd9472

+ 2 - 2
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceReportRetryJob.java

@@ -144,7 +144,7 @@ public class BytedanceReportRetryJob {
 
 
         List<JSONObject> changDuRetry = channelService.getChangDuRetry();
         List<JSONObject> changDuRetry = channelService.getChangDuRetry();
         if (!Check.isNull(changDuRetry)) {
         if (!Check.isNull(changDuRetry)) {
-            ExecutorService executorService = Executors.newFixedThreadPool(2);
+            ExecutorService executorService = Executors.newFixedThreadPool(1);
             for (int i = 0; i < changDuRetry.size(); i++) {
             for (int i = 0; i < changDuRetry.size(); i++) {
                 JSONObject jsonObject = changDuRetry.get(i);
                 JSONObject jsonObject = changDuRetry.get(i);
                 Long id = jsonObject.getLong("id");
                 Long id = jsonObject.getLong("id");
@@ -172,7 +172,7 @@ public class BytedanceReportRetryJob {
 
 
         List<JSONObject> maEcpmRetryJob = miniAppService.getMaEcpmRetryJob();
         List<JSONObject> maEcpmRetryJob = miniAppService.getMaEcpmRetryJob();
         if (!Check.isNull(maEcpmRetryJob)) {
         if (!Check.isNull(maEcpmRetryJob)) {
-            ExecutorService executorService = Executors.newFixedThreadPool(2);
+            ExecutorService executorService = Executors.newFixedThreadPool(1);
             for (int i = 0; i < maEcpmRetryJob.size(); i++) {
             for (int i = 0; i < maEcpmRetryJob.size(); i++) {
                 JSONObject jsonObject = maEcpmRetryJob.get(i);
                 JSONObject jsonObject = maEcpmRetryJob.get(i);
                 Long id = jsonObject.getLong("id");
                 Long id = jsonObject.getLong("id");