Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5216
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r160684153
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -143,31 +138,48 @@
private YarnConfigOptions
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r160683957
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -272,6 +275,7 @@ public void testJavaAPI() throws Exce
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r160683780
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java ---
@@ -78,6 +83,9 @@ public void testPerJobMode() {
jobG
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r159243077
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -272,6 +275,7 @@ public void testJavaAPI() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r159243765
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -143,31 +138,48 @@
private YarnConfigOptions.UserJarI
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5216#discussion_r159242946
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java ---
@@ -78,6 +83,9 @@ public void testPerJobMode() {
jobGraph.addJ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5216
[FLINK-8329] [flip6] Move YarnClient to AbstractYarnClusterDescriptor
## What is the purpose of the change
Moves the YarnClient from the YarnClusterClient to the
AbstractYarnClusterDes
