diff --git a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SynchronizedUnion.java b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SynchronizedUnion.java index d3cb529cf75..4b613d848a6 100644 --- a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SynchronizedUnion.java +++ b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SynchronizedUnion.java @@ -79,7 +79,7 @@ public class SynchronizedUnion implements Union } @Override - public void update(char[] chars) + public synchronized void update(char[] chars) { delegate.update(chars); } @@ -115,7 +115,7 @@ public class SynchronizedUnion implements Union } @Override - public boolean isSameResource(Memory mem) + public synchronized boolean isSameResource(Memory mem) { return delegate.isSameResource(mem); }