PIG-5382: Log the name when POStore fails on write (knoguchi)
git-svn-id: https://svn.apache.org/repos/asf/pig/trunk@1855283 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt
index 0dba9b8..690dfde 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -26,6 +26,8 @@
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)
diff --git a/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java b/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
index e0e0bc2..c033952 100644
--- a/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
+++ b/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POStore.java
@@ -177,10 +177,10 @@
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;
}
diff --git a/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java b/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
index 7880530..c5fae94 100644
--- a/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
+++ b/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/operator/POStoreTez.java
@@ -142,10 +142,10 @@
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;
}
