Я пытаюсь создать миллионы вершин из текстового файла через граф Януса, используя spark.
Код JAva:
JavaRDD<String> myRDD = sc.textFile(System.getProperty("user.dir") + File.separator + "vertices.txt");
myRDD.foreachPartition(new VoidFunction<Iterator<String>>() {
public void call(Iterator<String> arg0) throws Exception {
String vertexLabel = "Vertex";
String s = "janusgraph-cassandra.properties";
int count = 0;
JanusGraph graph = JanusGraphFactory.open(s);
TransactionBuilder builder = graph.buildTransaction();
JanusGraphTransaction tx = builder.enableBatchLoading().consistencyChecks(false)
.commitTime(Instant.ofEpochSecond(100)).start();
while (arg0.hasNext()) {
System.out.println(arg0.next());
tx.addVertex(vertexLabel).property("v1", arg0.next().split(":")[1].trim()).property("test",
arg0.next().split(":")[2].split(" ")[0].trim());
tx.addVertex(vertexLabel).property("v2", arg0.next().split(":")[2].split(" ")[1].trim())
.property("test", arg0.next().split(":")[3].trim());
}
tx.commit();
}
});
это исключение:
16:52:34.631 [Executor task launch worker-2] ERROR org.apache.spark.executor.Executor - Exception in task 8.0 in stage 0.0 (TID 8)
com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)
at com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:63) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:25) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68) ~[cassandra-driver-core-3.3.2.jar:na]
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.initializeTable(CQLKeyColumnValueStore.java:236) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.<init>(CQLKeyColumnValueStore.java:161) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.cql.CQLStoreManager.lambda$openDatabase$14(CQLStoreManager.java:398) ~[janusgraph-cql-0.3.1.jar:na]
at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) ~[na:1.8.0_201]
at org.janusgraph.diskstorage.cql.CQLStoreManager.openDatabase(CQLStoreManager.java:398) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.keycolumnvalue.KeyColumnValueStoreManager.openDatabase(KeyColumnValueStoreManager.java:43) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend$6.apply(Backend.java:643) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend$6.apply(Backend.java:638) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend.getLocker(Backend.java:208) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.locking.consistentkey.ExpectedValueCheckingStoreManager.openDatabase(ExpectedValueCheckingStoreManager.java:64) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend.initialize(Backend.java:236) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.graphdb.configuration.GraphDatabaseConfiguration.getBackend(GraphDatabaseConfiguration.java:1926) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.graphdb.database.StandardJanusGraph.<init>(StandardJanusGraph.java:139) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:164) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:133) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:80) ~[janusgraph-core-0.2.2.jar:na]
at com.infa.ldm.converttographjson.App$1.call(App.java:186) ~[classes/:na]
at com.infa.ldm.converttographjson.App$1.call(App.java:1) ~[classes/:na]
at org.apache.spark.api.java.JavaRDDLike$$anonfun$foreachPartition$1.apply(JavaRDDLike.scala:219) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.api.java.JavaRDDLike$$anonfun$foreachPartition$1.apply(JavaRDDLike.scala:219) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:925) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:925) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.scheduler.Task.run(Task.scala:99) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:282) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_201]
Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)
at com.datastax.driver.core.Responses$Error.asException(Responses.java:119) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:535) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1083) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1006) ~[cassandra-driver-core-3.3.2.jar:na]
at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) ~[netty-handler-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:581) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:498) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[netty-common-4.0.56.Final.jar:4.0.56.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.0.56.Final.jar:4.0.56.Final]
... 1 common frames omitted
16:52:34.633 [dispatcher-event-loop-2] DEBUG o.a.s.scheduler.TaskSchedulerImpl - parentName: , name: TaskSet_0.0, runningTasks: 1
16:52:34.634 [task-result-getter-3] INFO o.a.spark.scheduler.TaskSetManager - Lost task 8.0 in stage 0.0 (TID 8) on localhost, executor driver: com.datastax.driver.core.exceptions.ServerError (An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)) [duplicate 6]
16:52:34.634 [dag-scheduler-event-loop] DEBUG o.a.s.s.OutputCommitCoordinator - Ignoring task completion for completed stage
16:52:34.752 [JanusGraph Cluster-nio-worker-2] WARN c.d.driver.core.RequestHandler - /10.65.145.1:9042 replied with server error (java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)), defuncting connection.
16:52:34.752 [JanusGraph Cluster-nio-worker-2] DEBUG com.datastax.driver.core.Host.STATES - Defuncting Connection[/10.65.145.1:9042-2, inFlight=0, closed=false] because: An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)
16:52:34.753 [JanusGraph Cluster-nio-worker-2] DEBUG com.datastax.driver.core.Host.STATES - [/10.65.145.1:9042] preventing new connections for the next 1000 ms
16:52:34.753 [JanusGraph Cluster-nio-worker-2] DEBUG com.datastax.driver.core.Host.STATES - [/10.65.145.1:9042] Connection[/10.65.145.1:9042-2, inFlight=0, closed=false] failed, remaining = 1
16:52:34.753 [JanusGraph Cluster-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[/10.65.145.1:9042-2, inFlight=0, closed=true] closing connection
16:52:34.753 [JanusGraph Cluster-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[/10.65.145.1:9042-2, inFlight=0, closed=true] has already terminated
16:52:34.755 [Executor task launch worker-0] ERROR org.apache.spark.executor.Executor - Exception in task 0.0 in stage 0.0 (TID 0)
com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)
at com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:63) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:25) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68) ~[cassandra-driver-core-3.3.2.jar:na]
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.initializeTable(CQLKeyColumnValueStore.java:236) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.<init>(CQLKeyColumnValueStore.java:161) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.cql.CQLStoreManager.lambda$openDatabase$14(CQLStoreManager.java:398) ~[janusgraph-cql-0.3.1.jar:na]
at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) ~[na:1.8.0_201]
at org.janusgraph.diskstorage.cql.CQLStoreManager.openDatabase(CQLStoreManager.java:398) ~[janusgraph-cql-0.3.1.jar:na]
at org.janusgraph.diskstorage.keycolumnvalue.KeyColumnValueStoreManager.openDatabase(KeyColumnValueStoreManager.java:43) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend$6.apply(Backend.java:643) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend$6.apply(Backend.java:638) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend.getLocker(Backend.java:208) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.locking.consistentkey.ExpectedValueCheckingStoreManager.openDatabase(ExpectedValueCheckingStoreManager.java:64) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.diskstorage.Backend.initialize(Backend.java:236) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.graphdb.configuration.GraphDatabaseConfiguration.getBackend(GraphDatabaseConfiguration.java:1926) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.graphdb.database.StandardJanusGraph.<init>(StandardJanusGraph.java:139) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:164) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:133) ~[janusgraph-core-0.2.2.jar:na]
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:80) ~[janusgraph-core-0.2.2.jar:na]
at com.infa.ldm.converttographjson.App$1.call(App.java:186) ~[classes/:na]
at com.infa.ldm.converttographjson.App$1.call(App.java:1) ~[classes/:na]
at org.apache.spark.api.java.JavaRDDLike$$anonfun$foreachPartition$1.apply(JavaRDDLike.scala:219) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.api.java.JavaRDDLike$$anonfun$foreachPartition$1.apply(JavaRDDLike.scala:219) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:925) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:925) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.scheduler.Task.run(Task.scala:99) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:282) ~[spark-core_2.11-2.1.0.jar:2.1.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_201]
Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)
at com.datastax.driver.core.Responses$Error.asException(Responses.java:119) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:535) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1083) ~[cassandra-driver-core-3.3.2.jar:na]
at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1006) ~[cassandra-driver-core-3.3.2.jar:na]
at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) ~[netty-handler-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[netty-codec-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:581) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:498) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[netty-transport-4.0.56.Final.jar:4.0.56.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[netty-common-4.0.56.Final.jar:4.0.56.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.0.56.Final.jar:4.0.56.Final]
... 1 common frames omitted
16:52:34.757 [dispatcher-event-loop-3] DEBUG o.a.s.scheduler.TaskSchedulerImpl - parentName: , name: TaskSet_0.0, runningTasks: 0
16:52:34.757 [task-result-getter-0] INFO o.a.spark.scheduler.TaskSetManager - Lost task 0.0 in stage 0.0 (TID 0) on localhost, executor driver: com.datastax.driver.core.exceptions.ServerError (An unexpected error occurred server side on /10.65.145.1:9042: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 41efd640-dd2b-11e9-b184-0d520ced114c; expected 41ecf010-dd2b-11e9-b184-0d520ced114c)) [duplicate 7]
16:52:34.757 [dag-scheduler-event-loop] DEBUG o.a.s.s.OutputCommitCoordinator - Ignoring task completion for completed stage
16:52:34.759 [task-result-getter-0] INFO o.a.s.scheduler.TaskSchedulerImpl - Removed TaskSet 0.0, whose tasks have all completed, from pool
16:52:35.631 [JanusGraph Cluster-worker-3] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.631 [JanusGraph Cluster-worker-6] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.631 [JanusGraph Cluster-worker-6] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.632 [JanusGraph Cluster-worker-4] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.632 [JanusGraph Cluster-worker-0] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.633 [JanusGraph Cluster-worker-4] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.633 [JanusGraph Cluster-worker-6] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.633 [JanusGraph Cluster-worker-3] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph
16:52:35.633 [JanusGraph Cluster-worker-6] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema for janusgraph