[hudi] branch master updated: [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink (#5574)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new a704e3740c [HUDI-3336][HUDI-FLINK]Support custom hadoop config for 
flink (#5574)
a704e3740c is described below

commit a704e3740c7b45fa080ff5e57ff14d32530300a1
Author: Bo Cui <cuibo0...@163.com>
AuthorDate: Fri May 13 19:52:55 2022 +0800

    [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink (#5574)
    
    * [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink
---
 .../main/java/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 8bfde20936..012bd09381 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