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..19957ea 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,8 @@ 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 + return new FetchWork(cachedResultsPath, fetchWork.getTblDesc(), fetchWork.getLimit()); } public QueryInfo getQueryInfo() {