Jan Lukavský
Jan Lukavský
Offset and limit are concepts inherently incompatible with completeness requirements of transactional processing. We must reject requests with offset and limit on transactional attributes. Prefix reads should be supported. Closes...
We need the ability to distinguish which transformations and replications should run in a specific instance of replication controller. This is generally somewhat possible, but hard to configure.
Subtask of #198
``` [ERROR] BeamGroovyEnvTest.testReduceValueStateByKey [ERROR] Run 1: expected: but was: [INFO] Run 2: PASS [INFO] Run 3: PASS ```
For cases where commit-log cannot support (or it would be too expensive) state-commit-log functionality, we can create a state-commit-log from commit-log by observing the commit-log and periodically persisting the compacted...
Call to ```java StreamElement elem = StreamElement.upsert(..., serialized(value)); Object value = elem.getParsed().get() ``` causes unnecessary serialization and deserialization of `value`. We can extend StreamElement.upsert() with the (optional) deserialized object that...
``` java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park([email protected]/Native Method) - parking to wait for (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...
Create a CountDownLatch wrapper, that will enforce using timeouts and will verify that the result is the count zero was reached. Replace that in all tests.
When multiple attributes with different types of TransactionModes are part of the same transaction, we need to delegate the commit to individual attributes to sub-transaction managers. The transaction will happen...
Design document: https://docs.google.com/document/d/1yPKIczGfi8tit3U89OJS9wEtCc8nIhL6VI6c35lYVhw/edit?usp=sharing