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

[Bug] Bucket Shuffle Join may cause:Failed to send brpc batch, Not connected to 0.0.0.0:0 (#5901)

Browse Source
This commit is contained in:
HappenLee
2021-05-27 09:05:15 -05:00
committed by GitHub
parent d958bbedc9
commit ce3ae764e5
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/planner/DataPartition.java
View File

@ -95,6 +95,10 @@ public class DataPartition {
return type != TPartitionType.UNPARTITIONED;
}
public boolean isBucketShuffleHashPartition() {
return type == TPartitionType.BUCKET_SHFFULE_HASH_PARTITIONED;
}
public TPartitionType getType() {
return type;
}

7
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -828,7 +828,11 @@ public class Coordinator {
params.instanceExecParams.size() + destParams.perExchNumSenders.get(exchId.asInt()));
}
if (bucketShuffleJoinController.isBucketShuffleJoin(destFragment.getFragmentId().asInt())) {
if (sink.getOutputPartition().isBucketShuffleHashPartition()) {
// the destFragment must be bucket shuffle
Preconditions.checkState(bucketShuffleJoinController.
isBucketShuffleJoin(destFragment.getFragmentId().asInt()));
int bucketSeq = 0;
int bucketNum = bucketShuffleJoinController.getFragmentBucketNum(destFragment.getFragmentId());
TNetworkAddress dummyServer = new TNetworkAddress("0.0.0.0", 0);
@ -1544,7 +1548,6 @@ public class Coordinator {
return true;
}
// One fragment could only have one HashJoinNode
if (node instanceof HashJoinNode) {
HashJoinNode joinNode = (HashJoinNode) node;
if (joinNode.isBucketShuffle()) {