diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/TezDummyStoreOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/TezDummyStoreOperator.java index d00057a17b..08c1cc408c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/TezDummyStoreOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/TezDummyStoreOperator.java @@ -37,7 +37,7 @@ public TezDummyStoreOperator(CompilationOpContext ctx) { super(ctx); } - private boolean fetchDone = false; + private transient boolean fetchDone = false; /** * Unlike the MR counterpoint, on Tez we want processOp to forward @@ -56,4 +56,10 @@ public boolean getFetchDone() { public void setFetchDone(boolean fetchDone) { this.fetchDone = fetchDone; } + + @Override + public void closeOp(boolean abort) throws HiveException { + super.closeOp(abort); + fetchDone = false; + } }