[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee reassigned FLINK-37085:
----------------------------------
Assignee: xingbe
> AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery
> -----------------------------------------------------
>
> Key: FLINK-37085
> URL: https://issues.apache.org/jira/browse/FLINK-37085
> Project: Flink
> Issue Type: Bug
> Components: Build System / CI
> Affects Versions: 2.0.0
> Reporter: Weijie Guo
> Assignee: xingbe
> Priority: Blocker
>
> {code:java}
> Jan 09 13:28:50 13:28:50.648 [ERROR]
> AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery:134 ast ==> expected: <
> Jan 09 13:28:50 LogicalProject(a1=[$0], b1=[$1], c1=[$2], d1=[$3], a2=[$4],
> b2=[$5], c2=[$6], d2=[$7])
> Jan 09 13:28:50 +- LogicalFilter(condition=[=($0, $4)])
> Jan 09 13:28:50 +- LogicalJoin(condition=[true], joinType=[inner])
> Jan 09 13:28:50 :- LogicalTableScan(table=[[default_catalog,
> default_database, T1, source: [TestTableSource(a1, b1, c1, d1)]]])
> Jan 09 13:28:50 +- LogicalTableScan(table=[[default_catalog,
> default_database, T2, source: [TestTableSource(a2, b2, c2, d2)]]])
> Jan 09 13:28:50 > but was: <
> Jan 09 13:28:50 LogicalProject(a1=[$0], b1=[$1], c1=[$2], d1=[$3], a2=[$4],
> b2=[$5], c2=[$6], d2=[$7])
> Jan 09 13:28:50 +- LogicalFilter(condition=[=($0, $4)])
> Jan 09 13:28:50 +- LogicalJoin(condition=[true], joinType=[inner])
> Jan 09 13:28:50 :- LogicalTableScan(table=[[default_catalog,
> default_database, T1]])
> Jan 09 13:28:50 +- LogicalTableScan(table=[[default_catalog,
> default_database, T2]])
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=65091&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4&l=11442
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
