This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push:
new 754fc5d Fix bad merge one last time.
754fc5d is described below
commit 754fc5d075a8c969708551851235901d9db1394a
Author: Brandon Williams <[email protected]>
AuthorDate: Wed Mar 2 13:35:00 2022 -0600
Fix bad merge one last time.
---
src/java/org/apache/cassandra/tools/BulkLoadConnectionFactory.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/java/org/apache/cassandra/tools/BulkLoadConnectionFactory.java
b/src/java/org/apache/cassandra/tools/BulkLoadConnectionFactory.java
index b8fde66..354ed94 100644
--- a/src/java/org/apache/cassandra/tools/BulkLoadConnectionFactory.java
+++ b/src/java/org/apache/cassandra/tools/BulkLoadConnectionFactory.java
@@ -43,7 +43,7 @@ public class BulkLoadConnectionFactory extends
NettyStreamingConnectionFactory
this.outboundBindAny = outboundBindAny;
}
- public NettyStreamingChannel connect(InetSocketAddress to, int
messagingVersion, StreamingChannel.Kind kind) throws IOException
+ public NettyStreamingChannel create(InetSocketAddress to, int
messagingVersion, StreamingChannel.Kind kind) throws IOException
{
// Connect to secure port for all peers if ServerEncryptionOptions is
configured other than 'none'
// When 'all', 'dc' and 'rack', server nodes always have SSL port
open, and since thin client like sstableloader
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
