You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/05/13 07:33:52 UTC
[flink] branch release-1.9 updated: [FLINK-17562][rest] Use correct
headers for POST JobPlanHandler
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 2c85761 [FLINK-17562][rest] Use correct headers for POST JobPlanHandler
2c85761 is described below
commit 2c857610c9ac2fd5e94e4078adcfbc9c7644f24c
Author: SteNicholas <pr...@163.com>
AuthorDate: Tue May 12 15:43:20 2020 +0800
[FLINK-17562][rest] Use correct headers for POST JobPlanHandler
---
docs/_includes/generated/rest_v1_dispatcher.html | 6 +++---
.../org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java | 2 +-
flink-runtime-web/src/test/resources/rest_api_v1.snapshot | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/_includes/generated/rest_v1_dispatcher.html b/docs/_includes/generated/rest_v1_dispatcher.html
index 2f6bdf8..d128d64 100644
--- a/docs/_includes/generated/rest_v1_dispatcher.html
+++ b/docs/_includes/generated/rest_v1_dispatcher.html
@@ -367,7 +367,7 @@ Using 'curl' you can upload a jar via 'curl -X POST -H "Expect:" -F "jarfile=@pa
<td class="text-left" colspan="2"><h5><strong>/jars/:jarid/plan</strong></h5></td>
</tr>
<tr>
- <td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
+ <td class="text-left" style="width: 20%">Verb: <code>POST</code></td>
<td class="text-left">Response code: <code>200 OK</code></td>
</tr>
<tr>
@@ -398,8 +398,8 @@ Using 'curl' you can upload a jar via 'curl -X POST -H "Expect:" -F "jarfile=@pa
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#550027726">Request</button>
- <div id="550027726" class="collapse">
+ <button data-toggle="collapse" data-target="#552419128">Request</button>
+ <div id="552419128" class="collapse">
<pre>
<code>
{
diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java
index efd3c6a..035aa9c 100644
--- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java
+++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java
@@ -123,7 +123,7 @@ public class WebSubmissionExtension implements WebMonitorExtension {
webSubmissionHandlers.add(Tuple2.of(JarRunHeaders.getInstance(), jarRunHandler));
webSubmissionHandlers.add(Tuple2.of(JarDeleteHeaders.getInstance(), jarDeleteHandler));
webSubmissionHandlers.add(Tuple2.of(JarPlanGetHeaders.getInstance(), jarPlanHandler));
- webSubmissionHandlers.add(Tuple2.of(JarPlanGetHeaders.getInstance(), postJarPlanHandler));
+ webSubmissionHandlers.add(Tuple2.of(JarPlanPostHeaders.getInstance(), postJarPlanHandler));
}
@Override
diff --git a/flink-runtime-web/src/test/resources/rest_api_v1.snapshot b/flink-runtime-web/src/test/resources/rest_api_v1.snapshot
index 3fb4c59..690ca57 100644
--- a/flink-runtime-web/src/test/resources/rest_api_v1.snapshot
+++ b/flink-runtime-web/src/test/resources/rest_api_v1.snapshot
@@ -222,7 +222,7 @@
}
}, {
"url" : "/jars/:jarid/plan",
- "method" : "GET",
+ "method" : "POST",
"status-code" : "200 OK",
"file-upload" : false,
"path-parameters" : {