From a704e3740c7b45fa080ff5e57ff14d32530300a1 Mon Sep 17 00:00:00 2001
From: Bo Cui <cuibo0108@163.com>
Date: Fri, 13 May 2022 19:52:55 +0800
Subject: [PATCH] [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink
 (#5574)

* [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink
---
 .../org/apache/hudi/source/StreamReadMonitoringFunction.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
index 8bfde2093..012bd0938 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
@@ -158,7 +158,7 @@ public class StreamReadMonitoringFunction
   @Override
   public void open(Configuration parameters) throws Exception {
     super.open(parameters);
-    this.hadoopConf = HadoopConfigurations.getHadoopConf(parameters);
+    this.hadoopConf = HadoopConfigurations.getHadoopConf(conf);
   }
 
   @Override