diff --git a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java index 662ece1c907b..7cc63913c5f6 100644 --- a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java +++ b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java @@ -4890,7 +4890,7 @@ public static enum ConfVars { LLAP_IO_NONVECTOR_WRAPPER_ENABLED("hive.llap.io.nonvector.wrapper.enabled", true, "Whether the LLAP IO layer is enabled for non-vectorized queries that read inputs\n" + "that can be vectorized"), - LLAP_IO_MEMORY_MODE("hive.llap.io.memory.mode", "cache", + LLAP_IO_MEMORY_MODE("hive.llap.io.memory.mode", "none", new StringSet("cache", "none"), "LLAP IO memory usage; 'cache' (the default) uses data and metadata cache with a\n" + "custom off-heap allocator, 'none' doesn't use either (this mode may result in\n" + @@ -5020,7 +5020,7 @@ public static enum ConfVars { "notifications are received by the daemon. Sweep phase of proactive eviction will only do the cache policy " + "cleanup in this case. This can increase cache hit ratio but might scale bad in a workload that generates " + "many proactive eviction events."), - LLAP_IO_CACHE_DELETEDELTAS("hive.llap.io.cache.deletedeltas", "all", new StringSet("none", "metadata", "all"), + LLAP_IO_CACHE_DELETEDELTAS("hive.llap.io.cache.deletedeltas", "none", new StringSet("none", "metadata", "all"), "When set to 'all' queries that use LLAP IO for execution will also access delete delta files via " + "LLAP IO layer and thus they will be fully cached. When set to 'metadata', only the tail of delete deltas " + "will be cached. If set to 'none', only the base files and insert deltas will be channeled through LLAP, " + diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java index 75a71560b81c..34e94a08774c 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java @@ -377,7 +377,9 @@ private void performDataRead() throws IOException { // TODO: I/O threadpool could be here - one thread per stripe; for now, linear. boolean hasFileId = this.fileKey != null; OrcBatchKey stripeKey = hasFileId ? new OrcBatchKey(fileKey, -1, 0) : null; - pathCache.touch(fileKey, split.getPath().toUri().toString()); + if (pathCache != null) { + pathCache.touch(fileKey, split.getPath().toUri().toString()); + } for (int stripeIxMod = 0; stripeIxMod < stripeRgs.length; ++stripeIxMod) { if (processStop()) { return;