You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/10 02:02:00 UTC
[jira] [Created] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery
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)