Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ####### stderr log page for app-20170508232546-0055/0
- ERROR 2017-05-08 23:26:00,023 Logging.scala:72 - com.datastax.spark.connector.writer.QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBatchStatement@2dbae165
- com.datastax.driver.core.exceptions.InvalidQueryException: Invalid null value in condition for column date
- at com.datastax.driver.core.Responses$Error.asException(Responses.java:142) ~[dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:170) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:170) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler.access$2400(RequestHandler.java:40) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:790) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:624) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1074) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991) [dse-java-driver-core-1.2.2.jar:na]
- at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1294) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:911) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:934) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:405) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:310) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]
- ERROR 2017-05-08 23:26:00,043 Logging.scala:91 - org.apache.spark.executor.Executor: Exception in task 0.1 in stage 0.0 (TID 1)
- java.io.IOException: Failed to write statements to ks.tbl.
- at com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1.apply(TableWriter.scala:207) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1.apply(TableWriter.scala:175) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:112) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:111) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector.closeResourceAfterUse(CassandraConnector.scala:145) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector.withSessionDo(CassandraConnector.scala:111) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.writeInternal(TableWriter.scala:175) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.insert(TableWriter.scala:162) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.write(TableWriter.scala:149) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.RDDFunctions$$anonfun$saveToCassandra$1.apply(RDDFunctions.scala:36) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.RDDFunctions$$anonfun$saveToCassandra$1.apply(RDDFunctions.scala:36) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:70) ~[spark-core_2.11-2.0.2.6.jar:2.0.2.6]
- at org.apache.spark.scheduler.Task.run(Task.scala:86) ~[spark-core_2.11-2.0.2.6.jar:2.0.2.6]
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:274) ~[spark-core_2.11-2.0.2.6.jar:5.1.0]
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_131]
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_131]
- at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]
- ERROR 2017-05-08 23:26:04,187 Logging.scala:72 - com.datastax.spark.connector.writer.QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBatchStatement@3e01a148
- com.datastax.driver.core.exceptions.InvalidQueryException: Invalid null value in condition for column date
- at com.datastax.driver.core.Responses$Error.asException(Responses.java:142) ~[dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:170) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:170) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler.access$2400(RequestHandler.java:40) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:790) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:624) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1074) [dse-java-driver-core-1.2.2.jar:na]
- at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991) [dse-java-driver-core-1.2.2.jar:na]
- at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:346) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1294) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:367) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:353) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:911) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:934) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:405) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:310) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) [netty-all-4.0.42.Final.jar:4.0.42.Final]
- at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]
- ERROR 2017-05-08 23:26:04,192 Logging.scala:91 - org.apache.spark.executor.Executor: Exception in task 0.3 in stage 0.0 (TID 3)
- java.io.IOException: Failed to write statements to ks.tbl.
- at com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1.apply(TableWriter.scala:207) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1.apply(TableWriter.scala:175) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:112) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:111) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector.closeResourceAfterUse(CassandraConnector.scala:145) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.cql.CassandraConnector.withSessionDo(CassandraConnector.scala:111) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.writeInternal(TableWriter.scala:175) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.insert(TableWriter.scala:162) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.writer.TableWriter.write(TableWriter.scala:149) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.RDDFunctions$$anonfun$saveToCassandra$1.apply(RDDFunctions.scala:36) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at com.datastax.spark.connector.RDDFunctions$$anonfun$saveToCassandra$1.apply(RDDFunctions.scala:36) ~[spark-cassandra-connector-unshaded_2.11-2.0.1.jar:2.0.1]
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:70) ~[spark-core_2.11-2.0.2.6.jar:2.0.2.6]
- at org.apache.spark.scheduler.Task.run(Task.scala:86) ~[spark-core_2.11-2.0.2.6.jar:2.0.2.6]
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:274) ~[spark-core_2.11-2.0.2.6.jar:5.1.0]
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_131]
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_131]
- at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement