HBASE-18481 The autoFlush flag was not used in PE tool

This commit is contained in:
Guanghao Zhang 2017-07-30 18:58:47 +08:00
parent 00c1b56665
commit df90ba58db
1 changed files with 6 additions and 0 deletions

View File

@ -1466,6 +1466,9 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
mutator.mutate(put);
if (opts.autoFlush) {
mutator.flush();
}
}
}
@ -1664,6 +1667,9 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
mutator.mutate(put);
if (opts.autoFlush) {
mutator.flush();
}
}
}