Skip to content

Instantly share code, notes, and snippets.

Uncaught exception on thread Thread[MutationStage-1,5,main]: {}
java.lang.IllegalArgumentException: Mutation of 112.881MiB is too large for the maximum size of 64.000MiB
at org.apache.cassandra.db.commitlog.CommitLog.add(CommitLog.java:255) ~[apache-cassandra-3.11.3.jar:3.11.3]
at org.apache.cassandra.db.Keyspace.applyInternal(Keyspace.java:593) ~[apache-cassandra-3.11.3.jar:3.11.3]
at org.apache.cassandra.db.Keyspace.applyFuture(Keyspace.java:433) ~[apache-cassandra-3.11.3.jar:3.11.3]
at org.apache.cassandra.db.Mutation.applyFuture(Mutation.java:222) ~[apache-cassandra-3.11.3.jar:3.11.3]
at org.apache.cassandra.db.MutationVerbHandler.doVerb(MutationVerbHandler.java:68) ~[apache-cassandra-3.11.3.jar:3.11.3]
at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:66) ~[apache-cassandra-3.11.3.jar:3.11.3]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_162]
at org.apache.cassandra.concurrent.AbstractLocalA
@ortizfabio
ortizfabio / stack_trace_spark_driver
Created February 19, 2020 23:12
Stack trace of Spark executor hanging on Cassandra Spark driver
java.lang.Thread.sleep(Native Method) com.datastax.spark.connector.writer.RateLimiter$$anonfun$$lessinit$greater$default$4$1.apply$mcVJ$sp(RateLimiter.scala:29) com.datastax.spark.connector.writer.RateLimiter$$anonfun$$lessinit$greater$default$4$1.apply(RateLimiter.scala:29) com.datastax.spark.connector.writer.RateLimiter$$anonfun$$lessinit$greater$default$4$1.apply(RateLimiter.scala:29) com.datastax.spark.connector.writer.RateLimiter.maybeSleep(RateLimiter.scala:63) com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1$$anonfun$apply$2.apply(TableWriter.scala:236) com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1$$anonfun$apply$2.apply(TableWriter.scala:233) scala.collection.Iterator$class.foreach(Iterator.scala:893) com.datastax.spark.connector.writer.GroupingBatchBuilder.foreach(GroupingBatchBuilder.scala:31) com.datastax.spark.connector.writer.TableWriter$$anonfun$writeInternal$1.apply(TableWriter.scala:233) com.datastax.spark.connector.writer.TableWriter$$anonfun