[
https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617
]
lining edited comment on FLINK-11162 at 12/18/18 3:19 AM:
----------------------------------------------------------
[~yanghua] we need add this information in which api, create new or use old api
like jobs:/jobid/plan?
I prefer in old api, result like this
vinoyang we need add this information in which api, create new or use old api
like jobs:/jobid/plan?
I prefer in old api, result like this
{
"jid": "ccee3dc6ac63c532feea3e8cdbf05eab",
"name": "Socket Window WordCount",
"nodes": [
{
"id": "cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism": 1,
"operator": "",
"operator_strategy": "",
"description": "Source: Socket Stream -> Flat Map",
"optimizer_properties": {}
},
{
"id": "90bea66de1c231edf33913ecd54406c1",
"parallelism": 1,
"operator": "",
"operator_strategy": "",
"description": "Window(TumblingProcessingTimeWindows(5000),
ProcessingTimeTrigger, ReduceFunction$1, PassThroughWindowFunction) ->
Sink: Print to Std. Out",
"inputs": [
{
"num": 0,
"id": "cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy": "HASH",
"exchange": "pipelined"
}
],
"optimizer_properties": {}
}
],
"operators": [
{
"vertex_id": "cbc357ccb763df2852fee8c4fc7d55f2",
"operator_id": "7df19f87deec5680128845fd9a6ca18d",
"name": "Flat Map",
"inputs": [
{
"operator_id": "cbc357ccb763df2852fee8c4fc7d55f2",
"partitioner": "FORWARD",
"type_number": 0
}
]
},
{
"vertex_id": "cbc357ccb763df2852fee8c4fc7d55f2",
"operator_id": "cbc357ccb763df2852fee8c4fc7d55f2",
"name": "Source: Socket Stream",
"inputs": [],
"metric_name": "Source__Socket_Stream"
},
{
"vertex_id": "90bea66de1c231edf33913ecd54406c1",
"operator_id": "17fbfcaabad45985bbdf4da0490487e3",
"name": "Sink: Print to Std. Out",
"inputs": [
{
"operator_id": "90bea66de1c231edf33913ecd54406c1",
"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
}
]
}
]
}
was (Author: lining):
[~yanghua] we need add this information in which api, create new or use old api
like jobs:/jobid/plan?
> 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
>
> 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)
