Xuannan issues

Results 11 issues of


                                            Xuannan

[FLINK-28860] Fix CacheITCase

## What is the purpose of the change The PR address the two problems that cause CacheITCase to fail randomly. - Cache consumption in stream mode should recompute the result...

component=API/DataStream

[FLINK-29339][runtime] JobMasterPartitionTracker returns future to avoid blocking main thread

## What is the purpose of the change JobMasterPartitionTracker#getClusterPartitionShuffleDescriptors returns future to avoid blocking the main thread. ## Brief change log - JobMasterPartitionTracker#getClusterPartitionShuffleDescriptors returns future to avoid blocking the main...

component=Runtime/Coordination

MySQL source supports bounded scan and cdc

type:feature

Provide public API for users to register Python/Java AggFunc to be used in Sliding/OverWindowTransform

type:feature

Improve error message when the timestamp field contains corrupted data

Currently, if the timestamp field contains corrupted data, the Flink job fails with the message, `RowTime field should not be null, please convert it to a non-null long value`, which...

type:improvement

Add a class to keep track of all the built-in and user-defined func and agg func

type:improvement

Test should use shared mini-cluster for all Flink processor tests

type:improvement

Support computing over window features with different filter expr, limit, and window size in one operator

type:improvement

Reduce the CI run time by caching the docker image

[FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL

## What is the purpose of the change This pull request introduces the Variant data structure to represent semi-structured data, a new SQL type variant, and a builtin method to...