flink

flink copied to clipboard

[hotfix] Fix watermark javadoc

2

## What is the purpose of the change Simple typo fix in the docstring/javadoc.

bivouak

[FLINK-38205][format][pb] Discard unknown fields by default

3

## What is the purpose of the change Currently, Flink Protobuf format does not discard unknown fields (and it does not even provide an option for that!). When the user...

X-czh

[FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage

1

## What is the purpose of the change Implementing FLIP-505 for Flink History Server scalability improvements by decoupling local job archive caching with a remote store. ## Brief change log...

achang52

[BP-1.19][FLINK-38138] Fix OOB error in ColumnarArrayData

1

release-1.19 backport of https://github.com/apache/flink/pull/26826

voonhous

[BP-1.20][FLINK-38138] Fix OOB error in ColumnarArrayData

1

release-1.20 backport of https://github.com/apache/flink/pull/26826

voonhous

Update README.md for end-to-end tests

2

## What is the purpose of the change This pull request updates the project documentation to provide clearer instructions for running end-to-end tests, including important prerequisites and recommendations for contributors....

nikita-ivanov-cc

[Test][Do NOT MERGE] Test PR to check if the build fails

2

## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring...

vssakuru

[FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation

4

## What is the purpose of the change This PR migrates CheckpointedStreamingProgram from the deprecated legacy SourceFunction API to the modern FLIP-27 Source API. ## Brief change log - Removed...

Poorvankbhatia

[FLINK-37973][table-planner] Add support for right joins to multijoin operator

6

## What is the purpose of the change The newly introduced `MultiJoin` operator currently does not support right joins. Since all right joins are converted to left joins, we need...

SteveStevenpoor

[FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN

1

## What is the purpose of the change This pull request aligns Flink’s default for the YARN configuration option `yarn.application-attempt-failures-validity-interval` with YARN itself. The previous default (10 000 ms) caused...

liyude-tw