We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 65f095a commit 37d7fb6Copy full SHA for 37d7fb6
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/client/ServerConnection.java
@@ -94,10 +94,10 @@ final class ServerConnection {
94
ClientAuthenticator authenticator) {
95
this.node = node;
96
this.state = ConnectionState.CONNECTING;
97
+ this.connectionMetricGroup = clientMetricGroup.createConnectionMetricGroup(node.uid());
98
bootstrap
99
.connect(node.host(), node.port())
100
.addListener((ChannelFutureListener) this::establishConnection);
- this.connectionMetricGroup = clientMetricGroup.createConnectionMetricGroup(node.uid());
101
this.authenticator = authenticator;
102
}
103
0 commit comments