Hong Liang Teoh
Hong Liang Teoh
## 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...
### 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)...
…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...
…to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too : https://github.com/apache/flink-connector-kafka/pull/132 ##...
…to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too : https://github.com/apache/flink-connector-kafka/pull/132 ##...
## Purpose of the change Support Flink 2.0 in `flink-connector-aws` ## Verifying this change This change is already covered by existing tests (unit test, integ test in CI) ## Significant...
## Purpose of the change Set up the Java version for Python CI to >= JDK 11. ## Verifying this change This change is already covered by existing tests (Existing...
## Purpose of the change Fix typo in docs. ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ## Significant changes *(Please...
…to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too : https://github.com/apache/flink-connector-kafka/pull/132 *...
## Purpose of the change Specify Java version to 11 to allow CI to run against the latest Flink artefacts. ## Verifying this change This change is already covered by...