|
19 | 19 | package org.apache.accumulo.test.compaction;
|
20 | 20 |
|
21 | 21 | import static com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly;
|
22 |
| -import static java.util.concurrent.TimeUnit.NANOSECONDS; |
| 22 | +import static java.util.concurrent.TimeUnit.MILLISECONDS; |
23 | 23 | import static org.apache.accumulo.core.metrics.Metric.COMPACTOR_ENTRIES_READ;
|
24 | 24 | import static org.apache.accumulo.core.metrics.Metric.COMPACTOR_ENTRIES_WRITTEN;
|
25 | 25 | import static org.apache.accumulo.test.compaction.ExternalCompactionTestUtils.QUEUE1;
|
@@ -184,7 +184,7 @@ public void testCompactionDurationContinuesAfterCoordinatorStop() throws Excepti
|
184 | 184 | .getCompactions().values().iterator().next();
|
185 | 185 | RunningCompactionInfo updatedCompactionInfo = new RunningCompactionInfo(updatedCompaction);
|
186 | 186 |
|
187 |
| - final Duration reportedCompactionDuration = Duration.ofNanos(updatedCompactionInfo.duration); |
| 187 | + final Duration reportedCompactionDuration = Duration.ofMillis(updatedCompactionInfo.duration); |
188 | 188 | final Duration measuredCompactionDuration =
|
189 | 189 | Duration.ofNanos(System.nanoTime() - compactionStartTime);
|
190 | 190 | final Duration coordinatorAge = Duration.ofNanos(System.nanoTime() - coordinatorRestartTime);
|
@@ -431,7 +431,7 @@ private void checkRunning() throws TException {
|
431 | 431 | RunningCompactionInfo rci = new RunningCompactionInfo(ec);
|
432 | 432 | RunningCompactionInfo previousRci = runningMap.put(ecid, rci);
|
433 | 433 | log.debug("ECID {} has been running for {} seconds", ecid,
|
434 |
| - NANOSECONDS.toSeconds(rci.duration)); |
| 434 | + MILLISECONDS.toSeconds(rci.duration)); |
435 | 435 | if (previousRci == null) {
|
436 | 436 | log.debug("New ECID {} with inputFiles: {}", ecid, rci.numFiles);
|
437 | 437 | } else {
|
|
0 commit comments