diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java index f627a25..6af6b2d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -280,6 +280,7 @@ protected void initializeOp(Configuration hconf) throws HiveException { numFiles = conf.getNumFiles(); dpCtx = conf.getDynPartCtx(); lbCtx = conf.getLbCtx(); + fsp = prevFsp = null; valToPaths = new HashMap(); taskId = Utilities.getTaskId(hconf); initializeSpecPath(); @@ -877,6 +878,7 @@ public void closeOp(boolean abort) throws HiveException { fsp.abortWriters(fs, abort, !autoDelete && isNativeTable); } } + fsp = prevFsp = null; } /**