[
https://issues.apache.org/jira/browse/FLINK-36064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-36064:
------------------------------
Summary: Refactor REST API for Client and Operator Coordinator
Communication to Use operatorUid. (was: Refactor CollectResultIterator to
eliminate dependency on OperatorID)
> Refactor REST API for Client and Operator Coordinator Communication to Use
> operatorUid.
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-36064
> URL: https://issues.apache.org/jira/browse/FLINK-36064
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Junrui Li
> Assignee: Junrui Li
> Priority: Major
> Labels: pull-request-available
>
> Currently, the REST API between clients and operator coordinators relies on
> the operator ID to send requests to the Job Manager (JM) for querying
> results. However, with the introduction of Stream Graph submission, the Job
> Graph will be compiled and generated within the JM, preventing the client
> from accessing the operator ID.
> To address this issue, we modify the REST API for communication between
> clients and operator coordinators by removing the dependency on operatorID
> and transitioning to a client-defined {{{}String operatorUid{}}}.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
