Change method signature from find(long incompleteTimeOutMillis) to find(long incompleteTimeOutMillis, int batchSize)
Fix NullPointerException in replay process.