diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/DbImportCommand.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/DbImportCommand.java index 5a6107f211..fc4be1c1aa 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/DbImportCommand.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/DbImportCommand.java @@ -21,6 +21,7 @@ package org.jumpmind.symmetric; +import java.io.BufferedInputStream; import java.io.File; import java.io.FileInputStream; @@ -176,7 +177,7 @@ protected boolean executeWithOptions(CommandLine line) throws Exception { } } for (String fileName : args) { - FileInputStream in = new FileInputStream(fileName); + BufferedInputStream in = new BufferedInputStream(new FileInputStream(fileName)); dbImport.importTables(in, line.getOptionValue(OPTION_TABLE)); in.close(); }