[rocketmq-connect] branch master updated: build: [ISSUE #211]修复工程编译时checkStyle问题

[duhengforever]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new f0b973d  build: [ISSUE #211]修复工程编译时checkStyle问题
     new 1e0f7cd  Merge pull request #212 from ahhqcheng22/master
f0b973d is described below

commit f0b973d91d5def72802bbe8818ee5a9310f62c65
Author: yongchun <yongchun.chen...@alibaba-inc.com>
AuthorDate: Thu Jul 21 17:51:55 2022 +0800

    build: [ISSUE #211]修复工程编译时checkStyle问题
    
    升级checkStyle的版本&优化代码格式
---
 pom.xml                                                          | 2 +-
 .../apache/rocketmq/connect/runtime/connectorwrapper/Worker.java | 2 +-
 .../connect/runtime/connectorwrapper/WorkerSinkTask.java         | 2 +-
 .../service/memory/MemoryConfigManagementServiceImpl.java        | 9 ++-------
 4 files changed, 5 insertions(+), 10 deletions(-)

diff --git a/pom.xml b/pom.xml
index 34eb5f0..cb8b222 100644
--- a/pom.xml
+++ b/pom.xml
@@ -175,7 +175,7 @@
             </plugin>
             <plugin>
                 <artifactId>maven-checkstyle-plugin</artifactId>
-                <version>2.17</version>
+                <version>3.1.2</version>
                 <executions>
                     <execution>
                         <id>verify</id>
diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java
index f8986d1..70bb7ad 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java
@@ -119,7 +119,7 @@ public class Worker {
 
     private final Plugin plugin;
 
-    private static final int MAX_START_TIMEOUT_MILLS = 1000*60;
+    private static final int MAX_START_TIMEOUT_MILLS = 1000 * 60;
 
     private static final long MAX_STOP_TIMEOUT_MILLS = 20000;
 
diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java
index 5afaa24..6081fdd 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java
@@ -549,7 +549,7 @@ public class WorkerSinkTask implements WorkerTask {
         List<ConnectRecord> sinkDataEntries = new ArrayList<>(32);
         for (MessageExt message : messages) {
             this.retryWithToleranceOperator.consumerRecord(message);
-            ConnectRecord sinkDataEntry = 
this.retryWithToleranceOperator.execute(()->convertToSinkDataEntry(message), 
ErrorReporter.Stage.CONVERTER, WorkerSinkTask.class);
+            ConnectRecord sinkDataEntry = 
this.retryWithToleranceOperator.execute(() -> convertToSinkDataEntry(message), 
ErrorReporter.Stage.CONVERTER, WorkerSinkTask.class);
             if (sinkDataEntry != null && 
!this.retryWithToleranceOperator.failed())
             sinkDataEntries.add(sinkDataEntry);
             String msgId = message.getMsgId();
diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java
index d4574ba..0668c37 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java
@@ -24,24 +24,19 @@ import 
org.apache.rocketmq.connect.runtime.common.LoggerName;
 import org.apache.rocketmq.connect.runtime.config.ConnectConfig;
 import org.apache.rocketmq.connect.runtime.config.RuntimeConfigDefine;
 import org.apache.rocketmq.connect.runtime.connectorwrapper.Worker;
-import org.apache.rocketmq.connect.runtime.converter.JsonConverter;
-import org.apache.rocketmq.connect.runtime.converter.ListConverter;
 import org.apache.rocketmq.connect.runtime.service.ConfigManagementService;
 import org.apache.rocketmq.connect.runtime.service.StagingMode;
-import org.apache.rocketmq.connect.runtime.store.FileBaseKeyValueStore;
 import org.apache.rocketmq.connect.runtime.store.KeyValueStore;
 import org.apache.rocketmq.connect.runtime.store.MemoryBasedKeyValueStore;
-import org.apache.rocketmq.connect.runtime.utils.FilePathConfigUtil;
 import org.apache.rocketmq.connect.runtime.utils.Plugin;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
+import java.util.ArrayList;
 import java.util.Set;
-
+import java.util.Map;
 /**
  * memory config management service impl for standalone
  */