HBASE-18481 The autoFlush flag was not used in PE tool
This commit is contained in:
parent
928137c1ce
commit
8fc010636a
|
@ -1466,6 +1466,9 @@ public class PerformanceEvaluation extends Configured implements Tool {
|
||||||
}
|
}
|
||||||
put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
|
put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
|
||||||
mutator.mutate(put);
|
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);
|
put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
|
||||||
mutator.mutate(put);
|
mutator.mutate(put);
|
||||||
|
if (opts.autoFlush) {
|
||||||
|
mutator.flush();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue