fixed skipping of first 2 chars of input file

brianmhess · Nov 14, 2016 · 6ff3c15 · 6ff3c15
1 parent bec6e45
commit 6ff3c15
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/.gitignore b/.gitignore
@@ -3,4 +3,6 @@ build/
 *~
 *.jar
 cassandra-loader
-
+*.BADINSERT
+*.BADPARSE
+*.LOG
diff --git a/src/main/java/com/datastax/loader/CqlDelimLoadTask.java b/src/main/java/com/datastax/loader/CqlDelimLoadTask.java
@@ -153,13 +153,12 @@ private void setup() throws IOException, ParseException, org.json.simple.parser.
             readerName = "stdin";
         }
         else {
-            FileInputStream fis = new FileInputStream(infile);
-            InputStream is = fis;
+            InputStream is =  null;
             try {
-                is = new GZIPInputStream(fis);
+                is = new GZIPInputStream(new FileInputStream(infile));
             }
             catch (ZipException e) {
-                is = fis;
+                is = new FileInputStream(infile);
             }
             reader = new BufferedReader(new InputStreamReader(is));
             readerName = infile.getName();