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 PartitionInfo createPartitionIfNotExists(final List partitionValu 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 @@ private void beginNextTransaction() throws StreamingException { } 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) {