Revert code format

AmateurEvents · Jan 20, 2020 · 9a6791d · 9a6791d
1 parent c04354d
commit 9a6791d
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java b/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -770,12 +770,12 @@ protected void waitForProcessingSinkMessages(String tenant,
                                                  String sinkName,
                                                  int numMessages) throws Exception {
         final String[] commands = {
-            PulsarCluster.ADMIN_SCRIPT,
-            "sink",
-            "status",
-            "--tenant", tenant,
-            "--namespace", namespace,
-            "--name", sinkName
+                PulsarCluster.ADMIN_SCRIPT,
+                "sink",
+                "status",
+                "--tenant", tenant,
+                "--namespace", namespace,
+                "--name", sinkName
         };
 
         final ContainerExecResult result = pulsarCluster.getAnyWorker().execCmd(commands);
@@ -1996,8 +1996,8 @@ private static void publishAndConsumeMessagesBytes(String inputTopic,
             }
         } else {
             @Cleanup Producer<byte[]> producer = client.newProducer(Schema.BYTES)
-                .topic(inputTopic)
-                .create();
+                    .topic(inputTopic)
+                    .create();
 
             for (int i = 0; i < numMessages; i++) {
                 producer.send(("message-" + i).getBytes(UTF_8));