Make commit always flush.
This commit is contained in:
parent
75787e5b37
commit
9cf71380e1
@ -124,7 +124,7 @@ public class MetricMessageEventHandler implements EventHandler<MetricMessageEven
|
||||
}
|
||||
if (sequence % batchSize == (batchSize - 1)) {
|
||||
TimerContext context = commitTimer.time();
|
||||
verticaMetricRepository.commitBatch();
|
||||
verticaMetricRepository.flush();
|
||||
context.stop();
|
||||
commitMeter.mark();
|
||||
}
|
||||
|
@ -104,7 +104,7 @@ public class VerticaMetricRepository extends VerticaRepository {
|
||||
|
||||
}
|
||||
|
||||
public void commitBatch() {
|
||||
private void commitBatch() {
|
||||
long startTime = System.currentTimeMillis();
|
||||
metricsBatch.execute();
|
||||
stagedDefinitionsBatch.execute();
|
||||
|
Loading…
Reference in New Issue
Block a user