commit 81ee58e3d08f27b26a5409a2b56e173142249557
author Steven Glenn Jacobs <sjaco002@ucr.edu> Tue Jan 16 11:09:15 2018 -0800
committer Steven Jacobs <sjaco002@ucr.edu> Mon Jan 29 13:51:06 2018 -0800
tree 54e708ae5f64f0842bab7279e1025f3cf040d69d
parent fb2c0948bb2f31027cfe8eefdc6ad3a589bb02dd

[ASTERIXDB-2244] Coordinated change

Change-Id: I739532488c14a47d479322b6023b619b5ae213e7

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 @@
     }
 
     @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) };
     }
 }