diff --git ql/src/java/org/apache/hadoop/hive/ql/Driver.java ql/src/java/org/apache/hadoop/hive/ql/Driver.java index 762e57c0db..53ead772d1 100644 --- ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -2199,10 +2199,11 @@ private void postExecutionCacheActions() throws Exception { if (plan.hasAcidResourcesInQuery()) { txnWriteIdList = AcidUtils.getValidTxnWriteIdList(conf); } + CacheEntry cacheEntry = cacheUsage.getCacheEntry(); boolean savedToCache = QueryResultsCache.getInstance().setEntryValid( - cacheUsage.getCacheEntry(), + cacheEntry, plan.getFetchTask().getWork()); - LOG.info("savedToCache: {}", savedToCache); + LOG.info("savedToCache: {} ({})", savedToCache, cacheEntry); if (savedToCache) { useFetchFromCache(cacheUsage.getCacheEntry()); // setEntryValid() already increments the reader count. Set usedCacheEntry so it gets released. diff --git ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java index d29c4da5ec..e041b1c817 100644 --- ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java +++ ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java @@ -297,7 +297,7 @@ public Path getCachedResultsPath() { * false if the status changes from PENDING to INVALID */ public boolean waitForValidStatus() { - LOG.info("Waiting on pending cacheEntry"); + LOG.info("Waiting on pending cacheEntry: {}", this); long timeout = 1000; long startTime = System.nanoTime();