hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vg...@apache.org
Subject [17/50] [abbrv] hive git commit: HIVE-19472: HiveStreamingConnection swallows exception on partition creation (Prasanth Jayachandran reviewed by Sergey Shelukhin)
Date Tue, 15 May 2018 23:20:45 GMT
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 <prasanthj@apache.org>
Authored: Thu May 10 11:54:54 2018 -0700
Committer: Prasanth Jayachandran <prasanthj@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) {


Mime
View raw message