From 6e046a03a5a81d036388eccf71d95c0a3eddb9bd Mon Sep 17 00:00:00 2001
From: Etienne Chauchot <echauchot@apache.org>
Date: Thu, 5 Apr 2018 10:22:10 +0200
Subject: [PATCH] Fix checkstyle

---
 .../java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java b/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
index a7218aae635d4..172bdc26bfd8a 100644
--- a/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
+++ b/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
@@ -789,8 +789,9 @@ public void processElement(ProcessContext c) {
    * Send {@code events} to Kafka.
    */
   private void sinkEventsToKafka(PCollection<Event> events) {
-    PCollection<byte[]> event_to_bytes = events.apply("Event to bytes", ParDo.of(EVENT_TO_BYTEARRAY));
-    event_to_bytes.apply(KafkaIO.<Void, byte[]>write()
+    PCollection<byte[]> eventToBytes =
+        events.apply("Event to bytes", ParDo.of(EVENT_TO_BYTEARRAY));
+    eventToBytes.apply(KafkaIO.<Void, byte[]>write()
                     .withBootstrapServers(options.getBootstrapServers())
                     .withTopic(options.getKafkaSinkTopic())
                     .withValueSerializer(ByteArraySerializer.class)