pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From knogu...@apache.org
Subject 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
Date Tue, 12 Mar 2019 04:30:42 GMT
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;
     }



Mime
View raw message