Repository: hive Updated Branches: refs/heads/master 8105d8ce1 -> 2d8e48c75
HIVE-19472: HiveStreamingConnection swallows exception on partition creation (Prasanth Jayachandran reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/2d8e48c7 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2d8e48c7 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2d8e48c7 Branch: refs/heads/master Commit: 2d8e48c75414cb03d36290f97413124dea8337bb Parents: 8105d8c Author: Prasanth Jayachandran <[email protected]> Authored: Thu May 10 11:54:54 2018 -0700 Committer: Prasanth Jayachandran <[email protected]> Committed: Thu May 10 11:59:06 2018 -0700 ---------------------------------------------------------------------- .../java/org/apache/hive/streaming/HiveStreamingConnection.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/2d8e48c7/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java ---------------------------------------------------------------------- diff --git a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java index 85887b2..f697211 100644 --- a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java +++ b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java @@ -373,7 +373,7 @@ public class HiveStreamingConnection implements StreamingConnection { exists = true; } catch (HiveException | TException e) { throw new StreamingException("Unable to creation partition for values: " + partitionValues + " connection: " + - toConnectionInfoString()); + toConnectionInfoString(), e); } return new PartitionInfo(partName, partLocation, exists); } @@ -460,7 +460,7 @@ public class HiveStreamingConnection implements StreamingConnection { } if (currentTransactionBatch.isClosed()) { - throw new IllegalStateException("Cannot begin next transaction on a closed streaming connection"); + throw new StreamingException("Cannot begin next transaction on a closed streaming connection"); } if (currentTransactionBatch.remainingTransactions() == 0) {
