fix ci check error

build.gradle

@@ -95,7 +95,8 @@ allprojects {
 
     checkstyleMain.exclude('**/org/apache/eventmesh/client/grpc/protos**')
             .exclude('**/org/apache/eventmesh/common/protocol/grpc/cloudevents**')
-            .exclude('**/org/apache/eventmesh/common/protocol/grpc/protos/**')
+            .exclude('**/org/apache/eventmesh/common/protocol/grpc/proto**')
+            .exclude('**/org/apache/eventmesh/common/protocol/grpc/adminserver/**')
             .exclude('**/org/apache/eventmesh/connector/openfunction/client/EventMeshGrpcService**')
             .exclude('**/org/apache/eventmesh/connector/openfunction/client/CallbackServiceGrpc**')
             .exclude('**/org/apache/eventmesh/connector/jdbc/antlr**')
@@ -405,7 +406,7 @@ tasks.register('checkDeniedLicense') {
                 "BSD-4-Clause", "BSD-4-Clause-UC", "NPL-1.0", "NPL-1.1", "JSON"
         ]
         // Update exemptions according to https://github.com/apache/eventmesh/issues/4842
-        def allowedArtifacts = ["amqp-client", "stax-api", "javassist", "ST4", "xsdlib"]
+        def allowedArtifacts = ["amqp-client", "stax-api", "javassist", "ST4", "xsdlib", "jsqlparser"]
 
         def licenseFile = file('tools/dist-license/LICENSE')
         def lines = licenseFile.readLines()

eventmesh-admin-server/build.gradle

@@ -37,7 +37,7 @@ dependencies {
 
 	// https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter
 	implementation "com.alibaba:druid-spring-boot-starter"
-	runtimeOnly 'com.mysql:mysql-connector-j'
+	compileOnly 'com.mysql:mysql-connector-j'
 	compileOnly 'org.projectlombok:lombok'
 	annotationProcessor 'org.projectlombok:lombok'
 }

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServer.java

@@ -31,12 +31,12 @@
 
 import org.apache.commons.lang3.StringUtils;
 
+import javax.annotation.PostConstruct;
+
 import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.PostConstruct;
-
 import lombok.extern.slf4j.Slf4j;
 
 @Service

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/AdminGrpcServer.java

@@ -48,15 +48,12 @@ public class AdminGrpcServer extends AdminServiceGrpc.AdminServiceImplBase {
 
     private Payload process(Payload value) {
         if (value == null || StringUtils.isBlank(value.getMetadata().getType())) {
-            return PayloadUtil.from(FailResponse.build(ErrorCode.BAD_REQUEST, "bad request: type not " +
-                "exists"));
+            return PayloadUtil.from(FailResponse.build(ErrorCode.BAD_REQUEST, "bad request: type not exists"));
         }
         try {
-            BaseRequestHandler<BaseRemoteRequest, BaseRemoteResponse> handler =
-                handlerFactory.getHandler(value.getMetadata().getType());
+            BaseRequestHandler<BaseRemoteRequest, BaseRemoteResponse> handler = handlerFactory.getHandler(value.getMetadata().getType());
             if (handler == null) {
-                return PayloadUtil.from(FailResponse.build(BaseRemoteResponse.UNKNOWN,
-                    "not match any request handler"));
+                return PayloadUtil.from(FailResponse.build(BaseRemoteResponse.UNKNOWN, "not match any request handler"));
             }
             BaseRemoteResponse response = handler.handlerRequest((BaseRemoteRequest) PayloadUtil.parse(value), value.getMetadata());
             if (response == null || response instanceof EmptyAckResponse) {
@@ -66,8 +63,7 @@ private Payload process(Payload value) {
         } catch (Exception e) {
             log.warn("process payload {} fail", value.getMetadata().getType(), e);
             if (e instanceof AdminServerRuntimeException) {
-                return PayloadUtil.from(FailResponse.build(((AdminServerRuntimeException) e).getCode(),
-                    e.getMessage()));
+                return PayloadUtil.from(FailResponse.build(((AdminServerRuntimeException) e).getCode(), e.getMessage()));
             }
             return PayloadUtil.from(FailResponse.build(ErrorCode.INTERNAL_ERR, "admin server internal err"));
         }

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/BaseServer.java

@@ -18,7 +18,6 @@
 package org.apache.eventmesh.admin.server.web;
 
 import org.apache.eventmesh.admin.server.ComponentLifeCycle;
-
 import org.apache.eventmesh.common.remote.payload.PayloadFactory;
 
 import javax.annotation.PostConstruct;

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshDataSource.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_data_source
+ * event_mesh_data_source
  */
 @TableName(value = "event_mesh_data_source")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshJobInfo.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_job_info
+ * event_mesh_job_info
  */
 @TableName(value = "event_mesh_job_info")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshMysqlPosition.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_mysql_position
+ * event_mesh_mysql_position
  */
 @TableName(value = "event_mesh_mysql_position")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshPositionReporterHistory.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_position_reporter_history
+ * event_mesh_position_reporter_history
  */
 @TableName(value = "event_mesh_position_reporter_history")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshRuntimeHeartbeat.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_runtime_heartbeat
+ * event_mesh_runtime_heartbeat
  */
 @TableName(value = "event_mesh_runtime_heartbeat")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/entity/EventMeshRuntimeHistory.java

@@ -27,7 +27,7 @@
 import lombok.Data;
 
 /**
- * @TableName event_mesh_runtime_history
+ * event_mesh_runtime_history
  */
 @TableName(value = "event_mesh_runtime_history")
 @Data

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshDataSourceService.java

@@ -23,8 +23,8 @@
 
 /**
 * 
-* for table `event_mesh_data_source】的数据库操作Service
-* @createDate 2024-05-09 15:52:49
+* for table 'event_mesh_data_source' db operation
+* 2024-05-09 15:52:49
 */
 public interface EventMeshDataSourceService extends IService<EventMeshDataSource> {
 

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/RequestHandlerFactory.java

@@ -58,8 +58,8 @@ public void onApplicationEvent(ContextRefreshedEvent event) {
                 continue;
             }
 
-            Class tClass = (Class) ((ParameterizedType) clazz.getGenericSuperclass()).getActualTypeArguments()[0];
-            handlers.putIfAbsent(tClass.getSimpleName(), requestHandler);
+            Class c = (Class) ((ParameterizedType) clazz.getGenericSuperclass()).getActualTypeArguments()[0];
+            handlers.putIfAbsent(c.getSimpleName(), requestHandler);
         }
     }
 }

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/heatbeat/EventMeshRuntimeHeartbeatBizService.java

@@ -30,8 +30,7 @@
 import lombok.extern.slf4j.Slf4j;
 
 /**
- * for table 'event_mesh_runtime_heartbeat' db operation
- * 2024-05-14 17:15:03
+ * for table 'event_mesh_runtime_heartbeat' db operation 2024-05-14 17:15:03
  */
 @Service
 @Slf4j
@@ -51,8 +50,8 @@ public boolean saveOrUpdateByRuntimeAddress(EventMeshRuntimeHeartbeat entity) {
             return heartbeatService.save(entity);
         } else {
             if (Long.parseLong(old.getReportTime()) >= Long.parseLong(entity.getReportTime())) {
-                log.info("update heartbeat record ignore, current report time late than db, job " +
-                    "[{}], remote [{}]", entity.getJobID(), entity.getRuntimeAddr());
+                log.info("update heartbeat record ignore, current report time late than db, job [{}], remote [{}]", entity.getJobID(),
+                    entity.getRuntimeAddr());
                 return true;
             }
             try {

eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/EventMeshJobInfoBizService.java

@@ -34,11 +34,11 @@
 
 import org.apache.commons.lang3.StringUtils;
 
+import java.util.Map;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.Map;
-
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.fasterxml.jackson.core.type.TypeReference;
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java

@@ -19,16 +19,16 @@
 
 import static org.apache.eventmesh.common.Constants.HTTP;
 
-import org.apache.commons.collections4.CollectionUtils;
-
 import org.apache.eventmesh.common.Constants;
 import org.apache.eventmesh.common.utils.IPUtils;
 
-import org.assertj.core.util.Strings;
+import org.apache.commons.collections4.CollectionUtils;
 
 import java.util.Collections;
 import java.util.List;
 
+import org.assertj.core.util.Strings;
+
 import lombok.Data;
 import lombok.NoArgsConstructor;
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java

@@ -21,8 +21,6 @@
 
 import org.apache.commons.lang3.StringUtils;
 
-import org.assertj.core.util.Strings;
-
 import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
@@ -31,6 +29,8 @@
 import java.util.Objects;
 import java.util.Properties;
 
+import org.assertj.core.util.Strings;
+
 import lombok.Getter;
 
 public class ConfigService {

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/FileLoad.java

@@ -68,6 +68,7 @@ class PropertiesFileLoad implements FileLoad {
         private final Convert convert = new Convert();
 
         @SuppressWarnings("unchecked")
+        @Override
         public <T> T getConfig(ConfigInfo configInfo) throws IOException {
             final Properties properties = new Properties();
             if (StringUtils.isNotBlank(configInfo.getResourceUrl())) {

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka/KafkaSinkConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SinkConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class KafkaSinkConfig extends SinkConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/kafka/KafkaSourceConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SourceConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class KafkaSourceConfig extends SourceConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar/PulsarSinkConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SinkConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class PulsarSinkConfig extends SinkConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/mq/pulsar/PulsarSourceConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SourceConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class PulsarSourceConfig extends SourceConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSinkConfig.java

@@ -33,7 +33,7 @@ public class CanalSinkConfig extends SinkConfig {
 
     private Integer poolSize = 5;                           // sink thread size for single channel
 
-    private SyncMode syncMode;                              // sync mode：column/row
+    private SyncMode syncMode;                              // sync mode: field/row
 
     private Boolean skipException = false;                  // skip sink process exception
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSourceConfig.java

@@ -56,9 +56,7 @@ public class CanalSourceConfig extends SourceConfig {
 
     private Boolean enableRemedy = false;                                             // enable remedy
 
-//    private RemedyAlgorithm remedyAlgorithm;                                          // remedyAlgorithm
-
-    private SyncMode syncMode;                                                 // sync mode：column/row
+    private SyncMode syncMode;                                                 // sync mode: field/row
 
     private SyncConsistency syncConsistency;                                          // sync consistency
 
@@ -71,7 +69,8 @@ public class CanalSourceConfig extends SourceConfig {
 
     private String systemMarkTableColumn;                                    // Column name of the bidirectional synchronization mark
 
-    private String systemMarkTableInfo;                                      // nfo information of the bidirectional synchronization mark, similar to BI_SYNC
+    private String systemMarkTableInfo;
+    // nfo information of the bidirectional synchronization mark, similar to BI_SYNC
 
     private String systemBufferTable;                                        // sync buffer table
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb/MongodbSinkConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SinkConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class MongodbSinkConfig extends SinkConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/mongodb/MongodbSourceConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SourceConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class MongodbSourceConfig extends SourceConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis/RedisSinkConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SinkConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class RedisSinkConfig extends SinkConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/redis/RedisSourceConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SourceConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class RedisSourceConfig extends SourceConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/s3/S3SourceConfig.java

@@ -20,7 +20,9 @@
 import org.apache.eventmesh.common.config.connector.SourceConfig;
 
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 
+@EqualsAndHashCode(callSuper = true)
 @Data
 public class S3SourceConfig extends SourceConfig {
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/SyncConsistency.java

@@ -19,15 +19,15 @@
 
 public enum SyncConsistency {
     /**
-     * 基于当前介质最新数据
+     * based with media
      */
     MEDIA("M"),
     /**
-     * 基于当前的store记录的数据
+     * based with store
      */
     STORE("S"),
     /**
-     * 基于当前的变更value，最终一致性
+     * Based on the current change value, eventual consistency
      */
     BASE("B");
 

eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/job/SyncMode.java

@@ -18,14 +18,18 @@
 package org.apache.eventmesh.common.remote.job;
 
 public enum SyncMode {
-    /** 行记录 */
+    /**
+     * row
+     */
     ROW("R"),
-    /** 字段记录 */
+    /**
+     * field
+     */
     FIELD("F");
 
     private String value;
 
-    SyncMode(String value){
+    SyncMode(String value) {
         this.value = value;
     }