Job Failure: tCassandraInput_1 Cassandra failure during read

Four Stars

Job Failure: tCassandraInput_1 Cassandra failure during read

One of the job is failing while migrating data from DataStax cassandra to cassandra..

Since we have more than 600GB per node and we have 17 nodes. So when we use "tCassandraInput_1" and provide a select query to fetch data to tMap it will throw an error as cassandra will not support select query for bigger Dataset. 

Please let us know which component to use or how to resolve this issue.

Below is the error we are getting:

Starting job ras_stream2batch_device_hourly_data at 14:28 28/03/2019.

[INFO ]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - TalendJob: 'ras_stream2batch_device_hourly_data' - Start.
[statistics] connecting to socket on port 3639
[statistics] connected
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_3 - Start to work.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_3 - ParametersSmiley Very HappyB_VERSION = CASSANDRA_3_0 | HOST = "172.29.78.4" | PORT = "9042" | REQUIRED_AUTHENTICATION = true | USERNAME = "nayanjyoti.bhagawati@lca.honeywell.com" | PASSWORD = 9ec0... | USE_HTTPS = false |
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
[DEBUG]: com.datastax.shaded.netty.util.internal.logging.InternalLoggerFactory - Using Log4J as the default logging framework
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - Platform: Windows
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - Java version: 8
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - sun.misc.Unsafe: available
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - Javassist: unavailable
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - You don't have Javassist in your class path or you don't have enough permission to load dynamically generated classes. Please check the configuration for better performance.
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - -Dio.netty.tmpdir: C:\Users\NayanJyotiB\AppData\Local\Temp (java.io.tmpdir)
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
[DEBUG]: com.datastax.shaded.netty.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
[DEBUG]: com.datastax.shaded.netty.channel.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 16
[DEBUG]: com.datastax.shaded.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
[DEBUG]: com.datastax.shaded.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@429bd883
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@4d49af10
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@279ad2e3
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@58134517
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@4450d156
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@4461c7e3
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@351d0846
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@77e4c80f
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@35fc6dc4
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@7fe8ea47
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@226a82c4
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@731f8236
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@255b53dc
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@1dd92fe2
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@6b53e23f
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@64d2d351
[DEBUG]: com.datastax.shaded.netty.util.ResourceLeakDetector - -Dcom.datastax.shaded.netty.leakDetection.level: simple
[DEBUG]: com.datastax.shaded.netty.util.ResourceLeakDetector - -Dcom.datastax.shaded.netty.leakDetection.maxRecords: 4
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 16
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 16
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
[DEBUG]: com.datastax.shaded.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
[DEBUG]: com.datastax.shaded.netty.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0xce914775fc99d009 (took 1 ms)
[DEBUG]: com.datastax.shaded.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
[DEBUG]: com.datastax.shaded.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 65536
[DEBUG]: com.datastax.shaded.netty.buffer.ByteBufUtil - -Dio.netty.maxThreadLocalCharBufferSize: 16384
[DEBUG]: com.datastax.shaded.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144
[DEBUG]: com.datastax.shaded.netty.buffer.AbstractByteBuf - -Dcom.datastax.shaded.netty.buffer.bytebuf.checkAccessible: true
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_3 - Done.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_2 - Start to work.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_2 - ParametersSmiley Very HappyB_VERSION = CASSANDRA_3_0 | HOST = "172.16.3.4" | PORT = "9042" | REQUIRED_AUTHENTICATION = true | USERNAME = "elassadmin" | PASSWORD = 1f59... | USE_HTTPS = false |
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@37883b97
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@6ab778a
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@4e3958e7
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@77f80c04
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@1dac5ef
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@5c90e579
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@58ea606c
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@6f45df59
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@38e79ae3
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@63070bab
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@68e5eea7
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@291b4bf5
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@2d2ffcb7
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@762ef0ea
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@31f9b85e
[TRACE]: com.datastax.shaded.netty.channel.nio.NioEventLoop - Instrumented an optimized java.util.Set into: sun.nio.ch.WindowsSelectorImpl@424e1977
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraConnection_2 - Done.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tFlowToIterate_1 - Start to work.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tFlowToIterate_1 - ParametersSmiley Very HappyEFAULT_MAP = false | MAP = [{VALUE=hour, KEY="hour"}, {VALUE=group_id, KEY="group_id"}] |
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraInput_1 - Start to work.
[DEBUG]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraInput_1 - Parameters:USE_EXISTING_CONNECTION = true | CONNECTION = tCassandraConnection_3 | KEY_SPACE = "ras_stream2batch" | COLUMN_FAMILY = "device_hourly_data" | QUERY = "select distinct hour, group_id from ras_stream2batch.device_hourly_data" |
[FATAL]: migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data - tCassandraInput_1 Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:85)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:27)
at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tCassandraInput_1Process(ras_stream2batch_device_hourly_data.java:2010)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tCassandraConnection_3Process(ras_stream2batch_device_hourly_data.java:701)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tPrejob_1Process(ras_stream2batch_device_hourly_data.java:483)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.runJobInTOS(ras_stream2batch_device_hourly_data.java:3149)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.main(ras_stream2batch_device_hourly_data.java:2977)
Caused by: com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:95)
at com.datastax.driver.core.Responses$Error.asException(Responses.java:128)
at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:179)
at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:184)
at com.datastax.driver.core.RequestHandler.access$2500(RequestHandler.java:43)
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:798)
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:617)
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(Unknown Source)
Caused by: com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:76)
at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:266)
at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:246)
at com.datastax.shaded.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
... 14 more
Exception in component tCassandraInput_1 (ras_stream2batch_device_hourly_data)
com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:85)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:27)
at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tCassandraInput_1Process(ras_stream2batch_device_hourly_data.java:2010)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tCassandraConnection_3Process(ras_stream2batch_device_hourly_data.java:701)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.tPrejob_1Process(ras_stream2batch_device_hourly_data.java:483)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.runJobInTOS(ras_stream2batch_device_hourly_data.java:3149)
at migrationtdp.ras_stream2batch_device_hourly_data_0_1.ras_stream2batch_device_hourly_data.main(ras_stream2batch_device_hourly_data.java:2977)
Caused by: com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.exceptions.ReadFailureException.copy(ReadFailureException.java:95)
at com.datastax.driver.core.Responses$Error.asException(Responses.java:128)
at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:179)
at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:184)
at com.datastax.driver.core.RequestHandler.access$2500(RequestHandler.java:43)
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:798)
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:617)
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(Unknown Source)
Caused by: com.datastax.driver.core.exceptions.ReadFailureException: Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)
at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:76)
at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:266)
at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:246)
at com.datastax.shaded.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
... 14 more
[statistics] disconnected

