Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2633#discussion_r184707886
--- Diff:
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java ---
@@ -101,6 +101,7 @@
private final AtomicBoolean commitTimeElapsed = new
AtomicBoolean(false);
private Timer commitTimer;
private boolean fileReadCompletely = true;
+ private boolean newReader = false;
--- End diff --
Does this need to be a field? It looks to me like it would work fine as a
local too?
---
