Github user jnioche commented on a diff in the pull request:
https://github.com/apache/storm/pull/2908#discussion_r237006771
--- Diff: flux/flux-core/src/main/java/org/apache/storm/flux/Flux.java ---
@@ -52,17 +52,22 @@
public class Flux {
private static final Logger
Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2908#discussion_r237005496
--- Diff: flux/flux-core/src/main/java/org/apache/storm/flux/Flux.java ---
@@ -52,17 +52,22 @@
public class Flux {
private static final Logger LOG
Github user jnioche commented on a diff in the pull request:
https://github.com/apache/storm/pull/2908#discussion_r237004334
--- Diff: flux/flux-core/src/main/java/org/apache/storm/flux/Flux.java ---
@@ -52,17 +52,22 @@
public class Flux {
private static final Logger
