Add null check on closing AccumuloBulkIngester

This commit is contained in:
liebemd1
2014-11-17 12:54:38 -05:00
parent dd98652d92
commit c42c06f6e2

View File

@@ -229,6 +229,11 @@ public final class AccumuloBulkIngester {
*/
public void shutdown(boolean compact) throws AccumuloSecurityException,
TableNotFoundException, AccumuloException {
// Make sure this wasn't closed already.
if (mtbw == null) {
throw new RuntimeException("Ingester was already closed");
}
mtbw.close();
mtbw = null;