The GitHub Actions job "Flink CI (beta)" on flink.git/master has succeeded.
Run started by GitHub user dianfu (triggered by dianfu).

Head commit for run:
d62be55c09a7beb85e6517312233127cd85e7dce / yongliu <[email protected]>
[FLINK-38933][python] Expose runtime context information in Python UDX 
FunctionContext

This aligns Python UDX with Java UDX by exposing runtime context information 
through FunctionContext. Added the following getter methods to FunctionContext:
- get_task_name()
- get_task_name_with_subtasks()
- get_number_of_parallel_subtasks()
- get_max_number_of_parallel_subtasks()
- get_index_of_this_subtask()
- get_attempt_number()

The runtime context is propagated from Java operators via the protobuf protocol 
by adding a runtime_context field to UserDefinedFunctions and 
UserDefinedAggregateFunctions messages.

This closes #27831.

Report URL: https://github.com/apache/flink/actions/runs/23706517732

With regards,
GitHub Actions via GitBox

Reply via email to