dcapwell commented on PR #2144:
URL: https://github.com/apache/cassandra/pull/2144#issuecomment-1439122639
Ran stress and here are exceptions that I saw
```
java.lang.NullPointerException: null
at accord.local.Commands$NotifyWaitingOn.accept(Commands.java:718)
at accord.local.Commands$NotifyWaitingOn.accept(Commands.java:651)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:322)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:309)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:207)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.service.accord.async.AsyncOperation.callback(AsyncOperation.java:158)
at
accord.utils.async.AsyncCallbacks.lambda$null$0(AsyncCallbacks.java:31)
at
org.apache.cassandra.concurrent.ExecutionFailure$1.run(ExecutionFailure.java:133)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
```
java.lang.NullPointerException: null
at accord.primitives.Range$EndInclusive.compareTo(Range.java:47)
at
accord.primitives.AbstractKeys.lambda$findNextIntersection$1(AbstractKeys.java:130)
at accord.utils.SortedArrays.exponentialSearch(SortedArrays.java:604)
at
accord.utils.SortedArrays.findNextIntersection(SortedArrays.java:801)
at
accord.utils.SortedArrays.findNextIntersectionWithMultipleMatches(SortedArrays.java:744)
at
accord.primitives.AbstractKeys.findNextIntersection(AbstractKeys.java:130)
at accord.topology.Topology.subsetFor(Topology.java:257)
at accord.topology.Topology.forSelection(Topology.java:203)
at accord.topology.Topology.forSelection(Topology.java:198)
at
accord.topology.TopologyManager.preciseEpochs(TopologyManager.java:359)
at accord.coordinate.CheckShards.topologyFor(CheckShards.java:57)
at accord.coordinate.CheckShards.<init>(CheckShards.java:49)
at accord.coordinate.MaybeRecover.<init>(MaybeRecover.java:50)
at accord.coordinate.MaybeRecover.maybeRecover(MaybeRecover.java:60)
at accord.local.Node.maybeRecover(Node.java:486)
at
accord.impl.SimpleProgressLog$Instance$State$CoordinateState.lambda$run$6(SimpleProgressLog.java:243)
at accord.local.Node.withEpoch(Node.java:199)
at
accord.impl.SimpleProgressLog$Instance$State$CoordinateState.run(SimpleProgressLog.java:241)
at
accord.impl.SimpleProgressLog$Instance.lambda$run$3(SimpleProgressLog.java:829)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:322)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:309)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:207)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.concurrent.FutureTask$1.call(FutureTask.java:96)
at
org.apache.cassandra.concurrent.FutureTask.call(FutureTask.java:61)
at org.apache.cassandra.concurrent.FutureTask.run(FutureTask.java:71)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
```
java.lang.IllegalStateException: null
at accord.utils.Invariants.illegalState(Invariants.java:44)
at accord.utils.Invariants.illegalState(Invariants.java:49)
at accord.utils.Invariants.checkState(Invariants.java:91)
at
accord.impl.SimpleProgressLog$Instance.invalidated(SimpleProgressLog.java:745)
at accord.local.Commands.commitInvalidate(Commands.java:354)
at
accord.messages.Commit$Invalidate.lambda$process$0(Commit.java:285)
at accord.local.CommandStores$1.apply(CommandStores.java:333)
at accord.local.CommandStores$1.apply(CommandStores.java:329)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForFunction.apply(AsyncOperation.java:300)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForFunction.apply(AsyncOperation.java:287)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:207)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.concurrent.FutureTask$1.call(FutureTask.java:96)
at
org.apache.cassandra.concurrent.FutureTask.call(FutureTask.java:61)
at org.apache.cassandra.concurrent.FutureTask.run(FutureTask.java:71)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
```
java.lang.IllegalStateException: null
at accord.utils.Invariants.illegalState(Invariants.java:44)
at accord.utils.Invariants.illegalState(Invariants.java:49)
at accord.utils.Invariants.checkState(Invariants.java:91)
at
accord.impl.SimpleProgressLog$Instance.invalidated(SimpleProgressLog.java:745)
at accord.local.Commands.commitInvalidate(Commands.java:354)
at
accord.coordinate.Invalidate.lambda$commitInvalidate$2(Invalidate.java:271)
at accord.local.CommandStores$1.apply(CommandStores.java:333)
at accord.local.CommandStores$1.apply(CommandStores.java:329)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForFunction.apply(AsyncOperation.java:300)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForFunction.apply(AsyncOperation.java:287)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:207)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.concurrent.FutureTask$1.call(FutureTask.java:96)
at
org.apache.cassandra.concurrent.FutureTask.call(FutureTask.java:61)
at org.apache.cassandra.concurrent.FutureTask.run(FutureTask.java:71)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
```
java.lang.IllegalArgumentException: Unsupported listener type:
accord.messages.Defer
at
org.apache.cassandra.service.accord.serializers.ListenerSerializers$Kind.of(ListenerSerializers.java:47)
at
org.apache.cassandra.service.accord.serializers.ListenerSerializers$Kind.access$000(ListenerSerializers.java:35)
at
org.apache.cassandra.service.accord.serializers.ListenerSerializers$3.serializedSize(ListenerSerializers.java:134)
at
org.apache.cassandra.service.accord.serializers.ListenerSerializers$3.serializedSize(ListenerSerializers.java:95)
at
org.apache.cassandra.io.LocalVersionedSerializer.serializedSize(LocalVersionedSerializer.java:91)
at
org.apache.cassandra.service.accord.AccordKeyspace.serialize(AccordKeyspace.java:317)
at
org.apache.cassandra.service.accord.AccordKeyspace.lambda$getCommandMutation$5(AccordKeyspace.java:510)
at
org.apache.cassandra.service.accord.AccordKeyspace.addSetChanges(AccordKeyspace.java:440)
at
org.apache.cassandra.service.accord.AccordKeyspace.getCommandMutation(AccordKeyspace.java:510)
at
org.apache.cassandra.service.accord.async.AsyncWriter.lambda$assembleWrites$1(AsyncWriter.java:88)
at java.base/java.util.HashMap.forEach(HashMap.java:1337)
at
org.apache.cassandra.service.accord.async.AsyncWriter.assembleWrites(AsyncWriter.java:85)
at
org.apache.cassandra.service.accord.async.AsyncWriter.maybeDispatchWrites(AsyncWriter.java:116)
at
org.apache.cassandra.service.accord.async.AsyncWriter.save(AsyncWriter.java:155)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:213)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.service.accord.async.AsyncOperation.callback(AsyncOperation.java:158)
at
accord.utils.async.AsyncCallbacks.lambda$null$0(AsyncCallbacks.java:31)
at
org.apache.cassandra.concurrent.ExecutionFailure$1.run(ExecutionFailure.java:133)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
```
java.lang.NullPointerException: null
at
org.apache.cassandra.service.accord.serializers.CommandSerializers$TimestampSerializer.serialize(CommandSerializers.java:81)
at
org.apache.cassandra.service.accord.serializers.CommandsForKeySerializer$AccordCFKLoader.saveForCFK(CommandsForKeySerializer.java:139)
at
org.apache.cassandra.service.accord.serializers.CommandsForKeySerializer$AccordCFKLoader.saveForCFK(CommandsForKeySerializer.java:79)
at
accord.impl.CommandsForKey$CommandTimeseries$Update.add(CommandsForKey.java:214)
at
accord.impl.SafeCommandsForKey.listenerUpdate(SafeCommandsForKey.java:116)
at
accord.impl.CommandsForKey$Listener.onChange(CommandsForKey.java:271)
at
accord.local.SafeCommandStore.lambda$notifyListeners$1(SafeCommandStore.java:115)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:322)
at
org.apache.cassandra.service.accord.async.AsyncOperation$ForConsumer.apply(AsyncOperation.java:309)
at
org.apache.cassandra.service.accord.async.AsyncOperation.runInternal(AsyncOperation.java:207)
at
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:247)
at
org.apache.cassandra.service.accord.async.AsyncOperation.callback(AsyncOperation.java:158)
at
accord.utils.async.AsyncCallbacks.lambda$null$0(AsyncCallbacks.java:31)
at
org.apache.cassandra.concurrent.ExecutionFailure$1.run(ExecutionFailure.java:133)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]