Repository: hive Updated Branches: refs/heads/branch-3 d2c970022 -> c03ae0b3d
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/c03ae0b3 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/c03ae0b3 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/c03ae0b3 Branch: refs/heads/branch-3 Commit: c03ae0b3d89226a7a00124339b763aedcbe1e22f Parents: d2c9700 Author: Prasanth Jayachandran <prasan...@apache.org> Authored: Thu May 10 11:54:54 2018 -0700 Committer: Prasanth Jayachandran <prasan...@apache.org> Committed: Thu May 10 11:59:28 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/c03ae0b3/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) {
