zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800286195
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800180651
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,53 +1189,78 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800179109
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132025
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132888
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,53 +1189,78 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132427
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132318
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132122
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientRetrieverImpl.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r800132025
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientWrapper.java
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r783179296
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientRetrieverImpl.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782947211
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientRetrieverImpl.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782262669
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientRetrieverImpl.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782260039
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782254612
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClientRetrieverImpl.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782251384
##
File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java
##
@@ -133,6 +140,42 @@ public void testPerJobWithArchive() throws
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r782251384
##
File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java
##
@@ -133,6 +140,42 @@ public void testPerJobWithArchive() throws
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780378665
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
##
@@ -87,6 +87,6 @@ private YarnClusterDescriptor
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780378665
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
##
@@ -87,6 +87,6 @@ private YarnClusterDescriptor
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780222160
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
##
@@ -87,6 +87,6 @@ private YarnClusterDescriptor
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780378774
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientProviderTest.java
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780378665
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
##
@@ -87,6 +87,6 @@ private YarnClusterDescriptor
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r78043
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientProviderTest.java
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r780222160
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
##
@@ -87,6 +87,6 @@ private YarnClusterDescriptor
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779455643
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779455534
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProvider.java
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779452624
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779451594
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientProviderTest.java
##
@@ -0,0 +1,130 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779444368
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientProviderTest.java
##
@@ -0,0 +1,130 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779443560
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778951672
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778951672
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778951672
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779258575
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r779258470
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778951672
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778563145
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778051063
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,53 +1189,72 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778048091
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778051063
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,53 +1189,72 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778048889
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778048889
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778048091
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778041838
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProvider.java
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778041725
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r778028610
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientProvider.java
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777839182
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,9 +1184,22 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777838682
##
File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java
##
@@ -133,6 +140,38 @@ public void testPerJobWithArchive() throws
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777837645
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777837406
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnAsyncClusterClientProviderFactory.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777837339
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,9 +1184,22 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777837238
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1240,8 +1247,17 @@ private ApplicationReport
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r777836101
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r776918452
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r776918413
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -613,21 +617,42 @@ public void killCluster(ApplicationId
zuston commented on a change in pull request #18220:
URL: https://github.com/apache/flink/pull/18220#discussion_r776918240
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1195,9 +1220,21 @@ private ApplicationReport
55 matches
Mail list logo