[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-16 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r785428305 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFsFactory.java ## @@ -75,6 +75,12 @@ public

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-15 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r785394053 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFsFactory.java ## @@ -75,6 +75,12 @@ public

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-15 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r785393405 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFsFactory.java ## @@ -75,6 +75,12 @@ public

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-15 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r785391572 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFsFactory.java ## @@ -75,6 +75,12 @@ public

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2021-12-02 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761672254 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ## @@ -247,4 +248,43 @@ private static

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2021-12-02 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670505 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java ## @@ -105,6 +105,14 @@

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2021-12-02 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670210 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -431,6 +433,14 @@ public Task( // finally,

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2021-12-02 Thread GitBox
liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670108 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -431,6 +433,14 @@ public Task( // finally,