Qingsheng Ren created FLINK-24376:
-------------------------------------
Summary: Operator name in OperatorCoordinator should not use
chained name
Key: FLINK-24376
URL: https://issues.apache.org/jira/browse/FLINK-24376
Project: Flink
Issue Type: Bug
Components: Runtime / Task
Affects Versions: 1.13.2, 1.12.5, 1.14.0, 1.14.1
Reporter: Qingsheng Ren
Currently the operator name passed to
{{CoordinatedOperatorFactory#getCoordinatorProvider}} is a chained operator
name (e.g. Source -> Map) instead of the name of coordinating operator, which
might be misleading.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
