[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-19 Thread djh4230
Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926 ![image](https://user-images.githubusercontent.com/8032384/34188337-cf86b410-e570-11e7-9781-283685d438bb.png) The hadoop config files are in the flink lauched classpath ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-19 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 @djh4230 could you check whether the Hadoop configuration directory is in the classpath of the launched Flink components? ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-19 Thread djh4230
Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926 ![image](https://user-images.githubusercontent.com/8032384/34147925-5e0fa10c-e4da-11e7-992d-b422f59a7d16.png) Not work! still can't read hdfs-site.xml and can't read hdfs namespace

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-19 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 Hi @djh4230, try to make sure that your Hadoop configuration file is on the classpath or that the `HADOOP_CONF_DIR` is properly set. ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-18 Thread djh4230
Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926 Does that mean it's not a issue? But the issue still happened in flink-1.4.How can i fix the issue? ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 Alright, thanks for the infos @steveloughran. After an offline discussion with @StephanEwen, we decided that we should probably not try to explicitly load a Hadoop configuration file

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-02 Thread steveloughran
Github user steveloughran commented on the issue: https://github.com/apache/flink/pull/4926 creating YarnConfiguration & HdfsConfiguration through some dynamic classloading is enough to force in these files & configs underneath your own Configurations. You shouldn't be reading in all

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 Thanks for the review @steveloughran, @StephanEwen and @aljoscha. If I understood it correctly, then we shouldn't upload the configuration files from the client and instead try to find

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4926 +1 to merge this ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4926 Thanks @steveloughran! I think this approach here should work for then, for now. ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread steveloughran
Github user steveloughran commented on the issue: https://github.com/apache/flink/pull/4926 ah. everything lives in Configuration, and is has some historical structure based on the history of how things all got split up from one big hadoop-default; 1. You can register a new

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4926 @steveloughran if it is okay, maybe we could pick could brain here quickly? What is the Yarn-ideomatic way to handle configurations and what are the assumptions? Specifically: - Do

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4926 The changes look good but let's see what you find regarding `yarn-site.xml`. 👍 ---

[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-11-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4926 A user reported that we maybe have to explicitly load the `yarn-site.xml` in the `HadoopUtils.getHadoopConfiguration` method as we do it for the `core-site.xml` and `hdfs-site.xml`. Will have