[rocketmq-connect] branch master updated: fix checkstyle issue (#304)

[zhoubo]

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

zhoubo 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 4279fa64 fix checkstyle issue (#304)
4279fa64 is described below

commit 4279fa648ba86f448618c7d5809cf0f9423dfb60
Author: Fan Lin <jinji...@alibaba-inc.com>
AuthorDate: Tue Sep 6 17:31:19 2022 +0800

    fix checkstyle issue (#304)
---
 .../connect/runtime/service/StateManagementServiceImpl.java  | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementServiceImpl.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementServiceImpl.java
index 0c20296e..d0d324f3 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementServiceImpl.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementServiceImpl.java
@@ -135,7 +135,7 @@ public class StateManagementServiceImpl implements 
StateManagementService {
         /**connector status map*/
         Map<String, ConnectorStatus> connectorStatusMap = 
connectorStatusStore.getKVMap();
         connectorStatusMap.forEach((connectorName, connectorStatus) -> {
-            if (connectorStatus == null){
+            if (connectorStatus == null) {
                 return;
             }
             // send status
@@ -144,11 +144,11 @@ public class StateManagementServiceImpl implements 
StateManagementService {
 
         /** task status map */
         Map<String, List<TaskStatus>> taskStatusMap = 
taskStatusStore.getKVMap();
-        if (taskStatusMap.isEmpty()){
+        if (taskStatusMap.isEmpty()) {
             return;
         }
         taskStatusMap.forEach((connectorName, taskStatusList) -> {
-            if (taskStatusList == null || taskStatusList.isEmpty()){
+            if (taskStatusList == null || taskStatusList.isEmpty()) {
                 return;
             }
             taskStatusList.forEach(taskStatus -> {
@@ -174,18 +174,18 @@ public class StateManagementServiceImpl implements 
StateManagementService {
      */
     private void prePersist() {
         Map<String, ConnAndTaskStatus.CacheEntry<ConnectorStatus>> connectors 
= connAndTaskStatus.getConnectors();
-        if (connectors.isEmpty()){
+        if (connectors.isEmpty()) {
             return;
         }
         connectors.forEach((connectName, connectorStatus) -> {
             connectorStatusStore.put(connectName, connectorStatus.get());
             Map<Integer, ConnAndTaskStatus.CacheEntry<TaskStatus>> 
cacheTaskStatus = connAndTaskStatus.getTasks().row(connectName);
-            if (cacheTaskStatus == null){
+            if (cacheTaskStatus == null) {
                 return;
             }
             taskStatusStore.put(connectName, new ArrayList<>());
             cacheTaskStatus.forEach((taskId, taskStatus) -> {
-                if (taskStatus != null){
+                if (taskStatus != null) {
                     taskStatusStore.get(connectName).add(taskStatus.get());
                 }
             });