Jan Lukavský
Jan Lukavský
### What needs to happen? After #30789 we can remove support for Flink 1.14 and review code to do cleanup of unneeded version specific code in `runners/flink//src`. ### Issue Priority...
Include the following options: a) `bulk` maximal number of write to be bulked into single on b) `flush` fox maximal time to hold the bulk c) `deflate` (boolean) to indicate...
``` Caused by: java.lang.OutOfMemoryError: Direct buffer memory. The direct out-of-memory error has occurred. This can mean two things: either job(s) require(s) a larger size of JVM direct memory or there...
The combination seems to fail to read the data back after being written.
As part of https://github.com/datadrivencz/proxima-platform/pull/411 `ProximaIO` was introduced. For a proper functionality it needs to know idempotency characteristics of underlying writers. We should add that information to the writers so that...
gRPC has been modularized, we can expand the set of artifacts published as standard modules.
``` java.lang.UnsatisfiedLinkError: could not load FFI provider cz.o2.proxima.cassandra.shaded.jnr.ffi.provider.jffi.Provider at cz.o2.proxima.cassandra.shaded.jnr.ffi.provider.InvalidProvider$1.loadLibrary(InvalidProvider.java:48) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at cz.o2.proxima.cassandra.shaded.jnr.ffi.LibraryLoader.load(LibraryLoader.java:325) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at cz.o2.proxima.cassandra.shaded.jnr.ffi.LibraryLoader.load(LibraryLoader.java:304) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at com.datastax.driver.core.Native$LibCLoader.(Native.java:104) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at com.datastax.driver.core.Native.isGettimeofdayAvailable(Native.java:189) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at com.datastax.driver.core.ClockFactory.newInstance(Clock.java:56) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at com.datastax.driver.core.AbstractMonotonicTimestampGenerator.(AbstractMonotonicTimestampGenerator.java:42) ~[proxima-direct-io-cassandra-0.13-SNAPSHOT.jar:?] at...
``` org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.AssertionError: Combine.globally(Count)/Flatten.PCollections.out: Expected: iterable over [] in any order but: Not matched: at app//org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:374) at app//org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:342) at app//org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:218) at app//org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:67) at app//org.apache.beam.sdk.Pipeline.run(Pipeline.java:323) at app//org.apache.beam.sdk.Pipeline.run(Pipeline.java:309) at app//cz.o2.proxima.beam.direct.io.DirectBatchUnboundedSourceTest.testBatchUnboundedSourceWithCountUsingRepository(DirectBatchUnboundedSourceTest.java:306) at app//cz.o2.proxima.beam.direct.io.DirectBatchUnboundedSourceTest.testBatchUnboundedSourceWithCount(DirectBatchUnboundedSourceTest.java:258)...
``` Error: Tests run: 5, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 13.784 s