fix unit test error

streamnative · Nov 30, 2021 · f68f01c · f68f01c
1 parent b832e3a
commit f68f01c
Showing 1 changed file with 10 additions and 4 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
@@ -62,16 +62,22 @@ private static Authentication getAuth(ClientConfigurationData conf)
     public static ClientConfigurationData newClientConf(String serviceUrl, Properties properties) {
         Map<String, Object> clientConfData = getClientParams(Maps.fromProperties(properties));
         ClientConfigurationData clientConf = new ClientConfigurationData();
-        clientConf = ConfigurationDataUtils.loadData(clientConfData, clientConf, ClientConfigurationData.class);
+        clientConf =
+                ConfigurationDataUtils.loadData(
+                        clientConfData, clientConf, ClientConfigurationData.class);
         clientConf.setServiceUrl(serviceUrl);
         return clientConf;
     }
 
     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)));
     }
 }