diff --git a/bin/checkDataIntegrity/Main.class b/bin/checkDataIntegrity/Main.class
index ef1d21e..465e8fb 100644
Binary files a/bin/checkDataIntegrity/Main.class and b/bin/checkDataIntegrity/Main.class differ
diff --git a/checkDataIntegrity.jar b/checkDataIntegrity.jar
index 6bda05e..d376cec 100644
Binary files a/checkDataIntegrity.jar and b/checkDataIntegrity.jar differ
diff --git a/src/checkDataIntegrity/Main.java b/src/checkDataIntegrity/Main.java
index eb04862..d32edfa 100644
--- a/src/checkDataIntegrity/Main.java
+++ b/src/checkDataIntegrity/Main.java
@@ -1,5 +1,8 @@
 package checkDataIntegrity;
 
+import java.io.BufferedInputStream;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.io.InputStream;
 import java.nio.file.Files;
@@ -12,14 +15,18 @@ import java.util.stream.Stream;
 public class Main {
 	
 	public static void main(final String[] args) throws IOException {
-		if (args.length < 2) {
-			System.err.println("Usage: checkDataIntegrity.java <Path0> <Path1>");
+		if (args.length < 4) {
+			System.err.println("Usage: checkDataIntegrity.java <Path0> <Path1> <skip> <limit>");
 			return;
 		}
 		final String path0 = args[0];
 		final String path1 = args[1];
+		final int skip = Integer.parseInt(args[2]);
+		final int limit = Integer.parseInt(args[3]);
 		System.out.println("Path0: " + path0);
 		System.out.println("Path1: " + path1);
+		System.out.println("Skip: " + skip);
+		System.out.println("Limit: " + limit);
 		
 		final long start = System.currentTimeMillis();
 		final AtomicLong count = new AtomicLong();
@@ -31,9 +38,11 @@ public class Main {
 			walk
 					.parallel()
 					.filter(Files::isRegularFile)
-					.forEach(p0 -> {
+					.skip(skip)
+					.limit(limit)
+					.forEachOrdered(p0 -> {
 						long cnt = count.incrementAndGet();
-						if (cnt % 10000 == 0) {
+						if (cnt % 1000 == 0) {
 							System.out.println(cnt);
 						}
 						
@@ -42,7 +51,7 @@ public class Main {
 						
 						final byte[] buf0 = bufs0.get();
 						final byte[] buf1 = bufs1.get();
-						try (InputStream inputStream0 = Files.newInputStream(p0); InputStream inputStream1 = Files.newInputStream(p1);) {
+						try (InputStream inputStream0 = new BufferedInputStream(new FileInputStream(p0.toFile()), 65536); InputStream inputStream1 = new BufferedInputStream(new FileInputStream(p1.toFile()), 65536)) {
 							int len0, len1;
 							do {
 								len0 = inputStream0.read(buf0);
@@ -52,10 +61,7 @@ public class Main {
 									countErr.incrementAndGet();
 									break;
 								}
-								if (len0 == -1) {
-									break;
-								}
-								if (!Arrays.equals(buf0, 0, len0, buf1, 0, len1)) {
+								if (len0 > -1 && !Arrays.equals(buf0, 0, len0, buf1, 0, len1)) {
 									System.out.println(rel + ": Data mismatch");
 									countErr.incrementAndGet();
 									break;
@@ -63,7 +69,7 @@ public class Main {
 							}
 							while (len0 > -1);
 						}
-						catch (NoSuchFileException nsfExc) {
+						catch (NoSuchFileException | FileNotFoundException nsfExc) {
 //							System.out.println(rel + ": NoSuchFileException");
 						}
 						catch (final Exception ex) {
@@ -74,7 +80,7 @@ public class Main {
 		}
 		
 		System.out.println("Took " + (System.currentTimeMillis() - start) + "ms");
-		System.out.println(count.get() + " files");
+		System.out.println(count.get() + " files checked");
 		System.out.println(countErr.get() + " errors");
 		
 		System.exit(countErr.get() > 0 ? 1 : 0);