Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4802
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144027945
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -420,89 +420,72 @@ protected int list(String[] args) {
}
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144019412
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -420,89 +420,72 @@ protected int list(String[] args) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144016836
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -420,89 +420,72 @@ protected int list(String[] args) {
}
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144011359
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -192,6 +196,18 @@ public String cancelWithSavepoint(
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144009864
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/ClusterClientTest.java
---
@@ -134,6 +140,25 @@ public void testClusterClientSavepoint(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144005254
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -192,6 +196,18 @@ public String cancelWithSave
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144006709
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/ClusterClientTest.java
---
@@ -134,6 +140,25 @@ public void testClusterClientSave
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144005365
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendListTest.java ---
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Softw
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144004816
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -420,89 +420,72 @@ protected int list(String[] args) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4802#discussion_r144007707
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -684,6 +688,29 @@ public void stop(final JobID jobId) t
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4802
[FLINK-7791] [REST][client] Integrate LIST command into RestClusterClient
## What is the purpose of the change
This PR integrates the LIST command into the RestClusterClient. This is a
full
12 matches
Mail list logo
