Ryan Skraba
Ryan Skraba
## What is the purpose of the change * Update AVRO dependency to the latest version (Continuing on the work of https://github.com/apache/flink/pull/17623) ## Brief change log - Updated org.apache.avro:avro:1.10.0 to...
# What is currently missing? Avro version 1.11.1 has been released with some python improvements: https://s.apache.org/avro-1.11.1-announce # How could this be improved? Python - [AVRO-3542](https://issues.apache.org/jira/browse/AVRO-3542) Scale assignment optimization - [AVRO-3521](https://issues.apache.org/jira/browse/AVRO-3521)...
## What is the purpose of the change Update the news section of the blog to invite Martin G ## Verifying this change This change is a trivial website change...
## What is the purpose of the change This pull request causes tests annotated with `@RetryOnException` to fail after the given number of retries when used with the JUnit5 `RetryExtension`....
## What is the purpose of the change Update the `flink-formats/flink-hadoop-bulk` 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 * Removed dependences...
## What is the purpose of the change Update the `flink-formats/flink-csv` module to AssertJ and JUnit 5 following the [JUnit 5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4xm5uiuXOooOJTtXqS_Jqk9KJitU/edit) I used the https://github.com/slinkydeveloper/assertj-migrator as the starting...
Adds a new transformation that appends the key or selected key fields into the existing value. This is similar to the existing standard Kafka transform ValueToKey, which _replaces_ the existing...