Repository: asterixdb-bad Updated Branches: refs/heads/master a7756f103 -> 9e13d7255
Coordinated change for https://asterix-gerrit.ics.uci.edu/#/c/2533/ Change-Id: I0fbc7ee17540b137353a14d0fbac575c36df30cd Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/9e13d725 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/9e13d725 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/9e13d725 Branch: refs/heads/master Commit: 9e13d72552e9499458cd6d95e7459462198b5e2a Parents: a7756f1 Author: Michael Blow <[email protected]> Authored: Tue Mar 27 12:20:17 2018 -0400 Committer: Michael Blow <[email protected]> Committed: Tue Mar 27 12:20:17 2018 -0400 ---------------------------------------------------------------------- .../org/apache/asterix/bad/lang/statement/BrokerDropStatement.java | 2 +- .../apache/asterix/bad/lang/statement/ChannelDropStatement.java | 2 +- .../asterix/bad/lang/statement/ChannelSubscribeStatement.java | 2 +- .../asterix/bad/lang/statement/ChannelUnsubscribeStatement.java | 2 +- .../apache/asterix/bad/lang/statement/CreateBrokerStatement.java | 2 +- .../apache/asterix/bad/lang/statement/CreateChannelStatement.java | 2 +- .../asterix/bad/lang/statement/CreateProcedureStatement.java | 2 +- .../asterix/bad/lang/statement/ExecuteProcedureStatement.java | 2 +- .../apache/asterix/bad/lang/statement/ProcedureDropStatement.java | 2 +- .../java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java | 2 +- 10 files changed, 10 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java ---------------------------------------------------------------------- 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 @@ public class BrokerDropStatement extends ExtensionStatement { MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java ---------------------------------------------------------------------- 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 @@ public class ChannelDropStatement extends ExtensionStatement { if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java ---------------------------------------------------------------------- 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 @@ public class ChannelSubscribeStatement extends ExtensionStatement { MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java ---------------------------------------------------------------------- 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 @@ public class ChannelUnsubscribeStatement extends ExtensionStatement { MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (Exception e) { QueryTranslator.abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java ---------------------------------------------------------------------- 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 @@ public class CreateBrokerStatement extends ExtensionStatement { 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(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java ---------------------------------------------------------------------- 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 @@ public class CreateChannelStatement extends ExtensionStatement { 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(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java ---------------------------------------------------------------------- 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 @@ public class CreateProcedureStatement extends ExtensionStatement { 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(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java ---------------------------------------------------------------------- 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 @@ public class ExecuteProcedureStatement extends ExtensionStatement { if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java ---------------------------------------------------------------------- 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 @@ public class ProcedureDropStatement extends ExtensionStatement { if (txnActive) { QueryTranslator.abort(e, e, mdTxnCtx); } - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/9e13d725/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java ---------------------------------------------------------------------- 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 @@ public class NotifyBrokerRuntime extends AbstractOneInputOneOutputOneFramePushRu try { executionTimeString = executionTime.toSimpleString(); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } ChannelJobService.sendBrokerNotificationsForChannel(entityId, endpoint.getStringValue(), subs,
