You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2018/03/27 17:36:47 UTC
asterixdb-bad git commit: Coordinated change for
https://asterix-gerrit.ics.uci.edu/#/c/2533/
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 <mb...@apache.org>
Authored: Tue Mar 27 12:20:17 2018 -0400
Committer: Michael Blow <mb...@apache.org>
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,