diff --git druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidScanQueryRecordReader.java druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidScanQueryRecordReader.java index 5bbee637cd..6a843aaf16 100644 --- druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidScanQueryRecordReader.java +++ druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidScanQueryRecordReader.java @@ -24,9 +24,9 @@ import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.JavaType; -import com.google.common.collect.Iterators; import java.io.IOException; +import java.util.Collections; import java.util.Iterator; import java.util.List; @@ -38,7 +38,7 @@ private static final TypeReference TYPE_REFERENCE = new TypeReference() { }; - private Iterator> compactedValues = Iterators.emptyIterator(); + private Iterator> compactedValues = Collections.emptyIterator(); @Override protected JavaType getResultTypeDef() { return DruidStorageHandlerUtils.JSON_MAPPER.getTypeFactory().constructType(TYPE_REFERENCE); diff --git pom.xml pom.xml index 7b45d84de8..59025f7737 100644 --- pom.xml +++ pom.xml @@ -149,7 +149,7 @@ 0.1.2 0.13.0-incubating 1.2.0-3f79e055 - 19.0 + 24.1.1-jre 2.4.11 1.3.166 3.1.0 diff --git ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStats.java ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStats.java index b723820f7b..e38a0675b8 100644 --- ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStats.java +++ ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStats.java @@ -86,7 +86,7 @@ public BasicStats build(Partish p) { final ExecutorService pool; if (threads <= 1) { - pool = MoreExecutors.sameThreadExecutor(); + pool = MoreExecutors.newDirectExecutorService(); } else { pool = Executors.newFixedThreadPool(threads, new ThreadFactoryBuilder().setDaemon(true).setNameFormat("Get-Partitions-Size-%d").build()); }