Performer returning CANCELLED error

11:32:56.465 [executor-0] ERROR ncurrentTransactionCoordinator - test: From performer (error): {}

io.grpc.StatusRuntimeException: CANCELLED: CANCELLED

    at io.grpc.Status.asRuntimeException(Status.java:539)

    at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:487)

    at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:576)

    at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)

    at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:757)

    at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:736)

    at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)

    at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)

    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)

    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)

    at java.base/java.lang.Thread.run(Thread.java:833)

11:32:56.474 [      main] INFO  ncurrentTransactionCoordinator - Performer is done

org.opentest4j.AssertionFailedError: Did not find any entries for transaction 5d8ee4f4-7b43-49f0-9f19-0a553b2cbd20 on ATR collection default._default._default - remember that ATR collection is by default on default collection of bucket of first mutated doc 

/**

 * Tests:

 * 1. All permutation of two mutating operations on the same doc.

 * 2. That, if the combination is allowed, that if it fails in COMMITTED state, then cleanup can successfully complete it.

 */

@IgnoreWhen(firstPerformerMissesTransactionsCaps = {Caps.EXT_ALL_KV_COMBINATIONS})

@TestFactory

Stream<DynamicTest> allPermutations() {

    return Stream.of(INSERT, REPLACE, REMOVE).flatMap(op1 ->

            Stream.of(INSERT, REPLACE, REMOVE).flatMap(op2 ->

                    Stream.of(true, false).map(commitWithCleanup -> {

                        StringBuilder name = new StringBuilder();

                        name.append(op1);

                        name.append(" -> ");

                        name.append(op2);

                        if (commitWithCleanup) {

                            name.append(" commit with cleanup");

                        }

                        return DynamicTest.dynamicTest(name.toString(), () -> test(op1, op2, commitWithCleanup));

                    })));

}