pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1736097 - /pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
Date Mon, 21 Mar 2016 21:09:26 GMT
Author: daijy
Date: Mon Mar 21 21:09:25 2016
New Revision: 1736097

URL: http://svn.apache.org/viewvc?rev=1736097&view=rev
Log:
PIG-4832: Fix TestPrumeColumn NPE failure

Modified:
    pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java

Modified: pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java?rev=1736097&r1=1736096&r2=1736097&view=diff
==============================================================================
--- pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
(original)
+++ pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
Mon Mar 21 21:09:25 2016
@@ -247,9 +247,11 @@ public class POStore extends PhysicalOpe
 
 
     public StoreFuncInterface getStoreFunc() {
-        if(storer == null){
-            storer = (StoreFuncInterface)PigContext.instantiateFuncFromSpec(sFile.getFuncSpec());
+        if (storer == null) {
+            storer = (StoreFuncInterface) PigContext.instantiateFuncFromSpec(sFile.getFuncSpec());
             storer.setStoreFuncUDFContextSignature(signature);
+        }
+        if (sDecorator == null) {
             // Init the Decorator we use for writing Tuples
             setStoreFuncDecorator(new StoreFuncDecorator(storer, signature));
         }



Mime
View raw message