pjfanning opened a new issue, #327:
URL: https://github.com/apache/pekko-projection/issues/327
```
[2025-10-24 16:53:08,330] [WARN]
[com.datastax.oss.driver.internal.core.control.ControlConnection] []
[s0-admin-1] - [s0] Error connecting to Node(endPoint=/127.0.0.1:9042,
hostId=null, hashCode=4f04b3b9), trying next node (ConnectionInitException:
[s0|control|connecting...] Protocol initialization request, step 1 (OPTIONS):
failed to send request (io.netty.channel.StacklessClosedChannelException)) MDC:
{}
Error: 0-24 16:53:10,586] [ERROR]
[org.apache.pekko.stream.connectors.cassandra.scaladsl.CassandraSession] []
[WordCountDocExampleTest-pekko.actor.default-dispatcher-8] - failed to start
CassandraSession MDC: {pekkoAddress=pekko://WordCountDocExampleTest,
pekkoUid=1833852078567210142,
pekkoSource=CassandraSession(pekko://WordCountDocExampleTest),
sourceThread=WordCountDocExampleTest-pekko.actor.default-dispatcher-3,
sourceActorSystem=WordCountDocExampleTest, pekkoTimestamp=16:53:10.583UTC}
java.util.concurrent.CompletionException:
com.datastax.oss.driver.api.core.AllNodesFailedException: Could not reach any
contact point, make sure you've provided valid addresses (showing first 1
nodes, use getAllErrors() for more): Node(endPoint=/127.0.0.1:9042,
hostId=null, hashCode=4f04b3b9):
[com.datastax.oss.driver.api.core.connection.ConnectionInitException:
[s0|control|connecting...] Protocol initialization request, step 1 (OPTIONS):
failed to send request (io.netty.channel.StacklessClosedChannelException)]
at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
at
java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1141)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2194)
at
com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.lambda$init$3(ControlConnection.java:329)
at
com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.connect(ControlConnection.java:360)
at
com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.lambda$connect$8(ControlConnection.java:400)
at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
at
java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
at
io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
at io.netty.channel.DefaultEventLoop.run(DefaultEventLoop.java:54)
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: com.datastax.oss.driver.api.core.AllNodesFailedException: Could
not reach any contact point, make sure you've provided valid addresses (showing
first 1 nodes, use getAllErrors() for more): Node(endPoint=/127.0.0.1:9042,
hostId=null, hashCode=4f04b3b9):
[com.datastax.oss.driver.api.core.connection.ConnectionInitException:
[s0|control|connecting...] Protocol initialization request, step 1 (OPTIONS):
failed to send request (io.netty.channel.StacklessClosedChannelException)]
at
com.datastax.oss.driver.api.core.AllNodesFailedException.reword(AllNodesFailedException.java:149)
at
com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.lambda$init$3(ControlConnection.java:325)
... 11 common frames omitted
Suppressed:
com.datastax.oss.driver.api.core.connection.ConnectionInitException:
[s0|control|connecting...] Protocol initialization request, step 1 (OPTIONS):
failed to send request (io.netty.channel.StacklessClosedChannelException)
at
com.datastax.oss.driver.internal.core.channel.ProtocolInitHandler$InitRequest.fail(ProtocolInitHandler.java:358)
at
com.datastax.oss.driver.internal.core.channel.ChannelHandlerRequest.writeListener(ChannelHandlerRequest.java:89)
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:590)
at
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:557)
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:492)
at
io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:185)
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
at
com.datastax.oss.driver.internal.core.channel.ChannelHandlerRequest.send(ChannelHandlerRequest.java:78)
at
com.datastax.oss.driver.internal.core.channel.ProtocolInitHandler$InitRequest.send(ProtocolInitHandler.java:195)
at
com.datastax.oss.driver.internal.core.channel.ProtocolInitHandler.onRealConnect(ProtocolInitHandler.java:126)
at
com.datastax.oss.driver.internal.core.channel.ConnectInitHandler.lambda$connect$0(ConnectInitHandler.java:59)
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:590)
at
io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:583)
at
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:559)
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:492)
at
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:636)
at
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:629)
at
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:118)
at
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:326)
at
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:342)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
... 4 common frames omitted
Suppressed:
io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused:
/127.0.0.1:9042
Caused by: java.net.ConnectException: Connection refused
at java.base/sun.nio.ch.Net.pollConnect(Native Method)
at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:682)
at
java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973)
at
io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:336)
at
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: io.netty.channel.StacklessClosedChannelException: null
at
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0()(Unknown Source)
[2025-10-24 16:53:10,600] [INFO]
[org.apache.pekko.actor.CoordinatedShutdown] []
[WordCountDocExampleTest-pekko.actor.default-dispatcher-8] - Running
CoordinatedShutdown with reason [ActorSystemTerminateReason] MDC:
{pekkoAddress=pekko://WordCountDocExampleTest, pekkoUid=1833852078567210142,
pekkoSource=CoordinatedShutdown(pekko://WordCountDocExampleTest),
sourceThread=pool-6-thread-3, sourceActorSystem=WordCountDocExampleTest,
pekkoTimestamp=16:53:10.600UTC}
[2025-10-24 16:53:10,648] [INFO] [org.apache.pekko.event.slf4j.Slf4jLogger]
[] [WordCountDocExampleSpec-pekko.actor.default-dispatcher-4] - Slf4jLogger
started MDC: {}
[info] WordCountDocExampleSpec:
[2025-10-24 16:53:10,784] [INFO]
[com.datastax.oss.driver.internal.core.cql.CqlPrepareAsyncProcessor] []
[WordCountDocExampleSpec-pekko.actor.default-dispatcher-5] - Adding handler to
invalidate cached prepared statements on type changes MDC: {}
[2025-10-24 16:53:10,786] [INFO]
[com.datastax.oss.driver.internal.core.time.Clock] [] [s1-admin-0] - Using
native clock for microsecond precision MDC: {}
[2025-10-24 16:53:13,203] [INFO]
[org.apache.pekko.actor.CoordinatedShutdown] []
[WordCountDocExampleSpec-pekko.actor.default-dispatcher-5] - Running
CoordinatedShutdown with reason [ActorSystemTerminateReason] MDC:
{pekkoAddress=pekko://WordCountDocExampleSpec, pekkoUid=8413726978586462154,
pekkoSource=CoordinatedShutdown(pekko://WordCountDocExampleSpec),
sourceThread=pool-6-thread-3, sourceActorSystem=WordCountDocExampleSpec,
pekkoTimestamp=16:53:13.203UTC}
[info] docs.cassandra.WordCountDocExampleSpec *** ABORTED *** (2 seconds,
492 milliseconds)
[info] com.datastax.oss.driver.api.core.DriverTimeoutException: Query
timed out after PT2S
[info] at
com.datastax.oss.driver.internal.core.cql.CqlRequestHandler.lambda$scheduleTimeout$1(CqlRequestHandler.java:209)
[info] at
io.netty.util.HashedWheelTimer$HashedWheelTimeout.run(HashedWheelTimer.java:713)
[info] at
io.netty.util.concurrent.ImmediateExecutor.execute(ImmediateExecutor.java:34)
[info] at
io.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:701)
[info] at
io.netty.util.HashedWheelTimer$HashedWheelBucket.expireTimeouts(HashedWheelTimer.java:788)
[info] at
io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:501)
[info] at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[info] at java.base/java.lang.Thread.run(Thread.java:1583)
[info] Run completed in 28 seconds, 980 milliseconds.
[info] Total number of tests run: 0
[info] Suites: completed 1, aborted 1
[info] Tests: succeeded 0, failed 0, canceled 0, ignored 0, pending 0
[info] *** 1 SUITE ABORTED ***
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