Job ras_stream2batch_device_hourly_data ended at 14:28 28/03/2019. [exit code=1]

Eleven Stars

Re: Job Failure: tCassandraInput_1 Cassandra failure during read

This is datastax documentation on this error . Hope this will be helpful 

 

https://support.datastax.com/hc/en-us/articles/204612559-ReadTimeoutException-seen-when-using-the-ja...

Regards
Abhishek KUMAR
Four Stars

Re: Job Failure: tCassandraInput_1 Cassandra failure during read

Thanks Abhishek,

We have read this article but we can't change the gc_grace_seconds to below as we already have bigger grace period and its in production.

alter table example with gc_grace_seconds = 10000

 Any suggestion really help.

 

Best Regards,

 

2019 GARNER MAGIC QUADRANT FOR DATA INTEGRATION TOOL

Talend named a Leader.

Get your copy

OPEN STUDIO FOR DATA INTEGRATION

Kickstart your first data integration and ETL projects.

Download now

What’s New for Talend Summer ’19

Watch the recorded webinar!

Watch Now

Best Practices for Using Context Variables with Talend – Part 2

Part 2 of a series on Context Variables

Blog

Best Practices for Using Context Variables with Talend – Part 1

Learn how to do cool things with Context Variables

Blog

Migrate Data from one Database to another with one Job using the Dynamic Schema

Find out how to migrate from one database to another using the Dynamic schema

Blog