[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee resolved FLINK-37085.
--------------------------------
Fix Version/s: 2.0.0
Resolution: Fixed
master:89c7c2b9c55702f6f54191c98c373ec2ce9f6c41
> 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
> Labels: pull-request-available
> Fix For: 2.0.0
>
>
> {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)
