Author: gunther
Date: Fri Mar 28 05:51:43 2014
New Revision: 1582612
URL: http://svn.apache.org/r1582612
Log:
HIVE-6748: FileSinkOperator needs to cleanup held references for container
reuse (Gopal V via Gunther Hagleitner)
Modified:
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Modified:
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
URL:
http://svn.apache.org/viewvc/hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java?rev=1582612&r1=1582611&r2=1582612&view=diff
==============================================================================
---
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
(original)
+++
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Fri Mar 28 05:51:43 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;
}
/**
