[ 
https://issues.apache.org/jira/browse/CASSANDRA-17103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572190#comment-17572190
 ] 

David Capwell commented on CASSANDRA-17103:
-------------------------------------------

More issues seen but in the existing 
org.apache.cassandra.distributed.test.accord.AccordIntegrationTest#multiKeyMultiQuery
 test

{code}
DEBUG [node1_RequestResponseStage-2] node1 2022-07-27 18:29:24,402 
AccordCallback.java:51 - Received failure UNKNOWN from /127.0.0.1:7012
java.lang.RuntimeException: UNKNOWN
        at 
org.apache.cassandra.service.accord.AccordCallback.onFailure(AccordCallback.java:52)
        at 
org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:53)
        at 
org.apache.cassandra.net.InboundSink.lambda$new$0(InboundSink.java:78)
        at 
org.apache.cassandra.net.InboundSink$Filtered.accept(InboundSink.java:64)
        at 
org.apache.cassandra.net.InboundSink$Filtered.accept(InboundSink.java:50)
        at org.apache.cassandra.net.InboundSink.accept(InboundSink.java:97)
        at 
org.apache.cassandra.distributed.impl.Instance.lambda$receiveMessageRunnable$6(Instance.java:485)
        at 
org.apache.cassandra.concurrent.ExecutionFailure$1.run(ExecutionFailure.java:124)
        at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:120)
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:829)
{code}

{code}
// Command{txnId=[1,1658971944759000,0,12700000000107012], status=NotWitnessed, 
txn=null, executeAt=null, deps=[]}
ERROR 01:29:31 Exception in thread Thread[node1_AccordStage-1,5,SharedPool]
java.lang.RuntimeException: java.lang.NullPointerException
        at accord.local.CommandStores.reduce(CommandStores.java:223)
        at accord.local.CommandStores.mapReduce(CommandStores.java:238)
        at accord.local.CommandStores.mapReduce(CommandStores.java:243)
        at accord.local.CommandStores.mapReduce(CommandStores.java:268)
        at accord.local.Node.mapReduceLocal(Node.java:202)
        at accord.messages.Commit.process(Commit.java:45)
        at 
org.apache.cassandra.service.accord.AccordVerbHandler.doVerb(AccordVerbHandler.java:46)
        at 
org.apache.cassandra.net.InboundSink.lambda$new$0(InboundSink.java:78)
        at 
org.apache.cassandra.net.InboundSink$Filtered.accept(InboundSink.java:64)
        at 
org.apache.cassandra.net.InboundSink$Filtered.accept(InboundSink.java:50)
        at org.apache.cassandra.net.InboundSink.accept(InboundSink.java:97)
        at 
org.apache.cassandra.distributed.impl.Instance.lambda$receiveMessageRunnable$6(Instance.java:485)
        at 
org.apache.cassandra.concurrent.ExecutionFailure$1.run(ExecutionFailure.java:124)
        at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:120)
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.NullPointerException: null
        at 
org.apache.cassandra.service.accord.async.AsyncWriter.denormalize(AsyncWriter.java:216)
        at 
org.apache.cassandra.service.accord.async.AsyncWriter.lambda$denormalize$12(AsyncWriter.java:230)
        at java.base/java.util.HashMap$Values.forEach(HashMap.java:977)
        at 
org.apache.cassandra.service.accord.async.AsyncWriter.denormalize(AsyncWriter.java:230)
        at 
org.apache.cassandra.service.accord.async.AsyncWriter.save(AsyncWriter.java:251)
        at 
org.apache.cassandra.service.accord.async.AsyncOperation.run(AsyncOperation.java:100)
        at 
org.apache.cassandra.service.accord.async.AsyncOperation.callback(AsyncOperation.java:77)
        at 
org.apache.cassandra.utils.concurrent.ListenerList$CallbackBiConsumerListener.run(ListenerList.java:247)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        ... 1 common frames omitted
{code}

> CEP-15 (C*): Messaging and storage engine integration
> -----------------------------------------------------
>
>                 Key: CASSANDRA-17103
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-17103
>             Project: Cassandra
>          Issue Type: New Feature
>          Components: Accord
>            Reporter: Benedict Elliott Smith
>            Priority: Normal
>
> This work encompasses implementing Accord’s storage and networking interfaces 
> within Cassandra, so that messages may be sent around the cluster and 
> exectuted



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

Reply via email to