flink

flink copied to clipboard

[FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler.

1

## What is the purpose of the change [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler. ## Brief change log - Introduce the abstraction and the interface about...

RocMarshal

[FLINK-36476] [TABLE-SQL] Remove deprecated methods

1

## What is the purpose of the change [[FLINK-36476](https://issues.apache.org/jira/browse/FLINK-36476)](https://issues.apache.org/jira/browse/FLINK-36476) Remove all deprecated methods under public APIs in table modules subtask: [FLINK-36508](https://issues.apache.org/jira/browse/FLINK-36508) Remove all deprecated methods in `SymbolType ` ## Brief...

lajith2006

FLINK-36481 Remove deprecated method TableDescriptor forManaged

1

## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-36481 Remove deprecated methods TableDescriptor.forManaged ## Brief change log Remove deprecated methods ## Verifying this change This change is already covered by...

jbalchan

FLINK-36482 Remove all deprecated methods TableEnvironment

1

## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-36482 Remove all deprecated methods in TableEnvironment ## Brief change log Remove deprecated methods ## Verifying this change This change is already...

jbalchan

FLINK-36485 remove deprecated method fromDataStream

1

## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-36485 Remove deprecated method StreamTableEnvironment fromDataStream ## Brief change log Removed deprecated method ## Verifying this change This change is already covered...

jbalchan

[FLINK-36476] [TABLE-SQL] Remove deprecated methods

1

## What is the purpose of the change [[FLINK-36476](https://issues.apache.org/jira/browse/FLINK-36476)](https://issues.apache.org/jira/browse/FLINK-36476) Remove all deprecated methods under public APIs in table modules subtask: - [[FLINK-36477](https://issues.apache.org/jira/browse/FLINK-36477)](https://issues.apache.org/jira/browse/FLINK-36477) Remove deprecated method `BaseExpressions#cast` in table-api-java - [[FLINK-36478](https://issues.apache.org/jira/browse/FLINK-36478)](https://issues.apache.org/jira/browse/FLINK-36478)...

corgy-w

[FLINK-36399][table] Fix incorrect cast behavior.

2

## What is the purpose of the change Fix incorrect cast behavior. ## Verifying this change This change is already covered by existing tests ## Does this pull request potentially...

liuyongvs

[FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler

3

## What is the purpose of the change [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler ## Brief change log - Introduce the `SlotSharingStrategy` and related implementations for...

RocMarshal

[FLINK-36266][table] Insert into as select * behaves incorrect

2

## What is the purpose of the change The PR fixes behavior for insert into queries with select * like ```sql INSERT INTO t(f0, f1 ,f2) SELECT * FROM t1;...

snuyanzin

[FLINK-36470][build] Bump checkstyle to 10+

2

## What is the purpose of the change Bumping checkstyle to 10+ ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ##...

snuyanzin