Is Flink >1.14 really supported by the runners?

2023-06-13 Thread Edgar H
Hi all, I've been running Beam with Flink in 1.14 for quite some time now but just seen in Maven that runners supporting 1.15 and 1.16 are available to use, however no mention to them within the compatibility matrix. Are they stable enough to be used? And also, https://issues.apache.org/jira/bro

Re: Is Flink >1.14 really supported by the runners?

2023-06-13 Thread Edgar H
gt; > [1] https://github.com/apache/beam/issues/27115 > > On 6/13/23 12:10, Edgar H wrote: > > Hi all, > > > > I've been running Beam with Flink in 1.14 for quite some time now but > > just seen in Maven that runners supporting 1.15 and 1.16 are available >

[FlinkRunner] KinesisIO stage report 100% busy time even with no load

2024-06-20 Thread Edgar H
Hi all! Recently I've been moving my jobs that use FlinkRunner to the latest 2.56.0 version from the 2.49.0. I've noticed the following: - Busy time with 2.49.0: N/A literal - probably the 100% load wasn't happening before and wasn't being reported due to lack of metrics? - Busy time with 2.56.0