update

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/rocketmq/consumer/ContentUnderstandingPipelineTaskConsumer.java

@@ -40,7 +40,7 @@ import java.util.Objects;
 @Component
 @RocketMQMessageListener(endpoints = "${rocketmq.consumer.endpoints:rmq-cn-vym47zv2i03-vpc.cn-hangzhou.rmq.aliyuncs.com:8080}",
         topic = "${rocketmq.consumer.pipelinetask.topic:topic_content_understanding_pipeline_task}",
-        consumerGroup = "${rocketmq.consumer.pipelinetask.group:group_content_understanding_pipeline_task}", tag = "*", consumptionThreadCount = 10)
+        consumerGroup = "${rocketmq.consumer.pipelinetask.group:group_content_understanding_pipeline_task}", tag = "*", consumptionThreadCount = 5)
 public class ContentUnderstandingPipelineTaskConsumer implements RocketMQListener {
 
     @Autowired

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/service/impl/ContentServiceImpl.java

@@ -248,7 +248,7 @@ public class ContentServiceImpl implements ContentService {
                     submitTasksParam.setContents(contentDTOList);
                     submitTasks(submitTasksParam);
                 } catch (Exception e) {
-                    XxlJobLogger.log("record = {} error", record);
+                    XxlJobLogger.log("record error {}", e);
                 } finally {
                     try {
                         TimeUnit.SECONDS.sleep(recordSleep);