Aris

I can't explain why, but sdkman + ``` sdk install java 11.0.13.fx-zulu ``` did the trick for me.

Stephan Ewen and his team are absolute experts in concurrency. Flink does an insane amount of work to very efficiently manage memory, buffers and network connections on top of a...

Hi @salvalcantara, The motivations behind the very existence of `flink4s` are twofold: - Drop in replacement for flink-streaming-scala, so that existing projects can migrate to Scala 3.x without much refactoring....

Hi @salvalcantara ! I haven't seen `flink-type-info` before. It seems to be focusing on deriving TypeInformation instances using shapeless (instead of the macro Flink provides). Shapeless doesn't support Scala 3.x...

Flink4s requires an in implicit `TypeInformaton` instance to work, but it has no opinion as to how this is generated. Flink4s and flink-adt *should* work together fine (in 2.13.4+ at...

Hey @salvalcantara I was the first to star `flink-scala-api`. It is a pure port of the existing code, so likely easier to migrate. My aim for flink4s was to create...

`submitQuery` is private because the implementation is incomplete. This method should respond only if the current node is **still** the leader. I think it would be best if `submitQuery` was...

Hey @sami-badawi ! This is a JVM issue. This has been fixed in RocksDB's latest version but it is likely that Flink isn't yet using it. I fixed this issue...

Hey @sami-badawi Unfortunately I don't have an M1 anymore to reproduce. I solved the issue using: - https://itnext.io/how-to-install-x86-and-arm-jdks-on-the-mac-m1-apple-silicon-using-sdkman-872a5adc050d - https://github.com/facebook/rocksdb/issues/7720 The actual problem is not RocksDB or Flink but rather...

The Scala specific serializers were created by the `createTypeInfo` macro which has been a no-go in large projects due to [very very slow compilation times](https://medium.com/drivetribe-engineering/towards-achieving-a-10x-compile-time-improvement-in-a-flink-codebase-a69596edcb50). There is a performance penalty...