flink
flink copied to clipboard
apache
Apache Flink
## What is the purpose of the change *Set parallelism for map operator in class HiveTableSink's method createBatchSink in order to keep consistent with HiveTableSink. If not so, the operators...
## What is the purpose of the change Migrate `WriteAheadSinkTestBase` and flink-connector-cassandra module to AssertJ and JUnit 5 following the [JUnit 5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4xm5uiuXOooOJTtXqS_Jqk9KJitU/edit) ## Brief change log Use JUnit5...
## What is the purpose of the change This is an implementation of `ARRAY_APPEND` and `ARRAY_PREPEND` inspired by https://github.com/apache/flink/pull/19543 ## Brief change log - ARRAY_APPEND for Table API and SQL...
## What is the purpose of the change PulsarSink is a bit slow when we use the `At-Least-Once` or `Exactly-Once`. This is because PulsarSink uses `MallboxExecutor` to write messages. A...
In this PR, we introduces several things for supporting create another k8s resources before JM deploy creation ## What is the purpose of the change *(For example: This pull request...
## What is the purpose of the change _User stories:_ As a Flink user, I’d like to use DynamoDB as sink for my data pipeline. _Scope:_ * Implement an asynchronous...
## What is the purpose of the change Refactor `RescaleCheckpointManuallyITCase`. ## Brief change log - Modify `NotifyingDefiniteKeySource` to wait for checkpoints to complete. - Make job fail artificially, to retain...
## What is the purpose of the change Convert Hive's void type to Flink's string type to handle the cases that some Hive's udf may return void type which isn't...
[FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type
## What is the purpose of the change To fix fail to call Hive UDAF when the UDAF accepts one parameter with array type ## Brief change log When the...
## What is the purpose of the change To fix fail to count mutiple fields excpetion in Hive dialect ## Brief change log - Remove the `count` from the backlist...