[jira] [Created] (FLINK-12561) Unable to insert into cassandra table using FileWordCount example using Remote Cassandra Host with credentials

[Shang Yuanchun (Jira)]

Ramesh Srinivasalu created FLINK-12561:
------------------------------------------

             Summary: 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.8.0, 1.7.2
         Environment: DEV/QA/Prod
            Reporter: Ramesh Srinivasalu
             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
(v7.6.3#76005)