[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
kangTwang updated FLINK-26668: ------------------------------ Attachment: (was: image-2022-03-16-10-57-19-617.png) > 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-1.jpg, image-2022-03-16-10-57-03-419.png > > > 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! > 因为是在streamgraph阶段抛错,所以无法看到具体的dag图,所以就采用非AdaptiveBatch,执行的dag图如下: > !image-2022-03-16-10-57-19-617.png! > 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)