You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2017/01/18 00:11:43 UTC
svn commit: r1779284 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java
Author: daijy
Date: Wed Jan 18 00:11:43 2017
New Revision: 1779284
URL: http://svn.apache.org/viewvc?rev=1779284&view=rev
Log:
PIG-4918: Pig on Tez cannot switch pig.temp.dir to another fs
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1779284&r1=1779283&r2=1779284&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Jan 18 00:11:43 2017
@@ -181,6 +181,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-4918: Pig on Tez cannot switch pig.temp.dir to another fs (daijy)
+
PIG-5078: Script fails with error - POStoreTez only accepts MROutput (rohini)
PIG-5088: HashValuePartitioner has skew when there is only map fields (rohini)
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java?rev=1779284&r1=1779283&r2=1779284&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/TezResourceManager.java Wed Jan 18 00:11:43 2017
@@ -69,7 +69,7 @@ public class TezResourceManager {
public void init(PigContext pigContext, Configuration conf) throws IOException {
if (!inited) {
this.resourcesDir = FileLocalizer.getTemporaryResourcePath(pigContext);
- this.remoteFs = FileSystem.get(conf);
+ this.remoteFs = resourcesDir.getFileSystem(conf);
this.conf = conf;
this.pigContext = pigContext;
this.inited = true;