fix unit test error

Author: gavingaozhangmin

pulsar-flink-connector/src/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)));
     }
 }