Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Better error message when partition space is exhausted (#15685) 

* Better error message when partition space is exhausted
This commit is contained in:
AmatyaAvadhanula 2024-01-16 12:32:40 +05:30 committed by GitHub
parent 67720b60ae
commit 11dbfb6e3f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
processing/src/main/java/org/apache/druid/timeline/partition/OvershadowableManager.java
View File

@ -403,9 +403,9 @@ class OvershadowableManager<T extends Overshadowable<T>>
TreeMap<RootPartitionRange, Short2ObjectSortedMap<AtomicUpdateGroup<T>>> stateMap
)
{
final RootPartitionRange lowFench = new RootPartitionRange((short) 0, (short) 0);
final RootPartitionRange lowFence = new RootPartitionRange((short) 0, (short) 0);
final RootPartitionRange highFence = new RootPartitionRange(partitionId, partitionId);
return stateMap.subMap(lowFench, false, highFence, false).descendingMap().entrySet().iterator();
return stateMap.subMap(lowFence, false, highFence, false).descendingMap().entrySet().iterator();
}
/**
@ -418,9 +418,14 @@ class OvershadowableManager<T extends Overshadowable<T>>
TreeMap<RootPartitionRange, Short2ObjectSortedMap<AtomicUpdateGroup<T>>> stateMap
)
{
final RootPartitionRange lowFench = new RootPartitionRange(partitionId, partitionId);
final RootPartitionRange lowFence = new RootPartitionRange(partitionId, partitionId);
final RootPartitionRange highFence = new RootPartitionRange(Short.MAX_VALUE, Short.MAX_VALUE);
return stateMap.subMap(lowFench, false, highFence, false).entrySet().iterator();
if (lowFence.compareTo(highFence) > 0) {
throw new ISE("PartitionId[%d] must be in the range [0, 32767]. "
+ "Try compacting the interval to reduce the segment count.", Short.toUnsignedInt(partitionId));
} else {
return stateMap.subMap(lowFence, false, highFence, false).entrySet().iterator();
}
}
/**