From f68f01c8d88a0032fc366a5d8612a580e8df93d4 Mon Sep 17 00:00:00 2001
From: gavingaozhangmin <gavingaozhangmin@didiglobal.com>
Date: Tue, 30 Nov 2021 16:50:46 +0800
Subject: [PATCH] fix unit test error

---
 .../pulsar/internal/PulsarClientUtils.java         | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java b/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java
index 92d5e71d..21cb08ae 100644
--- a/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java
+++ b/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java
@@ -62,7 +62,9 @@ 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;
     }
@@ -70,8 +72,12 @@ 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)));
     }
 }