svn commit: r1736097 - /pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java

[daijy]

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));
         }