Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158023150
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/Task.java ---
@@ -105,9 +115,12 @@ public Task(Executor executor, Integer taskId) throws
IOException {
if (grouping != null && grouping != GrouperFactory.DIRECT) {
throw new IllegalArgumentException("Cannot emitDirect to a
task expecting a regular grouping");
}
- new EmitInfo(values, stream, taskId,
Collections.singletonList(outTaskId)).applyOn(userTopologyContext);
+ if(!userTopologyContext.getHooks().isEmpty()) {
--- End diff --
Nice finding!
---
