Repository: asterixdb-bad Updated Branches: refs/heads/master fb2c0948b -> 81ee58e3d
[ASTERIXDB-2244] Coordinated change Change-Id: I739532488c14a47d479322b6023b619b5ae213e7 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/81ee58e3 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/81ee58e3 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/81ee58e3 Branch: refs/heads/master Commit: 81ee58e3d08f27b26a5409a2b56e173142249557 Parents: fb2c094 Author: Steven Glenn Jacobs <sjaco...@ucr.edu> Authored: Tue Jan 16 11:09:15 2018 -0800 Committer: Steven Jacobs <sjaco...@ucr.edu> Committed: Mon Jan 29 13:51:06 2018 -0800 ---------------------------------------------------------------------- .../apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/81ee58e3/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java index d5d05cf..0e2be8b 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java @@ -49,7 +49,8 @@ public class NotifyBrokerRuntimeFactory implements IPushRuntimeFactory { } @Override - public IPushRuntime createPushRuntime(IHyracksTaskContext ctx) throws HyracksDataException { - return new NotifyBrokerRuntime(ctx, brokerEvalFactory, subEvalFactory, channelExecutionEvalFactory, entityId); + public IPushRuntime[] createPushRuntime(IHyracksTaskContext ctx) throws HyracksDataException { + return new IPushRuntime[] { new NotifyBrokerRuntime(ctx, brokerEvalFactory, subEvalFactory, + channelExecutionEvalFactory, entityId) }; } }
