Fwd: A WordCount job using DataStream API but behave like the batch WordCount example

2023-04-28 Thread Luke Xiong
Dear experts, Is it possible to write a WordCount job that uses the DataStream API, but make it behave like the batch version WordCount example? More specifically, I hope the job can get a DataStream of the final (word, count) records when fed a text file. For example, given a text file: ```inpu

Re: [Discussion] - Release major Flink version to support JDK 17 (LTS)

2023-04-28 Thread Alexey Novakov via user
If breaking savepoint compatibility will be eventually an option, I would recommend to try to upgrade Flink's Scala even to *2.13* Best regards, Alexey On Fri, Apr 28, 2023 at 10:22 AM Chesnay Schepler wrote: > We don't know yet. I wanted to run some more experiments to see if I cant > get Scal

Re: [Discussion] - Release major Flink version to support JDK 17 (LTS)

2023-04-28 Thread Chesnay Schepler
We don't know yet. I wanted to run some more experiments to see if I cant get Scala 2.12.7 working on Java 17. If that doesn't work, then it would also be an option to bump Scala in the Java 17 builds (breaking savepoint compatibility), and users should just only use the Java APIs. The alter