HOTFIX: Fix checkstyle errors in MetricsTest (#5345)
This was broken when picking #5341 into 1.1.
Reviewers: Guozhang Wang <wangguoz@gmail.com>
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 a902de0..32669ff 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 @@
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 @@
}
}
}
- })
- );
+ }));
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) {
