This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 3de46746ca6 Fix NPE in segment allocation when reduceMetadataIO is
true (#17537)
3de46746ca6 is described below
commit 3de46746ca651a37f3958ec09aad1f1f662f3b94
Author: Kashif Faraz <[email protected]>
AuthorDate: Wed Dec 4 23:28:47 2024 -0800
Fix NPE in segment allocation when reduceMetadataIO is true (#17537)
---
.../org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
index e3a3ee04708..69d86ab80cf 100644
---
a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
+++
b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
@@ -2943,7 +2943,7 @@ public class IndexerSQLMetadataStorageCoordinator
implements IndexerMetadataStor
=
versionIntervalToSmallestSegmentId.computeIfAbsent(segmentId.getVersion(), v ->
new HashMap<>());
final SegmentId value = map.get(segmentId.getInterval());
if (value == null || value.getPartitionNum() >
segmentId.getPartitionNum()) {
- map.put(interval, segmentId);
+ map.put(segmentId.getInterval(), segmentId);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
