Author: gunther
Date: Fri Mar 28 05:51:00 2014
New Revision: 1582611
URL: http://svn.apache.org/r1582611
Log:
HIVE-6748: FileSinkOperator needs to cleanup held references for container
reuse (Gopal V via Gunther Hagleitner)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
URL:
http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java?rev=1582611&r1=1582610&r2=1582611&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
(original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Fri Mar 28 05:51:00 2014
@@ -280,6 +280,7 @@ public class FileSinkOperator extends Te
numFiles = conf.getNumFiles();
dpCtx = conf.getDynPartCtx();
lbCtx = conf.getLbCtx();
+ fsp = prevFsp = null;
valToPaths = new HashMap<String, FSPaths>();
taskId = Utilities.getTaskId(hconf);
initializeSpecPath();
@@ -877,6 +878,7 @@ public class FileSinkOperator extends Te
fsp.abortWriters(fs, abort, !autoDelete && isNativeTable);
}
}
+ fsp = prevFsp = null;
}
/**
