[
https://issues.apache.org/jira/browse/FLINK-12561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-12561:
-----------------------------------
Priority: Minor (was: Major)
> 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
> 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)
