diff --git a/ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java b/ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java index 131127e..0acade8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/cache/results/QueryResultsCache.java @@ -242,7 +242,10 @@ private String getQueryText() { } public FetchWork getFetchWork() { - return fetchWork; + // FetchWork's sink is used to hold results, so each query needs a separate copy of FetchWork + FetchWork fetch = new FetchWork(cachedResultsPath, fetchWork.getTblDesc(), fetchWork.getLimit()); + fetch.setCachedResult(true); + return fetch; } public QueryInfo getQueryInfo() {