Michael Blow has submitted this change and it was merged. Change subject: Coordinated change for https://asterix-gerrit.ics.uci.edu/#/c/2533/ ......................................................................
Coordinated change for https://asterix-gerrit.ics.uci.edu/#/c/2533/ Change-Id: I0fbc7ee17540b137353a14d0fbac575c36df30cd --- M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java M asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java 10 files changed, 10 insertions(+), 10 deletions(-) Approvals: Jenkins: Verified Michael Blow: Looks good to me, approved diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java index 485a1e1..4f68f40 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java @@ -86,7 +86,7 @@ MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java index 3d43ee6..8403fcc 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java @@ -150,7 +150,7 @@ if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java index 5f08845..ca1241c 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java @@ -219,7 +219,7 @@ MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java index 79c8efd..1b18f83 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java @@ -143,7 +143,7 @@ MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java index 99aded8..367599b 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java @@ -93,7 +93,7 @@ QueryTranslator.abort(e, e, mdTxnCtx); } LOGGER.log(Level.WARNING, "Failed creating a broker", e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java index c3c9a1e..161f093 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java @@ -338,7 +338,7 @@ QueryTranslator.abort(e, e, mdTxnCtx); } LOGGER.log(Level.WARNING, "Failed creating a channel", e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java index cab66c2..f3561a4 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java @@ -314,7 +314,7 @@ QueryTranslator.abort(e, e, mdTxnCtx); } LOGGER.log(Level.WARNING, "Failed creating a procedure", e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java index b597f98..635f2ce 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java @@ -160,7 +160,7 @@ if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java index ebde605..95531bd 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java @@ -145,7 +145,7 @@ if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java index a246193..5d51926 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java @@ -106,7 +106,7 @@ try { executionTimeString = executionTime.toSimpleString(); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } ChannelJobService.sendBrokerNotificationsForChannel(entityId, endpoint.getStringValue(), subs, -- To view, visit https://asterix-gerrit.ics.uci.edu/2537 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I0fbc7ee17540b137353a14d0fbac575c36df30cd Gerrit-PatchSet: 1 Gerrit-Project: asterixdb-bad Gerrit-Branch: master Gerrit-Owner: Michael Blow <mb...@apache.org> Gerrit-Reviewer: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Gerrit-Reviewer: Michael Blow <mb...@apache.org> Gerrit-Reviewer: Murtadha Hubail <mhub...@apache.org> Gerrit-Reviewer: Till Westmann <ti...@apache.org>
