From fd50e640bdd274eff8fa260951e8959ed03878fd Mon Sep 17 00:00:00 2001 From: Megha Gupta Date: Tue, 28 Mar 2017 11:45:25 +0530 Subject: [PATCH] Update HdfsSpout.java --- .../src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 89776befb40..56c8e6cc6df 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 @@ -529,7 +529,7 @@ private String getDefaultLockDir(Path sourceDirPath) { } private static void checkValidReader(String readerType) { - if ( readerType.equalsIgnoreCase(Configs.TEXT) || readerType.equalsIgnoreCase(Configs.SEQ) ) + if ( readerType.equalsIgnoreCase(Configs.TEXT) || readerType.equalsIgnoreCase(Configs.SEQ) || readerType.equalsIgnoreCase(Configs.ZIP) ) return; try { Class classType = Class.forName(readerType);