From 0998cde3dd02e507b80b6548af1c9fc9a130da0a Mon Sep 17 00:00:00 2001 From: Jason Gustafson Date: Fri, 6 Jul 2018 15:55:39 -0700 Subject: [PATCH] HOTFIX: Fix checkstyle errors in MetricsTEst --- .../kafka/common/metrics/MetricsTest.java | 50 +++++++++---------- 1 file changed, 23 insertions(+), 27 deletions(-) diff --git a/clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java b/clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java index a902de0cce359..32669ff502247 100644 --- a/clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java +++ b/clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java @@ -624,16 +624,15 @@ public void testConcurrentReadUpdate() throws Exception { final AtomicBoolean alive = new AtomicBoolean(true); executorService = Executors.newSingleThreadExecutor(); executorService.submit(new ConcurrentMetricOperation(alive, "record", new Runnable() { - @Override - public void run() { - while (alive.get()) { - for (Sensor sensor : sensors) { - sensor.record(random.nextInt(10000)); - } - } + @Override + public void run() { + while (alive.get()) { + for (Sensor sensor : sensors) { + sensor.record(random.nextInt(10000)); } - }) - ); + } + } + })); for (int i = 0; i < 10000; i++) { if (sensors.size() > 5) { @@ -708,28 +707,25 @@ public void run() { } } } - }) - ); + })); Future readFuture = executorService.submit(new ConcurrentMetricOperation(alive, "read", new Runnable() { - @Override - public void run() { - while (alive.get()) { - for (Sensor sensor : sensors) { - for (Metric metric : sensor.metrics()) { - assertNotNull("Invalid metric value", metric.metricValue()); - } - } + @Override + public void run() { + while (alive.get()) { + for (Sensor sensor : sensors) { + for (Metric metric : sensor.metrics()) { + assertNotNull("Invalid metric value", metric.metricValue()); } } - }) - ); + } + } + })); Future reportFuture = executorService.submit(new ConcurrentMetricOperation(alive, "report", new Runnable() { - @Override - public void run() { - reporter.processMetrics(); - } - }) - ); + @Override + public void run() { + reporter.processMetrics(); + } + })); for (int i = 0; i < 10000; i++) { if (sensors.size() > 10) {