[dev]修改线程配置

DataAssets/TranslationOperator/src/main/java/com/dataspy/translation/service/NewTranslateService.java

@@ -248,7 +248,7 @@ public class NewTranslateService {
         }
 
         // 重试次数
-        AtomicInteger failCount = new AtomicInteger(30);
+        AtomicInteger failCount = new AtomicInteger(10);
         JsonArray res = new JsonArray();
         Map<String , String> cols = getColObj(value);
         for (Map.Entry<String, String> tmpKV : cols.entrySet()) {
@@ -281,7 +281,6 @@ public class NewTranslateService {
                     }
                     if(translateSplit.length()!=0){
                         translateSplits.add(translateSplit.toString());
-                        translateSplit=new StringBuilder();
                     }
                     for(int i=0;i<translateSplits.size();i++){
                         String tmpContentZh = "";

DataProcessCenter/src/main/java/com/dataspy/center/service/ListenerAssignService.java

@@ -57,7 +57,7 @@ public class ListenerAssignService {
              retryBean.setOperatorBeanName(entry.getKey());
              retryBean.setKafkaConsumerParams(getRetryKafkaParam());
              retryBean.setInputTopic(commonConfig.getRetryTopic());
-             retryBean.setProcessThreadNum(45);
+             retryBean.setProcessThreadNum(30);
              String retryConsumer=entry.getKey()+"_retry_consumer";
              retryBean.setTopicConsumer(retryConsumer);