Merge pull request #24 from vintmd/fixlog

wucheng · web-flow · commit 06dc86d3cbd5 · 2024-05-09T10:38:05.000+08:00
remove user info config log
diff --git a/flink-cos-fs-base/pom.xml b/flink-cos-fs-base/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>flink-cos-fs</artifactId>
         <groupId>com.qcloud.cos</groupId>
-        <version>1.10.0-0.2.2</version>
+        <version>1.10.0-0.2.3</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-cos-fs-examples/pom.xml b/flink-cos-fs-examples/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>flink-cos-fs</artifactId>
         <groupId>com.qcloud.cos</groupId>
-        <version>1.10.0-0.2.2</version>
+        <version>1.10.0-0.2.3</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-cos-fs-hadoop/pom.xml b/flink-cos-fs-hadoop/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>flink-cos-fs</artifactId>
         <groupId>com.qcloud.cos</groupId>
-        <version>1.10.0-0.2.2</version>
+        <version>1.10.0-0.2.3</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-cos-fs-hadoop/src/main/java/org/apache/flink/fs/coshadoop/COSNFileSystemFactory.java b/flink-cos-fs-hadoop/src/main/java/org/apache/flink/fs/coshadoop/COSNFileSystemFactory.java
@@ -120,7 +120,9 @@ protected org.apache.hadoop.conf.Configuration getHadoopConfiguration() {
                         String shadeValue = FLINK_SHADING_PREFIX + value;
                         conf.set(key, shadeValue);
                     }
-                    LOG.info("Adding Flink config entry for {} as {} to Hadoop config", key, conf.get(key));
+                    if (!key.startsWith("fs.cosn.userinfo")) {
+                        LOG.info("Adding Flink config entry for {} as {} to Hadoop config", key, conf.get(key));
+                    }
                 }
             }
         }
diff --git a/flink-fs-hadoop-shaded/pom.xml b/flink-fs-hadoop-shaded/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>flink-cos-fs</artifactId>
         <groupId>com.qcloud.cos</groupId>
-        <version>1.10.0-0.2.2</version>
+        <version>1.10.0-0.2.3</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/pom.xml b/pom.xml
@@ -13,7 +13,7 @@
 
     <groupId>com.qcloud.cos</groupId>
     <artifactId>flink-cos-fs</artifactId>
-    <version>1.10.0-0.2.2</version>
+    <version>1.10.0-0.2.3</version>
     <name>Flink : FileSystems : COS FS</name>
     <description>
         This project aims to provide COS's implementation of the Flink file system interface,

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,9 @@ protected org.apache.hadoop.conf.Configuration getHadoopConfiguration() {`
`120`	`120`	`String shadeValue = FLINK_SHADING_PREFIX + value;`
`121`	`121`	`conf.set(key, shadeValue);`
`122`	`122`	`}`
`123`		`- LOG.info("Adding Flink config entry for {} as {} to Hadoop config", key, conf.get(key));`
	`123`	`+ if (!key.startsWith("fs.cosn.userinfo")) {`
	`124`	`+ LOG.info("Adding Flink config entry for {} as {} to Hadoop config", key, conf.get(key));`
	`125`	`+ }`
`124`	`126`	`}`
`125`	`127`	`}`
`126`	`128`	`}`