Weijie Guo created FLINK-37085:
----------------------------------
Summary: 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
{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}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
