You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2023/05/29 06:38:09 UTC
[shardingsphere] branch master updated: Fix checkstyle (#25928)
This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 204cad1c6ff Fix checkstyle (#25928)
204cad1c6ff is described below
commit 204cad1c6ffcfc4ce6d212fba716aca59c7b1559
Author: zhaojinchao <zh...@apache.org>
AuthorDate: Mon May 29 14:38:02 2023 +0800
Fix checkstyle (#25928)
---
.../data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java | 2 +-
.../proxy/backend/connector/jdbc/connection/ResourceLockTest.java | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
index dfbac42f191..bc3f6314d67 100644
--- a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
+++ b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/connector/SocketSinkImporterConnector.java
@@ -184,7 +184,7 @@ public final class SocketSinkImporterConnector implements ImporterConnector, Aut
* Send incremental start event.
*
* @param socketSinkImporter socket sink importer
- * @param batchSize batch size
+ * @param batchSize batch size
*/
public void sendIncrementalStartEvent(final SocketSinkImporter socketSinkImporter, final int batchSize) {
incrementalRecordMap.computeIfAbsent(socketSinkImporter, ignored -> new ArrayBlockingQueue<>(batchSize));
diff --git a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/connection/ResourceLockTest.java b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/connection/ResourceLockTest.java
index 4db57ec9cbb..21b095049ac 100644
--- a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/connection/ResourceLockTest.java
+++ b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/connector/jdbc/connection/ResourceLockTest.java
@@ -68,7 +68,6 @@ class ResourceLockTest {
when(channel.isWritable()).thenReturn(true);
when(channel.isActive()).thenReturn(true);
when(channelHandlerContext.channel()).thenReturn(channel);
- ResourceLock resourceLock = new ResourceLock();
long startTime = System.currentTimeMillis();
ExecutorService executorService = Executors.newFixedThreadPool(1);
executorService.submit(() -> {