Hong Liang Teoh

[FLINK-31980] Implement support for EFO in Kinesis consumer

3

## Purpose of the change Implement support for EFO in the new KDS source ## Verifying this change This change added tests and can be verified as follows: - Added...

[Bug]: KinesisIO source on FlinkRunner initializes the same splits twice

7

### What happened? #### Bug description Setup details: - FlinkRunner (Flink 1.15.4) (also replicated with Flink 1.18.2) - KinesisIO (from `beam-sdks-java-io-amazon-web-services2`) - Beam version 2.56.0 - Pipeline attached mode (false)...

[FLINK-36571][web] Fix issue to allow Busy and Backpressure numbers o…

1

…n Flink dashboard ## What is the purpose of the change Fix bug so that non-zero numbers of Busy / Backpressure can be shown on Flink dashboard ## Brief change...