yunfengzhou-hub

[FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

10

## What is the purpose of the change This PR is a continuation of #20275, further guaranteeing the consistency of operator events sent from subtasks to their coordinators. A coordinator...

## What is the purpose of the change This PR modifies Flink ML's python quickstart document to improve user experience and to align with flink's quickstart documents ## Brief change...

[FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel

4

## What is the purpose of the change This pull request adds support for consuming multiple subpartitions in a single input channel. ## Brief change log - Separate the notion...

[FLINK-34371][runtime] Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

3

## What is the purpose of the change This pull request adds support for EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment. ## Brief change log - Introduces OperatorAttributes...

Clink needs more documentation and examples about the usage of Clink APIs so as to improve Clink's readability and usability. It is equally important to setup conventions for the whole...

build-cli-deps.sh ```shell # zip Feathub and its dependencies cd "${CURRENT_DIR}" if [[ -z "${FEATHUB_WHEEL_PATH}" ]]; then # TODO: Install the latest stable version after Feathub released. python -m pip install...

Add test and document for built-in function ARRAY.

Feathub should provide document for configurations like `common.timeZone`.

SlidingWindowKeyedProcessFunction.java: ```java // TODO: Register at most one timer at a timestamp regardless of the number of the keys // processed by the operator. while (triggerTime