You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/24 08:59:00 UTC
[jira] [Closed] (FLINK-12561) Unable to insert into cassandra table using FileWordCount example using Remote Cassandra Host with credentials
[ https://issues.apache.org/jira/browse/FLINK-12561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser closed FLINK-12561.
----------------------------------
Fix Version/s: (was: 1.7.3)
Resolution: Cannot Reproduce
> Unable to insert into cassandra table using FileWordCount example using Remote Cassandra Host with credentials
> --------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-12561
> URL: https://issues.apache.org/jira/browse/FLINK-12561
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Cassandra
> Affects Versions: 1.7.2, 1.8.0
> Environment: DEV/QA/Prod
> Reporter: Ramesh Srinivasalu
> Priority: Minor
> Labels: auto-deprioritized-major
>
> eculativeRetry=99.0PERCENTILE,droppedColumns={},triggers=[],isDense=false]
> 09:33:55,072 INFO org.apache.cassandra.db.ColumnFamilyStore - Initializing system_auth.role_members
> 09:33:55,317 INFO org.apache.cassandra.transport.Server - Netty using native Epoll event loop
> 09:33:55,356 INFO org.apache.cassandra.transport.Server - Using Netty Version: [netty-buffer=netty-buffer-4.0.33.Final.69b5aef, netty-codec=netty-codec-4.0.33.Final.69b5aef, netty-codec-http=netty-codec-http-4.0.27.Final.054e7c5, netty-codec-socks=netty-codec-socks-4.0.27.Final.054e7c5, netty-common=netty-common-4.0.33.Final.69b5aef, netty-handler=netty-handler-4.0.33.Final.69b5aef, netty-tcnative=netty-tcnative-1.1.32.Fork1.9e735d2, netty-transport=netty-transport-4.0.33.Final.69b5aef, netty-transport-native-epoll=netty-transport-native-epoll-4.0.27.Final.054e7c5, netty-transport-rxtx=netty-transport-rxtx-4.0.27.Final.054e7c5, netty-transport-sctp=netty-transport-sctp-4.0.27.Final.054e7c5, netty-transport-udt=netty-transport-udt-4.0.27.Final.054e7c5]
> 09:33:55,356 INFO org.apache.cassandra.transport.Server - Starting listening for CQL clients on /127.0.0.1:9042...
> 09:33:55,389 INFO org.apache.cassandra.service.CassandraDaemon - Not starting RPC server as requested. Use JMX (StorageService->startRPCServer()) or nodetool (enablethrift) to start it
> 09:33:55,389 INFO org.apache.flink.connectors.cassandra.EmbeddedCassandraService - Embedded Cassasndra service started
> 09:33:55,389 INFO org.apache.flink.connectors.cassandra.datamodel.DataServiceFacade - Bringing up Embedded Cassandra service ... DONE
> 09:33:55,550 INFO com.datastax.driver.core.NettyUtil - Did not find Netty's native epoll transport in the classpath, defaulting to NIO.
> [WARNING]
> com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host testremoteserver.com/192.121.22.1:9042: Host testremoteserver.com/192.121.22.1:9042 requires authentication, but no authenticator found in Cluster configuration
> at com.datastax.driver.core.AuthProvider$1.newAuthenticator(AuthProvider.java:40)
> at com.datastax.driver.core.Connection$5.apply(Connection.java:250)
> at com.datastax.driver.core.Connection$5.apply(Connection.java:234)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.Futures$ChainingListenableFuture.run(Futures.java:906)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.Futures$1$1.run(Futures.java:635)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.MoreExecutors$DirectExecutorService.execute(MoreExecutors.java:299)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.Futures$1.run(Futures.java:632)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:457)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145)
> at org.apache.flink.cassandra.shaded.com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:185)
> at com.datastax.driver.core.Connection$Future.onSet(Connection.java:1174)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1005)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:928)
> at com.datastax.shaded.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at com.datastax.shaded.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at com.datastax.shaded.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at com.datastax.shaded.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)
> at com.datastax.shaded.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at com.datastax.shaded.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at com.datastax.shaded.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
> at com.datastax.shaded.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> at com.datastax.shaded.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> at com.datastax.shaded.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> at com.datastax.shaded.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> at com.datastax.shaded.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at com.datastax.shaded.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
> at java.lang.Thread.run(Thread.java:748)
> 09:34:05,214 WARN org.apache.cassandra.utils.FBUtilities - Trigger directory doesn't exist, please create it and try again.
> 09:34:05,218 INFO org.apache.cassandra.auth.CassandraRoleManager - Created default superuser role 'cassandra'
--
This message was sent by Atlassian Jira
(v8.20.1#820001)