Hi all,
I'm using CassandraSassionProvider 1.12.1 with CosmosDB Cassandra API in
Azure with no problem.
When I tried to migrate the flow to 1.14 NiFi version, it doesn't connect.
I got this error in log:
2021-09-30 14:30:46,449 ERROR [Timer-Driven Process Thread-7]
o.a.n.c.s.StandardControllerServiceNode
StandardControllerServiceNode[service=CassandraSessionProvider[id=3139b034-00a6-30fc-b5bd-cee7c5e5d4c8],
name=CassandraSessionProvider, active=true] Failed to invoke
@OnEnabled method due to
com.datastax.driver.core.exceptions.NoHostAvailableException
: All host(s) tried for query failed (tried:
redacted.cassandra.cosmos.azure.com/redacted:10350
(com.datastax.driver.core.exceptions.TransportException: [
redacted.cassandra.cosmos.azure.com/redacted:10350]
Channel has been closed)): {}
com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried:
redacted.cassandra.cosmos.azure.com/redacted:10350
(com.datastax.driver.core.exceptions.TransportException: [
redacted.cassandra.cosmos.azure.com/redacted:10350]
Channel has been closed))
at
com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:270)
at
com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:109)
at
com.datastax.driver.core.Cluster$Manager.negotiateProtocolVersionAndConnect(Cluster.java:1813)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1726)
at com.datastax.driver.core.Cluster.init(Cluster.java:214)
at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:387)
at com.datastax.driver.core.Cluster.connect(Cluster.java:338)
at
org.apache.nifi.service.CassandraSessionProvider.connectToCassandra(CassandraSessionProvider.java:255)
at
org.apache.nifi.service.CassandraSessionProvider.onEnabled(CassandraSessionProvider.java:175)
at jdk.internal.reflect.GeneratedMethodAccessor776.invoke(Unknown Source)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:145)
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:133)
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:78)
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotation(ReflectionUtils.java:55)
at
org.apache.nifi.controller.service.StandardControllerServiceNode$2.run(StandardControllerServiceNode.java:456)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2021-09-30 14:30:46,450 ERROR [Timer-Driven Process Thread-7]
o.a.n.c.s.StandardControllerServiceNode Failed to invoke @OnEnabled
method of CassandraSessionProvider[id=3139b034-00a6-30fc-b5bd-cee7c5e5d4c8]
due to com.datastax.driver.core.exceptions.NoHostAvailableException
: All host(s) tried for query failed (tried:
redacted.cassandra.cosmos.azure.com/redacted:10350
(com.datastax.driver.core.exceptions.TransportException: [
redacted.cassandra.cosmos.azure.com/redacted:10350]
Channel has been closed))
Someone with same problem?
Thanks.
Eduardo Fontes
