From 14d8735a1c1bd093624a0ef51a256733099d8516 Mon Sep 17 00:00:00 2001
From: superche <73096722+hechao-ustc@users.noreply.github.com>
Date: Mon, 13 Jun 2022 19:10:38 +0800
Subject: [PATCH] Strip extra spaces when creating new configuration (#5849)

Co-authored-by: superche <superche@tencent.com>
---
 .../main/java/org/apache/hudi/configuration/FlinkOptions.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
index 57cb8daa4..d4fb4656f 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
@@ -823,7 +823,9 @@ public class FlinkOptions extends HoodieConfig {
    */
   public static Configuration fromMap(Map<String, String> map) {
     final Configuration configuration = new Configuration();
-    map.forEach(configuration::setString);
+    for (Map.Entry<String, String> entry : map.entrySet()) {
+      configuration.setString(entry.getKey().trim(), entry.getValue());
+    }
     return configuration;
   }