storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [3/4] storm git commit: STORM-3028 HdfsSpout: handle empty file in case of ackers
Date Mon, 09 Jul 2018 21:31:17 GMT
STORM-3028 HdfsSpout: handle empty file in case of ackers


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/473bf84a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/473bf84a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/473bf84a

Branch: refs/heads/master
Commit: 473bf84a0caef26544b8c01aecd6fb139aa51110
Parents: 3382482
Author: Gergely Hajos <rogozsin@gmail.com>
Authored: Wed May 16 14:18:56 2018 +0200
Committer: Gergely Hajos <rogozsin@gmail.com>
Committed: Wed May 16 14:18:56 2018 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java       | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/473bf84a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java
index e34b194..31fabc8 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java
@@ -231,8 +231,6 @@ public class HdfsSpout extends BaseRichSpout {
                         fileReadCompletely = false;
                         newReader = true;
                     }
-                } else {
-                    newReader = false;
                 }
                 if (fileReadCompletely) { // wait for more ACKs before proceeding
                     return;


Mime
View raw message