flink

flink copied to clipboard

[FLINK-38802][table] DDL with duplicated keys in table options should fail while validation

1

## What is the purpose of the change To make the behavior more transparent ddl with duplicated keys in table options should fail rather than silently applying the last value...

snuyanzin

[FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode

1

## What is the purpose of the change This PR fixes a bug where `pipeline.jobvertex-parallelism-overrides` configuration was completely ignored when running jobs in Application Mode with Flink 2.0+. This broke...

barakbaron12

[FLINK-38799][runtime] Rename `LoadingWeight` to `ResourceUnitCount`

1

## What is the purpose of the change Rename `LoadingWeight` and its accompanying class, interface to be more intuitive what it represents. ## Brief change log - Renamed `LoadingWeight` to...

ferenc-csaky

[FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant

1

## What is the purpose of the change Introduce Built-in Function to Access field or element in the Variant SQL Function | Table Function | Description -- | -- |...

JinkunLiu

[FLINK-38793][table] Reuse result of functions if ther are used multiple times as input for other functions

1

## What is the purpose of the change It should reuse result of functions as input for other functions ## Brief change log projections rules ## Verifying this change There...

snuyanzin

[FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability

2

## What is the purpose of the change Upgrade lz4 to 1.8.1 due to security vulnerability ## Verifying this change Change should be covered by the existing tests. ## Does...

pnowojski

[hotfix][table] Fix incorrect error message of RootArgumentTypeStrategy

2

## What is the purpose of the change ## Brief change log ## Verifying this change `InputTypeStrategiesTest` ## Does this pull request potentially affect one of the following parts: -...

dylanhz

fix: update wording for 2.1.0 release notes for java 17 usage

1

fix: update wording for 2.1.0 release notes for java 17 usage

chenrui333

[FLINK-38774] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti…

1

## What is the purpose of the change Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… ## Brief change log...

abjfh30

[FLINK-38735][connector-file] add restore state check

4

## What is the purpose of the change bug fix for https://issues.apache.org/jira/browse/FLINK-38735 ## Brief change log - Avoid got NoSuchElementException when restore with empty state ## Verifying this change Add...

liunaijie