database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](feut) Fix distribute hint test with reorder cross join (#35987)

Browse Source 
when checking plan shape of distribute hint test, the shape of it does
not changed but projection has changed. So it needed to be updated
This commit is contained in:
LiBinfeng
2024-06-07 14:47:45 +08:00
committed by GitHub
parent 7bf479febf
commit 2358ebe338
1 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
fe/fe-core/src/test/java/org/apache/doris/nereids/DistributeHintTest.java
View File

@ -117,21 +117,20 @@ class DistributeHintTest extends TestWithFeService implements MemoPatternMatchSu
MatchingUtils.assertMatches(plan,
physicalResultSink(
physicalDistribute(
physicalProject(
physicalHashJoin(
physicalHashJoin(physicalDistribute().when(dis -> {
DistributionSpec spec = dis.getDistributionSpec();
Assertions.assertTrue(spec instanceof DistributionSpecHash);
DistributionSpecHash hashSpec = (DistributionSpecHash) spec;
Assertions.assertEquals(ShuffleType.EXECUTION_BUCKETED,
hashSpec.getShuffleType());
return true;
}), physicalDistribute()),
physicalDistribute()
).when(join -> join.getDistributeHint().distributeType == DistributeType.SHUFFLE_RIGHT)
physicalHashJoin(
physicalHashJoin(physicalDistribute().when(dis -> {
DistributionSpec spec = dis.getDistributionSpec();
Assertions.assertTrue(spec instanceof DistributionSpecHash);
DistributionSpecHash hashSpec = (DistributionSpecHash) spec;
Assertions.assertEquals(ShuffleType.EXECUTION_BUCKETED,
hashSpec.getShuffleType());
return true;
}), physicalDistribute()),
physicalDistribute()).when(join -> join.getDistributeHint().distributeType
== DistributeType.SHUFFLE_RIGHT)
)
)
));
);
});
}