This is an automated email from the ASF dual-hosted git repository.
karan 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 d823c0650f5 Fixing Dart Quidem supplier. (#18088)
d823c0650f5 is described below
commit d823c0650f5135136f984d314efe683a83d2a51e
Author: Karan Kumar <[email protected]>
AuthorDate: Fri Jun 6 11:40:42 2025 +0530
Fixing Dart Quidem supplier. (#18088)
---
.../test/java/org/apache/druid/msq/test/DartComponentSupplier.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/DartComponentSupplier.java
b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/DartComponentSupplier.java
index 641836f5a26..cac156e071e 100644
---
a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/DartComponentSupplier.java
+++
b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/DartComponentSupplier.java
@@ -51,9 +51,9 @@ import org.apache.druid.sql.calcite.util.datasets.TestDataSet;
import java.nio.ByteBuffer;
import java.util.Collections;
-import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
+import java.util.concurrent.ConcurrentHashMap;
public class DartComponentSupplier extends AbstractMSQComponentSupplierDelegate
{
@@ -153,7 +153,7 @@ public class DartComponentSupplier extends
AbstractMSQComponentSupplierDelegate
@Dart
Map<String, Worker> workerMap()
{
- return new HashMap<String, Worker>();
+ return new ConcurrentHashMap<>();
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]