This is an automated email from the ASF dual-hosted git repository.
kgyrtkirk 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 0ac00fa273d fix: deadlock in HeapMemorySegmentMetadataCache (#19240)
0ac00fa273d is described below
commit 0ac00fa273d7864b3f9b7cf943e199a6430c2abc
Author: Zoltan Haindrich <[email protected]>
AuthorDate: Wed Apr 1 07:27:48 2026 +0200
fix: deadlock in HeapMemorySegmentMetadataCache (#19240)
---
.../druid/metadata/segment/cache/HeapMemorySegmentMetadataCache.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/server/src/main/java/org/apache/druid/metadata/segment/cache/HeapMemorySegmentMetadataCache.java
b/server/src/main/java/org/apache/druid/metadata/segment/cache/HeapMemorySegmentMetadataCache.java
index 0b85243c8f2..f2accfe5541 100644
---
a/server/src/main/java/org/apache/druid/metadata/segment/cache/HeapMemorySegmentMetadataCache.java
+++
b/server/src/main/java/org/apache/druid/metadata/segment/cache/HeapMemorySegmentMetadataCache.java
@@ -619,8 +619,7 @@ public class HeapMemorySegmentMetadataCache implements
SegmentMetadataCache
datasourceToSegmentCache.compute(
dataSource,
(ds, existingCache) -> {
- if (existingCache != null && existingCache.isEmpty()
- && !existingCache.isBeingUsedByTransaction()) {
+ if (existingCache != null &&
!existingCache.isBeingUsedByTransaction() && existingCache.isEmpty()) {
emitMetric(dataSource, Metric.DELETED_DATASOURCES, 1L);
return null;
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
