svn commit: r1855283 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java

[knoguchi]

Author: knoguchi
Date: Tue Mar 12 04:30:42 2019
New Revision: 1855283

URL: http://svn.apache.org/viewvc?rev=1855283&view=rev
Log:
PIG-5382: Log the name when POStore fails on write (knoguchi)

Modified:
    pig/trunk/CHANGES.txt
    
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
    
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java

Modified: pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1855283&r1=1855282&r2=1855283&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Mar 12 04:30:42 2019
@@ -26,6 +26,8 @@ PIG-5282: Upgade to Java 8 (satishsaley
  
 IMPROVEMENTS
 
+PIG-5382: Log the name when POStore fails on write (knoguchi)
+
 PIG-5255: Improvements to bloom join (satishsaley via rohini)
 
 PIG-5359: Reduce time spent in split serialization (satishsaley via rohini)

Modified: 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
URL: 
http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java?rev=1855283&r1=1855282&r2=1855283&view=diff
==============================================================================
--- 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
 (original)
+++ 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
 Tue Mar 12 04:30:42 2019
@@ -177,10 +177,10 @@ public class POStore extends PhysicalOpe
             default:
                 break;
             }
-        } catch (IOException ioe) {
+        } catch (Exception ex) {
             int errCode = 2135;
-            String msg = "Received error from store function." + 
ioe.getMessage();
-            throw new ExecException(msg, errCode, ioe);
+            String msg = "Received error from store function " + name() + ". " 
+ ex.getMessage();
+            throw new ExecException(msg, errCode, ex);
         }
         return res;
     }

Modified: 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
URL: 
http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java?rev=1855283&r1=1855282&r2=1855283&view=diff
==============================================================================
--- 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
 (original)
+++ 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
 Tue Mar 12 04:30:42 2019
@@ -142,10 +142,10 @@ public class POStoreTez extends POStore
             default:
                 break;
             }
-        } catch (IOException ioe) {
+        } catch (Exception ex) {
             int errCode = 2135;
-            String msg = "Received error from store function." + 
ioe.getMessage();
-            throw new ExecException(msg, errCode, ioe);
+            String msg = "Received error from store function " + name() + ". " 
+ ex.getMessage();
+            throw new ExecException(msg, errCode, ex);
         }
         return res;
     }