You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/11 18:08:26 UTC
[incubator-inlong] branch master updated: [INLONG-3070] Fix the warnings about the Javadoc (#3071)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new eba14f8 [INLONG-3070] Fix the warnings about the Javadoc (#3071)
eba14f8 is described below
commit eba14f8aa96c822bc70a2a5f77a71c76a3c8c557
Author: dockerzhang <do...@tencent.com>
AuthorDate: Sat Mar 12 02:08:18 2022 +0800
[INLONG-3070] Fix the warnings about the Javadoc (#3071)
---
codestyle/checkstyle.xml | 12 +-----------
.../org/apache/inlong/agent/message/ProxyMessage.java | 8 ++------
.../java/org/apache/inlong/agent/plugin/Validator.java | 2 +-
inlong-agent/agent-plugins/pom.xml | 11 -----------
.../inlong/agent/plugin/metrics/PluginMetric.java | 18 +++++++++---------
.../inlong/agent/plugin/metrics/SinkMetrics.java | 6 +++---
.../inlong/agent/plugin/metrics/SourceMetrics.java | 6 +++---
.../org/apache/inlong/audit/file/ConfigManager.java | 3 ---
inlong-common/pom.xml | 4 ----
.../apache/inlong/common/msg/InLongMsgAttrBuilder.java | 2 ++
.../org/apache/inlong/dataproxy/sink/TubeSink.java | 6 +++---
.../dataproxy/sink/tubezone/TubeClusterProducer.java | 2 +-
.../inlong/dataproxy/source/DefaultServiceDecoder.java | 3 +++
.../apache/inlong/dataproxy/source/ServiceDecoder.java | 1 +
.../org/apache/inlong/dataproxy/utils/MockUtils.java | 8 ++++----
.../apache/inlong/manager/client/api/InlongClient.java | 2 +-
.../apache/inlong/manager/client/api/InlongGroup.java | 2 ++
.../org/apache/inlong/sdk/dataproxy/MessageSender.java | 12 ++++++------
.../inlong/sdk/dataproxy/http/InternalHttpSender.java | 1 +
.../sdk/dataproxy/pb/PbProtocolMessageSender.java | 2 +-
.../sdk/dataproxy/pb/channel/BufferQueueChannel.java | 2 --
.../apache/inlong/sdk/dataproxy/utils/EncryptUtil.java | 3 +++
.../org/apache/inlong/sdk/dataproxy/utils/IpUtils.java | 2 ++
.../java/org/apache/inlong/sdk/dataproxy/AppTest.java | 1 +
.../inlong/sdk/sort/impl/InLongTopicManagerImpl.java | 2 +-
.../sdk/sort/impl/decode/MessageDeserializer.java | 2 +-
.../sdk/sort/impl/pulsar/InLongPulsarFetcherImpl.java | 2 +-
.../sdk/sort/impl/tube/InLongTubeFetcherImpl.java | 2 +-
inlong-sort/pom.xml | 2 +-
.../inlong/sort/flink/filesystem/BucketAssigner.java | 1 +
.../inlong/sort/flink/filesystem/PartFileInfo.java | 7 ++++---
31 files changed, 60 insertions(+), 77 deletions(-)
diff --git a/codestyle/checkstyle.xml b/codestyle/checkstyle.xml
index dc47976..d81a800 100644
--- a/codestyle/checkstyle.xml
+++ b/codestyle/checkstyle.xml
@@ -85,7 +85,7 @@
</module>
<module name="AvoidStarImport">
<property name="severity" value="error"/>
- </module>
+ </module>
<module name="OneTopLevelClass"/>
<module name="NoLineWrap">
<property name="tokens" value="PACKAGE_DEF, IMPORT, STATIC_IMPORT"/>
@@ -403,16 +403,6 @@
<property name="allowedAnnotations" value="Override, Test"/>
<property name="tokens" value="METHOD_DEF, CTOR_DEF, ANNOTATION_FIELD_DEF"/>
</module>
- <module name="MissingJavadocMethod">
- <property name="severity" value="info"/>
- <property name="scope" value="public"/>
- <!--
- <property name="minLineCount" value="2"/>
- -->
- <property name="minLineCount" value="15"/>
- <property name="allowedAnnotations" value="Override, Test"/>
- <property name="tokens" value="METHOD_DEF, CTOR_DEF, ANNOTATION_FIELD_DEF"/>
- </module>
<module name="MethodName">
<!--
<property name="format" value="^[a-z][a-z0-9][a-zA-Z0-9_]*$"/>
diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/ProxyMessage.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/ProxyMessage.java
index d0bf564..c189b82 100644
--- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/ProxyMessage.java
+++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/ProxyMessage.java
@@ -35,9 +35,7 @@ public class ProxyMessage implements Message {
private final Map<String, String> header;
private final String inlongGroupId;
private final String inlongStreamId;
- /**x
- * determine the group key when making batch
- */
+ // determine the group key when making batch
private final String batchKey;
private String dataKey;
@@ -47,9 +45,7 @@ public class ProxyMessage implements Message {
this.inlongGroupId = header.get(PROXY_KEY_GROUP_ID);
this.inlongStreamId = header.getOrDefault(PROXY_KEY_STREAM_ID, DEFAULT_INLONG_STREAM_ID);
this.dataKey = header.getOrDefault(PROXY_KEY_DATA, "");
- /**
- * use the batch key of user and inlongStreamId to determine one batch
- */
+ // use the batch key of user and inlongStreamId to determine one batch
this.batchKey = dataKey + inlongStreamId;
}
diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Validator.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Validator.java
index 56c749d..6ee6268 100644
--- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Validator.java
+++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Validator.java
@@ -23,7 +23,7 @@ package org.apache.inlong.agent.plugin;
public interface Validator {
/**
- *
+ * validate
* @param messageLine
* @return
*/
diff --git a/inlong-agent/agent-plugins/pom.xml b/inlong-agent/agent-plugins/pom.xml
index a9b20f9..0acbc60 100644
--- a/inlong-agent/agent-plugins/pom.xml
+++ b/inlong-agent/agent-plugins/pom.xml
@@ -29,17 +29,6 @@
<modelVersion>4.0.0</modelVersion>
<name>Apache InLong - Agent Plugins</name>
- <repositories>
- <repository>
- <id>central</id>
- <name>Central Repository</name>
- <url>https://repo.maven.apache.org/maven2</url>
- <layout>default</layout>
- <snapshots>
- <enabled>false</enabled>
- </snapshots>
- </repository>
- </repositories>
<properties>
<powermock.version>2.0.2</powermock.version>
<version.debezium>1.8.1.Final</version.debezium>
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginMetric.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginMetric.java
index 52b4603..496dc68 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginMetric.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginMetric.java
@@ -20,27 +20,27 @@ package org.apache.inlong.agent.plugin.metrics;
public interface PluginMetric {
/**
- * @return The tag name of plugin metrics.
+ * The tag name of plugin metrics.
*/
String getTagName();
/**
- * Increment the count of the read number metric.
+ * Increment the count of the read number metric.
*/
void incReadNum();
/**
- * @return Count of the read number metric.
+ * Count of the read number metric.
*/
long getReadNum();
/**
- * Increment the count of the send number metric.
+ * Increment the count of the send number metric.
*/
void incSendNum();
/**
- * @return Count of the send number metric.
+ * Count of the send number metric.
*/
long getSendNum();
@@ -50,7 +50,7 @@ public interface PluginMetric {
void incReadFailedNum();
/**
- * @return Count of the read failed number metric.
+ * Count of the read failed number metric.
*/
long getReadFailedNum();
@@ -60,7 +60,7 @@ public interface PluginMetric {
void incSendFailedNum();
/**
- * @return Count of the send failed number metric.
+ * Count of the send failed number metric.
*/
long getSendFailedNum();
@@ -70,7 +70,7 @@ public interface PluginMetric {
void incReadSuccessNum();
/**
- * @return Count of the read success number metric.
+ * Count of the read success number metric.
*/
long getReadSuccessNum();
@@ -87,7 +87,7 @@ public interface PluginMetric {
void incSendSuccessNum(int delta);
/**
- * @return Count of the send success number metric.
+ * Count of the send success number metric.
*/
long getSendSuccessNum();
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkMetrics.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkMetrics.java
index 10d4008..7bf3256 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkMetrics.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkMetrics.java
@@ -22,7 +22,7 @@ package org.apache.inlong.agent.plugin.metrics;
public interface SinkMetrics {
/**
- * @return The tag name of sink metrics.
+ * The tag name of sink metrics.
*/
String getTagName();
@@ -32,7 +32,7 @@ public interface SinkMetrics {
void incSinkSuccessCount();
/**
- * @return Count of the sink success metric.
+ * Count of the sink success metric.
*/
long getSinkSuccessCount();
@@ -42,7 +42,7 @@ public interface SinkMetrics {
void incSinkFailCount();
/**
- * @return Count of the sink failed metric.
+ * Count of the sink failed metric.
*/
long getSinkFailCount();
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceMetrics.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceMetrics.java
index 3d69f53..e71bda7 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceMetrics.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceMetrics.java
@@ -22,7 +22,7 @@ package org.apache.inlong.agent.plugin.metrics;
public interface SourceMetrics {
/**
- * @return The tag name of source metrics.
+ * The tag name of source metrics.
*/
String getTagName();
@@ -32,7 +32,7 @@ public interface SourceMetrics {
void incSourceSuccessCount();
/**
- * @return Count of the source success metric.
+ * Count of the source success metric.
*/
long getSourceSuccessCount();
@@ -42,7 +42,7 @@ public interface SourceMetrics {
void incSourceFailCount();
/**
- * @return Count of the source fail metric.
+ * Count of the source fail metric.
*/
long getSourceFailCount();
diff --git a/inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/file/ConfigManager.java b/inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/file/ConfigManager.java
index 0774a4a..5611bf7 100644
--- a/inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/file/ConfigManager.java
+++ b/inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/file/ConfigManager.java
@@ -34,9 +34,6 @@ import org.apache.inlong.audit.file.holder.PropertiesConfigHolder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- *
- */
public class ConfigManager {
private static final Logger LOG = LoggerFactory.getLogger(ConfigManager.class);
diff --git a/inlong-common/pom.xml b/inlong-common/pom.xml
index ea4be1b..52a9534 100644
--- a/inlong-common/pom.xml
+++ b/inlong-common/pom.xml
@@ -85,10 +85,6 @@
<artifactId>je</artifactId>
</dependency>
<dependency>
- <groupId>com.google.code.gson</groupId>
- <artifactId>gson</artifactId>
- </dependency>
- <dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>${common.lang.version}</version>
diff --git a/inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsgAttrBuilder.java b/inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsgAttrBuilder.java
index 784740b..cfbe523 100644
--- a/inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsgAttrBuilder.java
+++ b/inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsgAttrBuilder.java
@@ -143,6 +143,7 @@ public class InLongMsgAttrBuilder {
/**
* buildAttr
* @return
+ *
* @throws Exception
*/
public String buildAttr() throws Exception {
@@ -241,6 +242,7 @@ public class InLongMsgAttrBuilder {
/**
* buildAttr
* @return
+ *
* @throws Exception
*/
public String buildAttr() throws Exception {
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
index 0dfdb6b..cf019ec 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
@@ -155,9 +155,8 @@ public class TubeSink extends AbstractSink implements Configurable {
/**
* when masterUrlLists change, update tubeClient
- *
- * @param originalCluster, previous masterHostAndPortList set
- * @param endCluster, new masterHostAndPortList set
+ * @param originalCluster previous masterHostAndPortList set
+ * @param endCluster new masterHostAndPortList set
*/
public void diffUpdateTubeClient(Set<String> originalCluster, Set<String> endCluster) {
if (SetUtils.isEqualSet(originalCluster, endCluster)) {
@@ -225,6 +224,7 @@ public class TubeSink extends AbstractSink implements Configurable {
*
* @param topic
* @return
+ *
* @throws TubeClientException
*/
private MessageProducer getProducer(String topic) throws TubeClientException {
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeClusterProducer.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeClusterProducer.java
index 276812e..0b8c1a0 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeClusterProducer.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeClusterProducer.java
@@ -106,8 +106,8 @@ public class TubeClusterProducer implements LifecycleAware {
/**
* initTubeConfig
- *
* @return
+ *
* @throws Exception
*/
private TubeClientConfig initTubeConfig() throws Exception {
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/DefaultServiceDecoder.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/DefaultServiceDecoder.java
index d311da3..3a2fda7 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/DefaultServiceDecoder.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/DefaultServiceDecoder.java
@@ -78,6 +78,7 @@ public class DefaultServiceDecoder implements ServiceDecoder {
* @param channel
* @param totalDataLen
* @return
+ *
* @throws
*/
private Map<String, Object> extractNewBinHB(Map<String, Object> resultMap,
@@ -234,6 +235,7 @@ public class DefaultServiceDecoder implements ServiceDecoder {
* @param totalDataLen
* @param msgType
* @return
+ *
* @throws Exception
*/
private Map<String, Object> extractNewBinData(Map<String, Object> resultMap,
@@ -354,6 +356,7 @@ public class DefaultServiceDecoder implements ServiceDecoder {
* @param totalDataLen
* @param msgType
* @return
+ *
* @throws Exception
*/
private Map<String, Object> extractDefaultData(Map<String, Object> resultMap,
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServiceDecoder.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServiceDecoder.java
index ba7778b..8249390 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServiceDecoder.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServiceDecoder.java
@@ -30,6 +30,7 @@ public interface ServiceDecoder {
* @param cb
* @param channel
* @return
+ *
* @throws
*/
Map<String, Object> extractData(ByteBuf cb, Channel channel) throws Exception;
diff --git a/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/utils/MockUtils.java b/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/utils/MockUtils.java
index 102e28b..cd12636 100644
--- a/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/utils/MockUtils.java
+++ b/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/utils/MockUtils.java
@@ -58,8 +58,8 @@ public class MockUtils {
/**
* mockChannel
- *
* @return
+ *
* @throws Exception
*/
public static Channel mockChannel() throws Exception {
@@ -77,8 +77,8 @@ public class MockUtils {
/**
* mockEvent
- *
* @return
+ *
* @throws Exception
*/
public static Event mockEvent() throws Exception {
@@ -96,8 +96,8 @@ public class MockUtils {
/**
* mockPulsarClient
- *
* @return
+ *
* @throws Exception
*/
@SuppressWarnings("unchecked")
@@ -143,8 +143,8 @@ public class MockUtils {
/**
* mockProducer
- *
* @return
+ *
* @throws Exception
*/
@SuppressWarnings({"unchecked"})
diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java
index bc13b16..608ec8a 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java
@@ -37,7 +37,7 @@ import java.util.List;
* InlongStreamBuilder builder = group.createStream(streamConf);
* StreamSource source = ..
* StreamSink sink = ..
- * List<StreamField> fields = ..
+ * List StreamField fields = ..
* InlongStream stream = builder.source(source).sink(sink).fields(fields).init();
* group.init();
* </code>
diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroup.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroup.java
index b604c7d..652a2be 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroup.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroup.java
@@ -32,6 +32,7 @@ public interface InlongGroup {
* Create snapshot for Inlong group
*
* @return
+ *
* @throws Exception
*/
InlongGroupContext context() throws Exception;
@@ -49,6 +50,7 @@ public interface InlongGroup {
* Update Inlong group on updated conf
*
* @return
+ *
* @throws Exception
*/
void update(InlongGroupConf conf) throws Exception;
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MessageSender.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MessageSender.java
index 3c44959..1426ee2 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MessageSender.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MessageSender.java
@@ -54,7 +54,7 @@ public interface MessageSender {
* @param body The data will be sent
*
* @param extraAttrMap The attributes you want to add,
- * and each element of extraAttrMap contains a pair like <attrKey,attrValue>
+ * and each element of extraAttrMap contains a pair like attrKey,attrValue
*/
public SendResult sendMessage(byte[] body, String groupId, String streamId, long dt, String msgUUID,
long timeout, TimeUnit timeUnit, Map<String, String> extraAttrMap);
@@ -75,7 +75,7 @@ public interface MessageSender {
*
* @param bodyList The data will be sent,which is a collection consisting of byte arrays
* @param extraAttrMap The attributes you want to add,
- * and each element of extraAttrMap contains a pair like <attrKey,attrValue>
+ * and each element of extraAttrMap contains a pair like attrKey,attrValue
*/
public SendResult sendMessage(List<byte[]> bodyList, String groupId, String streamId, long dt, String msgUUID,
long timeout, TimeUnit timeUnit, Map<String, String> extraAttrMap);
@@ -101,7 +101,7 @@ public interface MessageSender {
*
* @param body The data will be sent
* @param extraAttrMap The attributes you want to add,
- * and each element of extraAttrMap contains a pair like <attrKey,attrValue>
+ * and each element of extraAttrMap contains a pair like attrKey,attrValue
*/
public void asyncSendMessage(SendMessageCallback callback,
byte[] body, String groupId, String streamId, long dt, String msgUUID,
@@ -136,7 +136,7 @@ public interface MessageSender {
*
* @param bodyList The data will be sent,which is a collection consisting of byte arrays
* @param extraAttrMap The attributes you want to add, and each
- * element of extraAttrMap contains a pair like <attrKey,attrValue>
+ * element of extraAttrMap contains a pair like attrKey,attrValue
*/
public void asyncSendMessage(SendMessageCallback callback,
List<byte[]> bodyList, String groupId, String streamId, long dt, String msgUUID,
@@ -150,7 +150,7 @@ public interface MessageSender {
* @param inlongGroupId
* @param inlongStreamId
* @param body
- * @param callback, callback can be null.
+ * @param callback callback can be null
* @throws ProxysdkException
*/
void asyncSendMessage(String inlongGroupId, String inlongStreamId, byte[] body, SendMessageCallback callback)
@@ -163,7 +163,7 @@ public interface MessageSender {
* @param inlongGroupId
* @param inlongStreamId
* @param bodyList
- * @param callback, callback can be null.
+ * @param callback callback can be null
* @throws ProxysdkException
*/
void asyncSendMessage(String inlongGroupId, String inlongStreamId, List<byte[]> bodyList,
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/http/InternalHttpSender.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/http/InternalHttpSender.java
index 768a311..d44e17f 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/http/InternalHttpSender.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/http/InternalHttpSender.java
@@ -173,6 +173,7 @@ public class InternalHttpSender {
* @param timeUnit
* @param hostInfo
* @return
+ *
* @throws Exception
*/
private SendResult sendByHttp(List<String> bodies, String groupId, String streamId, long dt,
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/PbProtocolMessageSender.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/PbProtocolMessageSender.java
index 5493cf4..bd2ac0e 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/PbProtocolMessageSender.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/PbProtocolMessageSender.java
@@ -56,7 +56,7 @@ public class PbProtocolMessageSender implements MessageSender, Configurable {
/**
* Constructor
*
- * @param context
+ * @param name
*/
public PbProtocolMessageSender(String name) {
lifecycleState = LifecycleState.IDLE;
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueueChannel.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueueChannel.java
index cf69f7e..c1b3c4d 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueueChannel.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueueChannel.java
@@ -57,8 +57,6 @@ public class BufferQueueChannel extends AbstractChannel {
/**
* Constructor
- *
- * @param context
*/
public BufferQueueChannel() {
}
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EncryptUtil.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EncryptUtil.java
index ed43ee9..87f4754 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EncryptUtil.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EncryptUtil.java
@@ -239,6 +239,7 @@ public class EncryptUtil {
* @param publicKey public key
* @param data data
* @return
+ *
* @throws Exception exception
*/
public static byte[] rsaEncrypt(RSAPublicKey publicKey, byte[] data)
@@ -274,6 +275,7 @@ public class EncryptUtil {
* @param privateKey key
* @param encryptedData data
* @return
+ *
* @throws Exception exception
*/
public static byte[] decryptByPrivateKey(RSAPrivateKey privateKey, byte[] encryptedData)
@@ -341,6 +343,7 @@ public class EncryptUtil {
* @param publicKey public key
* @param cipherData cipher data
* @return
+ *
* @throws Exception exception
*/
public static byte[] rsaDecrypt(RSAPublicKey publicKey, byte[] cipherData)
diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/IpUtils.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/IpUtils.java
index a32eba8..9f05690 100644
--- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/IpUtils.java
+++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/IpUtils.java
@@ -40,6 +40,7 @@ public class IpUtils {
* getLocalAddress
*
* @return
+ *
* @throws Exception
*/
public static String getLocalAddress() {
@@ -90,6 +91,7 @@ public class IpUtils {
* getLocalAddressBytes
*
* @return
+ *
* @throws Exception
*/
public static byte[] getLocalAddressBytes() throws Exception {
diff --git a/inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/AppTest.java b/inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/AppTest.java
index 1c262f5..69733e0 100644
--- a/inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/AppTest.java
+++ b/inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/AppTest.java
@@ -37,6 +37,7 @@ public class AppTest
}
/**
+ * suite
* @return the suite of tests being tested
*/
public static Test suite() {
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImpl.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImpl.java
index a4c66ff..f225502 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImpl.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImpl.java
@@ -305,7 +305,7 @@ public class InLongTopicManagerImpl extends InLongTopicManager {
/**
* offline inlong topic which not belong the sortTaskId
*
- * @param oldInLongTopics {@link List<String>}
+ * @param oldInLongTopics {@link List}
*/
private void offlineRmovedTopic(List<String> oldInLongTopics) {
for (String fetchKey : oldInLongTopics) {
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/decode/MessageDeserializer.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/decode/MessageDeserializer.java
index 86e9ecd..145b7ad 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/decode/MessageDeserializer.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/decode/MessageDeserializer.java
@@ -118,7 +118,7 @@ public class MessageDeserializer implements Deserializer {
* transform MessageObjs to SortSdkMessage
*
* @param messageObjs {@link MessageObjs}
- * @return {@link List<InLongMessage>}
+ * @return {@link List}
*/
private List<InLongMessage> transformMessageObjs(ClientContext context, InLongTopic inLongTopic,
MessageObjs messageObjs, String inlongGroupId,
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImpl.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImpl.java
index 9c307cf..112a959 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImpl.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImpl.java
@@ -228,7 +228,7 @@ public class InLongPulsarFetcherImpl extends InLongTopicFetcher {
/**
* put the received msg to onFinished method
*
- * @param messageRecords {@link List<MessageRecord>}
+ * @param messageRecords {@link List}
*/
private void handleAndCallbackMsg(List<MessageRecord> messageRecords) {
long start = System.currentTimeMillis();
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/tube/InLongTubeFetcherImpl.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/tube/InLongTubeFetcherImpl.java
index 7c196f8..7540a19 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/tube/InLongTubeFetcherImpl.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/tube/InLongTubeFetcherImpl.java
@@ -222,7 +222,7 @@ public class InLongTubeFetcherImpl extends InLongTopicFetcher {
* @param splitter {@link Splitter}
* @param attr String
* @param entrySplitterStr String
- * @return {@link Map<String,String>}
+ * @return {@link Map}
*/
private Map<String, String> parseAttr(Splitter splitter, String attr, String entrySplitterStr) {
Map<String, String> map = new HashMap<>();
diff --git a/inlong-sort/pom.xml b/inlong-sort/pom.xml
index 9037a6d..74b4f51 100644
--- a/inlong-sort/pom.xml
+++ b/inlong-sort/pom.xml
@@ -54,7 +54,7 @@
<log4j.configuration>log4j-test.properties</log4j.configuration>
<tubemq.version>${project.version}</tubemq.version>
<commons-lang3.version>3.3.2</commons-lang3.version>
- <clickhouse-jdbc.version>0.3.0</clickhouse-jdbc.version>
+ <clickhouse-jdbc.version>0.3.1</clickhouse-jdbc.version>
<flink.jackson.version>2.12.1-13.0</flink.jackson.version>
<jsr.version>3.0.2</jsr.version>
<snappy.version>1.1.4</snappy.version>
diff --git a/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketAssigner.java b/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketAssigner.java
index dba3b1f..d8efb57 100644
--- a/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketAssigner.java
+++ b/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketAssigner.java
@@ -41,6 +41,7 @@ public interface BucketAssigner<IN, BucketID> extends Serializable {
BucketID getBucketId(IN element, BucketAssigner.Context context);
/**
+ * capable of serializing/deserializing the elements
* @return A {@link SimpleVersionedSerializer} capable of serializing/deserializing the elements
* of type {@code BucketID}. That is the type of the objects returned by the
* {@link #getBucketId(Object, BucketAssigner.Context)}.
diff --git a/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileInfo.java b/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileInfo.java
index aeaa11d..09c73b9 100644
--- a/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileInfo.java
+++ b/inlong-sort/sort-connectors/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileInfo.java
@@ -25,23 +25,24 @@ import java.io.IOException;
public interface PartFileInfo<BucketID> {
/**
+ * The bucket identifier of the current buffer
* @return The bucket identifier of the current buffer, as returned by the
* {@link BucketAssigner#getBucketId(Object, BucketAssigner.Context)}.
*/
BucketID getBucketId();
/**
- * @return The creation time (in ms) of the currently open part file.
+ * The creation time (in ms) of the currently open part file.
*/
long getCreationTime();
/**
- * @return The size of the currently open part file.
+ * The size of the currently open part file.
*/
long getSize() throws IOException;
/**
- * @return The last time (in ms) the currently open part file was written to.
+ * The last time (in ms) the currently open part file was written to.
*/
long getLastUpdateTime();
}