fix code style

streamnative · Nov 30, 2021 · cb7e76f · cb7e76f
1 parent f68f01c
commit cb7e76f
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/...rc/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java b/...rc/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java
@@ -72,12 +72,8 @@ public static ClientConfigurationData newClientConf(String serviceUrl, Propertie
     public static Map<String, Object> getClientParams(Map<String, String> parameters) {
         return parameters.keySet().stream()
                 .filter(k -> k.startsWith(PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX))
-                .collect(
-                        Collectors.toMap(
-                                k ->
-                                        k.substring(
-                                                PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX
-                                                        .length()),
-                                k -> parameters.get(k)));
+                .collect(Collectors.toMap(
+                        k -> k.substring(PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX.length()),
+                        k -> parameters.get(k)));
     }
 }