Github user ghajos commented on a diff in the pull request:
https://github.com/apache/storm/pull/2633#discussion_r188606821
--- Diff:
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java ---
@@ -221,14 +221,18 @@ public void nextTuple() {
while (true) {
try {
// 3) Select a new file if one is not open already
+ boolean newReader = false;
if (reader == null) {
reader = pickNextFile();
if (reader == null) {
LOG.debug("Currently no new files to process under
: " + sourceDirPath);
return;
} else {
fileReadCompletely = false;
+ newReader = true;
}
+ } else {
+ newReader = false;
--- End diff --
Thank you for pointing this out!
---
