[
https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723977#comment-16723977
]
lining commented on FLINK-11162:
--------------------------------
add new api /jobs/:jobid/operators
{
*
operators:
[ *
{ *
vertex_id: "cbc357ccb763df2852fee8c4fc7d55f2",
*
operator_id: "cbc357ccb763df2852fee8c4fc7d55f2",
*
name: "Source: Socket Stream",
*
inputs: [ ]},
*
{ *
vertex_id: "cbc357ccb763df2852fee8c4fc7d55f2",
*
operator_id: "7df19f87deec5680128845fd9a6ca18d",
*
name: "Flat Map",
*
inputs:
[ *
{ *
operator_id: "cbc357ccb763df2852fee8c4fc7d55f2",
*
partitioner: "FORWARD",
*
type_number: 0}]},
*
{ *
vertex_id: "90bea66de1c231edf33913ecd54406c1",
*
operator_id: "90bea66de1c231edf33913ecd54406c1",
*
name: "Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction)",
*
inputs:
[ *
{ *
operator_id: "7df19f87deec5680128845fd9a6ca18d",
*
partitioner: "HASH",
*
type_number: 0}]},
*
{ *
vertex_id: "90bea66de1c231edf33913ecd54406c1",
*
operator_id: "17fbfcaabad45985bbdf4da0490487e3",
*
name: "Sink: Print to Std. Out",
*
inputs:
[ *
{ *
operator_id: "90bea66de1c231edf33913ecd54406c1",
*
partitioner: "FORWARD",
*
type_number: 0}]}]
}
> Provide a rest API to list all logical operators
> ------------------------------------------------
>
> Key: FLINK-11162
> URL: https://issues.apache.org/jira/browse/FLINK-11162
> Project: Flink
> Issue Type: New Feature
> Components: REST
> Reporter: vinoyang
> Assignee: lining
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The scene of this issue:
> We are using the indicator variable of the operator: <operator_id>,
> <operator_name>.
> We have customized the display of the indicator. Based on the query purpose,
> we currently lack an interface to get all the logical operators of a job. The
> current rest API only provides the chained node information.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
