Proxima groovy console hang during collect()

[je-ik]

   java.lang.Thread.State: WAITING (parking)
        at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
        - parking to wait for  <0x00000007e97fe138> (a java.util.concurrent.CountDownLatch$Sync)
        at java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:194)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt([email protected]/AbstractQueuedSynchronizer.java:885)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly([email protected]/AbstractQueuedSynchronizer.java:1039)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly([email protected]/AbstractQueuedSynchronizer.java:1345)
        at java.util.concurrent.CountDownLatch.await([email protected]/CountDownLatch.java:232)
        at cz.o2.proxima.beam.tools.groovy.RemoteConsumer$CollectService$$Lambda$1022/0x0000000840981440.run(Unknown Source)
        at cz.o2.proxima.util.ExceptionUtils.ignoringInterrupted(ExceptionUtils.java:157)
        at cz.o2.proxima.beam.tools.groovy.RemoteConsumer$CollectService.awaitAllClosed(RemoteConsumer.java:155)
        at cz.o2.proxima.beam.tools.groovy.RemoteConsumer$Server.close(RemoteConsumer.java:178)
        at cz.o2.proxima.beam.tools.groovy.RemoteConsumer.stop(RemoteConsumer.java:277)
        at cz.o2.proxima.beam.tools.groovy.RemoteConsumer.close(RemoteConsumer.java:298)
        at cz.o2.proxima.beam.tools.groovy.BeamStream.forEach(BeamStream.java:376)
        at cz.o2.proxima.beam.tools.groovy.BeamStream.forEach(BeamStream.java:368)
        at cz.o2.proxima.beam.tools.groovy.BeamStream.collect(BeamStream.java:493)
        at cz.o2.proxima.tools.groovy.Stream$collect$1.call(Unknown Source)
        at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:47)
        at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:125)
        at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:130)
        at groovysh_evaluate7.run(groovysh_evaluate7:3)
        at cz.o2.proxima.tools.groovy.internal.ProximaInterpreter.evaluate(ProximaInterpreter.groovy:58)

Possibly related previous exception:

io.grpc.StatusRuntimeException: CANCELLED: client cancelled
	at io.grpc.Status.asRuntimeException(Status.java:524)
	at io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:284)
	at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:353)
	at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:341)
	at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:861)
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:834)