You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ab...@apache.org on 2026/10/18 23:26:20 UTC
(fluss) branch main updated (70efa0b17 -> 1f352b963)
This is an automated email from the ASF dual-hosted git repository.
fresh-borzoni pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 70efa0b17 [FIP-29][security] Add SslPrincipalMapper for certificate DN to principal mapping (#4641)
new c3b462a5f [rpc] Fix race in Netty client disconnection test
new 1f352b963 fix smaller race
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/fluss/rpc/netty/client/NettyClientTest.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
(fluss) 01/02: [rpc] Fix race in Netty client disconnection test
Posted by ab...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fresh-borzoni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
commit c3b462a5f1db4a93ca6c3de9a569e208fb2212f9
Author: Shangqing Yang <ya...@126.com>
AuthorDate: Sat Oct 17 13:50:14 2026 -0400
[rpc] Fix race in Netty client disconnection test
---
.../test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java b/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
index 4e5d334d7..8386e8f38 100644
--- a/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
+++ b/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
@@ -156,6 +156,9 @@ final class NettyClientTest {
// close the netty server.
nettyServer.close();
+ // Wait for the old connection to be removed before attempting a new connection.
+ retry(Duration.ofSeconds(10), () -> assertThat(nettyClient.connections()).isEmpty());
+
assertThatThrownBy(
() ->
nettyClient
(fluss) 02/02: fix smaller race
Posted by ab...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fresh-borzoni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
commit 1f352b96373d0277fe7c1c2ed4bda0781e5c0535
Author: Anton Borisov <an...@fresha.com>
AuthorDate: Sun Oct 18 23:24:53 2026 +0100
fix smaller race
---
.../test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java b/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
index 8386e8f38..7f2b8a9d3 100644
--- a/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
+++ b/fluss-rpc/src/test/java/org/apache/fluss/rpc/netty/client/NettyClientTest.java
@@ -22,6 +22,7 @@ import org.apache.fluss.cluster.ServerNode;
import org.apache.fluss.cluster.ServerType;
import org.apache.fluss.config.ConfigOptions;
import org.apache.fluss.config.Configuration;
+import org.apache.fluss.exception.DisconnectException;
import org.apache.fluss.exception.NetworkException;
import org.apache.fluss.metrics.groups.MetricGroup;
import org.apache.fluss.metrics.util.NOPMetricsGroup;
@@ -165,8 +166,7 @@ final class NettyClientTest {
.sendRequest(serverNode, ApiKeys.API_VERSIONS, request)
.get())
.rootCause()
- .isInstanceOf(ConnectException.class)
- .hasMessageContaining("Connection refused");
+ .isInstanceOfAny(ConnectException.class, DisconnectException.class);
retry(Duration.ofSeconds(10), () -> assertThat(nettyClient.connections()).isEmpty());
// restart the netty server.