[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628182#comment-17628182
]
JasonLee commented on FLINK-29852:
----------------------------------
Hi [~gaoyunhaii] yes,Stably repeated, I tested two different SQL jobs and one
datastream api job,There will be repetition.
{code:java}
// the content of the response from the web server
{
"jid":"a294907b86943c3892070f07b98ec6e3",
"name":"FlinkStreamingBroadcastMysqlDemo",
"isStoppable":false,
"state":"RUNNING",
"start-time":1667462380130,
"end-time":-1,
"duration":858837,
"maxParallelism":-1,
"now":1667463238967,
"timestamps":Object{...},
"vertices":Array[3],
"status-counts":Object{...},
"plan":{
"jid":"a294907b86943c3892070f07b98ec6e3",
"name":"FlinkStreamingBroadcastMysqlDemo",
"type":"STREAMING",
"nodes":[
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"Source: Kafka Source<br/>+- Map<br/>",
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"parallelism":6,
"operator":"",
"operator_strategy":"",
"description":"test<br/>",
"inputs":[
{
"num":0,
"id":"cbc357ccb763df2852fee8c4fc7d55f2",
"ship_strategy":"HASH",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
},
{
"id":"1a936cb48657826a536f331e9fb33b5e",
"parallelism":1,
"operator":"",
"operator_strategy":"",
"description":"Sink: Print to Std. Out<br/>",
"inputs":[
{
"num":0,
"id":"9dd63673dd41ea021b896d5203f3ba7c",
"ship_strategy":"REBALANCE",
"exchange":"pipelined_bounded"
}
],
"optimizer_properties":{
}
}
]
}
}{code}
> The operator is repeatedly displayed on the Flink Web UI
> --------------------------------------------------------
>
> Key: FLINK-29852
> URL: https://issues.apache.org/jira/browse/FLINK-29852
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Web Frontend
> Affects Versions: 1.16.0
> Environment: Flink 1.16.0
> Reporter: JasonLee
> Priority: Major
> Attachments: image-2022-11-02-23-57-39-387.png
>
>
> All the operators in the DAG are shown repeatedly
> !image-2022-11-02-23-57-39-387.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
