Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5215
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160699294
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -717,7 +645,26 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160699235
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160675128
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -743,6 +690,142 @@ private void logAndSysout(String
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674931
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -717,7 +645,26 @@ public int run(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674936
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -717,7 +645,26 @@ public int run(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674722
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674586
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/YarnApplicationStatusMonitor.java
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674427
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r160674117
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159227619
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -717,7 +645,26 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159226314
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159224695
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -743,6 +690,142 @@ private void logAndSysout(String message) {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159225871
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/YarnApplicationStatusMonitor.java
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159227955
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159228367
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -717,7 +645,26 @@ public int run(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159230885
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -743,6 +690,142 @@ private void logAndSysout(String message) {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5215#discussion_r159227421
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -660,7 +570,25 @@ public int run(
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5215
[FLINK-8328] [flip6] Move Yarn ApplicationStatus polling out of
YarnClusterClient
## What is the purpose of the change
Introduce YarnApplicationStatusMonitor which does the Yarn
19 matches
Mail list logo
