[
https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kangTwang updated FLINK-26668:
------------------------------
Description:
In the AdaptiveBatch TPC DS test, the following error messages appear when
executing query_23a，If the upstreamnode is Calc [50], the downstreamnode is
multipleinput [75], and they are forwardpartitioners, the parallelism is
inconsistent, and an unsupported operationexception is thrown：
Because the error is thrown in the streamgraph stage, the specific DAG diagram
cannot be seen. Therefore, non adaptive batch is adopted. The DAG diagram
executed is as follows:
Check Calc [50] and find that the downstream operator is HashAggregate[51], not
MultipleInput[75]
was:
In the AdaptiveBatch TPC DS test, the following error messages appear when
executing query_23a，If the upstreamnode is Calc [50], the downstreamnode is
multipleinput [75], and they are forwardpartitioners, the parallelism is
inconsistent, and an unsupported operationexception is thrown：
!aaa.jpg!
Because the error is thrown in the streamgraph stage, the specific DAG diagram
cannot be seen. Therefore, non adaptive batch is adopted. The DAG diagram
executed is as follows:
!image-2022-03-16-10-57-19-617.png!
Check Calc [50] and find that the downstream operator is HashAggregate[51], not
MultipleInput[75]
> Unsupportedoperation exception caused by createActualEdge error in adaptive
> batch scheduler
> -------------------------------------------------------------------------------------------
>
> Key: FLINK-26668
> URL: https://issues.apache.org/jira/browse/FLINK-26668
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.15.0
> Environment:
>
> Reporter: kangTwang
> Priority: Major
> Attachments: aaa.jpg, bbb.jpg
>
>
> In the AdaptiveBatch TPC DS test, the following error messages appear when
> executing query_23a，If the upstreamnode is Calc [50], the downstreamnode is
> multipleinput [75], and they are forwardpartitioners, the parallelism is
> inconsistent, and an unsupported operationexception is thrown：
>
> Because the error is thrown in the streamgraph stage, the specific DAG
> diagram cannot be seen. Therefore, non adaptive batch is adopted. The DAG
> diagram executed is as follows:
>
> Check Calc [50] and find that the downstream operator is HashAggregate[51],
> not MultipleInput[75]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
