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

Put Massive Amounts of Data to Work

Learn how to make your data more available, reduce costs and cut your build time

Watch Now

How OTTO Utilizes Big Data to Deliver Personalized Experiences

Read about OTTO's experiences with Big Data and Personalized Experiences

Blog

Best Practices for Using Context Variables with Talend – Part 4

Pick up some tips and tricks with Context Variables

Blog