[ https://issues.apache.org/jira/browse/FLINK-12561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328416#comment-17328416 ]
Flink Jira Bot commented on FLINK-12561: ---------------------------------------- This major issue is unassigned and itself and all of its Sub-Tasks have not been updated for 30 days. So, it has been labeled "stale-major". If this ticket is indeed "major", please either assign yourself or give an update. Afterwards, please remove the label. In 7 days the issue will be deprioritized. > 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: Major > Labels: stale-major > Fix For: 1.7.3 > > > 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.3.4#803005)