Steven Jacobs has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2876
Change subject: Fixed bug with pull-based channel
......................................................................
Fixed bug with pull-based channel
Change-Id: If758f9e8d5c66c5badd819ad877d269bee4408c8
---
M
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
1 file changed, 5 insertions(+), 1 deletion(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb-bad
refs/changes/76/2876/1
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 8e07af2..3e15db8 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
@@ -95,7 +95,11 @@
eval2 = channelExecutionEvalFactory.createScalarEvaluator(ctx);
this.entityId = activeJobId;
this.push = push;
- recordPrinterFactory = new ARecordPrinterFactory((ARecordType)
recordType).createPrinter();
+ if (push) {
+ recordPrinterFactory = new ARecordPrinterFactory((ARecordType)
recordType).createPrinter();
+ } else {
+ recordPrinterFactory = null;
+ }
subscriptionIdListPrinterFactory =
new AOrderedlistPrinterFactory(new
AOrderedListType(BuiltinType.AUUID, null)).createPrinter();
executionTimeString = null;
--
To view, visit https://asterix-gerrit.ics.uci.edu/2876
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: If758f9e8d5c66c5badd819ad877d269bee4408c8
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <[email protected]>
