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 2018/04/04 12:22:31 UTC
[13/18] flink git commit: [FLINK-9104][docs] Update generator and
regenerate REST API docs
http://git-wip-us.apache.org/repos/asf/flink/blob/83fffdf3/docs/_includes/generated/rest_dispatcher.html
----------------------------------------------------------------------
diff --git a/docs/_includes/generated/rest_dispatcher.html b/docs/_includes/generated/rest_dispatcher.html
index 25bdff1..e02c232 100644
--- a/docs/_includes/generated/rest_dispatcher.html
+++ b/docs/_includes/generated/rest_dispatcher.html
@@ -12,8 +12,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1881098330">Request</button>
- <div id="-1881098330" class="collapse">
+ <button data-toggle="collapse" data-target="#1124793457">Request</button>
+ <div id="1124793457" class="collapse">
<pre>
<code>
{} </code>
@@ -23,18 +23,18 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-574888474">Response</button>
- <div id="-574888474" class="collapse">
+ <button data-toggle="collapse" data-target="#-1863963983">Response</button>
+ <div id="-1863963983" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:BlobServerPortResponseBody",
- "properties" : {
- "port" : {
- "type" : "integer"
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:BlobServerPortResponseBody",
+ "properties" : {
+ "port" : {
+ "type" : "integer"
+ }
+ }
} </code>
</pre>
</div>
@@ -56,8 +56,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1357269034">Request</button>
- <div id="-1357269034" class="collapse">
+ <button data-toggle="collapse" data-target="#1648622753">Request</button>
+ <div id="1648622753" class="collapse">
<pre>
<code>
{} </code>
@@ -67,30 +67,30 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-642531372">Response</button>
- <div id="-642531372" class="collapse">
+ <button data-toggle="collapse" data-target="#-1931606881">Response</button>
+ <div id="-1931606881" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:DashboardConfiguration",
- "properties" : {
- "refreshInterval" : {
- "type" : "integer"
- },
- "timeZoneName" : {
- "type" : "string"
- },
- "timeZoneOffset" : {
- "type" : "integer"
- },
- "flinkVersion" : {
- "type" : "string"
- },
- "flinkRevision" : {
- "type" : "string"
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:DashboardConfiguration",
+ "properties" : {
+ "refreshInterval" : {
+ "type" : "integer"
+ },
+ "timeZoneName" : {
+ "type" : "string"
+ },
+ "timeZoneOffset" : {
+ "type" : "integer"
+ },
+ "flinkVersion" : {
+ "type" : "string"
+ },
+ "flinkRevision" : {
+ "type" : "string"
+ }
+ }
} </code>
</pre>
</div>
@@ -112,8 +112,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1353094089">Request</button>
- <div id="-1353094089" class="collapse">
+ <button data-toggle="collapse" data-target="#1652797698">Request</button>
+ <div id="1652797698" class="collapse">
<pre>
<code>
{} </code>
@@ -123,24 +123,24 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1672532771">Response</button>
- <div id="-1672532771" class="collapse">
+ <button data-toggle="collapse" data-target="#1333359016">Response</button>
+ <div id="1333359016" class="collapse">
<pre>
<code>
-{
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:ClusterConfigurationInfoEntry",
- "properties" : {
- "key" : {
- "type" : "string"
- },
- "value" : {
- "type" : "string"
- }
- }
- }
+{
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:ClusterConfigurationInfoEntry",
+ "properties" : {
+ "key" : {
+ "type" : "string"
+ },
+ "value" : {
+ "type" : "string"
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -172,8 +172,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1667487464">Request</button>
- <div id="-1667487464" class="collapse">
+ <button data-toggle="collapse" data-target="#1338404323">Request</button>
+ <div id="1338404323" class="collapse">
<pre>
<code>
{} </code>
@@ -183,30 +183,30 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1356759103">Response</button>
- <div id="-1356759103" class="collapse">
+ <button data-toggle="collapse" data-target="#1649132684">Response</button>
+ <div id="1649132684" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
- "properties" : {
- "metrics" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
- "properties" : {
- "id" : {
- "type" : "string"
- },
- "value" : {
- "type" : "string"
- }
- }
- }
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
+ "properties" : {
+ "metrics" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
+ "properties" : {
+ "id" : {
+ "type" : "string"
+ },
+ "value" : {
+ "type" : "string"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -228,8 +228,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1281196202">Request</button>
- <div id="1281196202" class="collapse">
+ <button data-toggle="collapse" data-target="#-7879307">Request</button>
+ <div id="-7879307" class="collapse">
<pre>
<code>
{} </code>
@@ -239,46 +239,46 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1630160880">Response</button>
- <div id="1630160880" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobIdsWithStatusOverview",
- "properties" : {
- "jobsWithStatus" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobIdsWithStatusOverview:JobIdWithStatus",
- "properties" : {
- "jobId" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
- "properties" : {
- "upperPart" : {
- "type" : "integer"
- },
- "lowerPart" : {
- "type" : "integer"
- },
- "bytes" : {
- "type" : "array",
- "items" : {
- "type" : "integer"
- }
- }
- }
- },
- "jobStatus" : {
- "type" : "string",
- "enum" : [ "CREATED", "RUNNING", "FAILING", "FAILED", "CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDED", "RECONCILING" ]
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#341085371">Response</button>
+ <div id="341085371" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobIdsWithStatusOverview",
+ "properties" : {
+ "jobsWithStatus" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobIdsWithStatusOverview:JobIdWithStatus",
+ "properties" : {
+ "jobId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "jobStatus" : {
+ "type" : "string",
+ "enum" : [ "CREATED", "RUNNING", "FAILING", "FAILED", "CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDING", "SUSPENDED", "RECONCILING" ]
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -300,21 +300,21 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1710504926">Request</button>
- <div id="1710504926" class="collapse">
+ <button data-toggle="collapse" data-target="#-1188986258">Request</button>
+ <div id="-1188986258" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobSubmitRequestBody",
- "properties" : {
- "serializedJobGraph" : {
- "type" : "array",
- "items" : {
- "type" : "integer"
- }
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobSubmitRequestBody",
+ "properties" : {
+ "serializedJobGraph" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -322,18 +322,18 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-476159276">Response</button>
- <div id="-476159276" class="collapse">
+ <button data-toggle="collapse" data-target="#919316836">Response</button>
+ <div id="919316836" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobSubmitResponseBody",
- "properties" : {
- "jobUrl" : {
- "type" : "string"
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobSubmitResponseBody",
+ "properties" : {
+ "jobUrl" : {
+ "type" : "string"
+ }
+ }
} </code>
</pre>
</div>
@@ -355,8 +355,114 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-297252120">Request</button>
- <div id="-297252120" class="collapse">
+ <button data-toggle="collapse" data-target="#-1586327629">Request</button>
+ <div id="-1586327629" class="collapse">
+ <pre>
+ <code>
+{} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#-1663567735">Response</button>
+ <div id="-1663567735" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:MultipleJobsDetails",
+ "properties" : {
+ "jobs" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobDetails",
+ "properties" : {
+ "jobId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "jobName" : {
+ "type" : "string"
+ },
+ "startTime" : {
+ "type" : "integer"
+ },
+ "endTime" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "CREATED", "RUNNING", "FAILING", "FAILED", "CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDING", "SUSPENDED", "RECONCILING" ]
+ },
+ "lastUpdateTime" : {
+ "type" : "integer"
+ },
+ "tasksPerState" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ },
+ "numTasks" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ }
+} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ </tbody>
+</table>
+<table class="table table-bordered">
+ <tbody>
+ <tr>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid</strong></td>
+ </tr>
+ <tr>
+ <td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
+ <td class="text-left">Response code: <code>200 OK</code></td>
+ </tr>
+ <tr>
+ <td colspan="2">description</td>
+ </tr>
+ <tr>
+ <td colspan="2">Path parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>jobid</code> - description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#-2071441832">Request</button>
+ <div id="-2071441832" class="collapse">
<pre>
<code>
{} </code>
@@ -366,70 +472,152 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-374492226">Response</button>
- <div id="-374492226" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:MultipleJobsDetails",
- "properties" : {
- "jobs" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:messages:webmonitor:JobDetails",
- "properties" : {
- "jobId" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
- "properties" : {
- "upperPart" : {
- "type" : "integer"
- },
- "lowerPart" : {
- "type" : "integer"
- },
- "bytes" : {
- "type" : "array",
- "items" : {
- "type" : "integer"
- }
- }
- }
- },
- "jobName" : {
- "type" : "string"
- },
- "startTime" : {
- "type" : "integer"
- },
- "endTime" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "status" : {
- "type" : "string",
- "enum" : [ "CREATED", "RUNNING", "FAILING", "FAILED", "CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDED", "RECONCILING" ]
- },
- "lastUpdateTime" : {
- "type" : "integer"
- },
- "tasksPerState" : {
- "type" : "array",
- "items" : {
- "type" : "integer"
- }
- },
- "numTasks" : {
- "type" : "integer"
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#998294776">Response</button>
+ <div id="998294776" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobDetailsInfo",
+ "properties" : {
+ "jobId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "name" : {
+ "type" : "string"
+ },
+ "jobStatus" : {
+ "type" : "string",
+ "enum" : [ "CREATED", "RUNNING", "FAILING", "FAILED", "CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDING", "SUSPENDED", "RECONCILING" ]
+ },
+ "startTime" : {
+ "type" : "integer"
+ },
+ "endTime" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "now" : {
+ "type" : "integer"
+ },
+ "timestamps" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "integer"
+ }
+ },
+ "jobVertexInfos" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobDetailsInfo:JobVertexDetailsInfo",
+ "properties" : {
+ "jobVertexID" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:jobgraph:JobVertexID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "name" : {
+ "type" : "string"
+ },
+ "parallelism" : {
+ "type" : "integer"
+ },
+ "executionState" : {
+ "type" : "string",
+ "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING", "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
+ },
+ "startTime" : {
+ "type" : "integer"
+ },
+ "endTime" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "tasksPerState" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "integer"
+ }
+ },
+ "jobVertexMetrics" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
+ "properties" : {
+ "bytesRead" : {
+ "type" : "integer"
+ },
+ "bytesReadComplete" : {
+ "type" : "boolean"
+ },
+ "bytesWritten" : {
+ "type" : "integer"
+ },
+ "bytesWrittenComplete" : {
+ "type" : "boolean"
+ },
+ "recordsRead" : {
+ "type" : "integer"
+ },
+ "recordsReadComplete" : {
+ "type" : "boolean"
+ },
+ "recordsWritten" : {
+ "type" : "integer"
+ },
+ "recordsWrittenComplete" : {
+ "type" : "boolean"
+ }
+ }
+ }
+ }
+ }
+ },
+ "jobVerticesPerState" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "integer"
+ }
+ },
+ "jsonPlan" : {
+ "type" : "string"
+ },
+ "stoppable" : {
+ "type" : "boolean"
+ }
+ }
} </code>
</pre>
</div>
@@ -471,8 +659,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1776493329">Request</button>
- <div id="1776493329" class="collapse">
+ <button data-toggle="collapse" data-target="#-1977276770">Request</button>
+ <div id="-1977276770" class="collapse">
<pre>
<code>
{} </code>
@@ -482,8 +670,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1961476153">Response</button>
- <div id="1961476153" class="collapse">
+ <button data-toggle="collapse" data-target="#-1792293946">Response</button>
+ <div id="-1792293946" class="collapse">
<pre>
<code>
{} </code>
@@ -496,7 +684,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/accumulators</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -516,9 +704,19 @@
</td>
</tr>
<tr>
+ <td colspan="2">Query parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>includeSerializedValue</code> (optional): description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-782366323">Request</button>
- <div id="-782366323" class="collapse">
+ <button data-toggle="collapse" data-target="#-2064509468">Request</button>
+ <div id="-2064509468" class="collapse">
<pre>
<code>
{} </code>
@@ -528,12 +726,54 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-2007597011">Response</button>
- <div id="-2007597011" class="collapse">
+ <button data-toggle="collapse" data-target="#-1744345868">Response</button>
+ <div id="-1744345868" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobAccumulatorsInfo",
+ "properties" : {
+ "jobAccumulators" : {
+ "type" : "array",
+ "items" : {
+ "type" : "any"
+ }
+ },
+ "userAccumulators" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobAccumulatorsInfo:UserTaskAccumulator",
+ "properties" : {
+ "name" : {
+ "type" : "string"
+ },
+ "type" : {
+ "type" : "string"
+ },
+ "value" : {
+ "type" : "string"
+ }
+ }
+ }
+ },
+ "serializedUserAccumulators" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:util:SerializedValue<org:apache:flink:util:OptionalFailure<java:lang:Object>>",
+ "properties" : {
+ "byteArray" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -544,7 +784,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/accumulators</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -565,8 +805,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-775433959">Request</button>
- <div id="-775433959" class="collapse">
+ <button data-toggle="collapse" data-target="#-1417778508">Request</button>
+ <div id="-1417778508" class="collapse">
<pre>
<code>
{} </code>
@@ -576,12 +816,267 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-455270359">Response</button>
- <div id="-455270359" class="collapse">
+ <button data-toggle="collapse" data-target="#-850872826">Response</button>
+ <div id="-850872826" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics",
+ "properties" : {
+ "counts" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:Counts",
+ "properties" : {
+ "numberRestoredCheckpoints" : {
+ "type" : "integer"
+ },
+ "totalNumberCheckpoints" : {
+ "type" : "integer"
+ },
+ "numberInProgressCheckpoints" : {
+ "type" : "integer"
+ },
+ "numberCompletedCheckpoints" : {
+ "type" : "integer"
+ },
+ "numberFailedCheckpoints" : {
+ "type" : "integer"
+ }
+ }
+ },
+ "summary" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:Summary",
+ "properties" : {
+ "stateSize" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics",
+ "properties" : {
+ "minimum" : {
+ "type" : "integer"
+ },
+ "maximum" : {
+ "type" : "integer"
+ },
+ "average" : {
+ "type" : "integer"
+ }
+ }
+ },
+ "duration" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ },
+ "alignmentBuffered" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ }
+ }
+ },
+ "latestCheckpoints" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:LatestCheckpoints",
+ "properties" : {
+ "completedCheckpointStatistics" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:CompletedCheckpointStatistics",
+ "properties" : {
+ "id" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "savepoint" : {
+ "type" : "boolean"
+ },
+ "triggerTimestamp" : {
+ "type" : "integer"
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ },
+ "checkpointStatisticsPerTask" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics",
+ "properties" : {
+ "checkpointId" : {
+ "type" : "integer"
+ },
+ "checkpointStatus" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "externalPath" : {
+ "type" : "string"
+ },
+ "discarded" : {
+ "type" : "boolean"
+ }
+ }
+ },
+ "savepointStatistics" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:CompletedCheckpointStatistics"
+ },
+ "failedCheckpointStatistics" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:FailedCheckpointStatistics",
+ "properties" : {
+ "id" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "savepoint" : {
+ "type" : "boolean"
+ },
+ "triggerTimestamp" : {
+ "type" : "integer"
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ },
+ "checkpointStatisticsPerTask" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics"
+ }
+ },
+ "failureTimestamp" : {
+ "type" : "integer"
+ },
+ "failureMessage" : {
+ "type" : "string"
+ }
+ }
+ },
+ "restoredCheckpointStatistics" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:RestoredCheckpointStatistics",
+ "properties" : {
+ "id" : {
+ "type" : "integer"
+ },
+ "restoreTimestamp" : {
+ "type" : "integer"
+ },
+ "savepoint" : {
+ "type" : "boolean"
+ },
+ "externalPath" : {
+ "type" : "string"
+ }
+ }
+ }
+ }
+ },
+ "history" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics",
+ "properties" : {
+ "id" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "savepoint" : {
+ "type" : "boolean"
+ },
+ "triggerTimestamp" : {
+ "type" : "integer"
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ },
+ "checkpointStatisticsPerTask" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics"
+ }
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -592,7 +1087,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/config</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -613,8 +1108,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-128702999">Request</button>
- <div id="-128702999" class="collapse">
+ <button data-toggle="collapse" data-target="#-1872439843">Request</button>
+ <div id="-1872439843" class="collapse">
<pre>
<code>
{} </code>
@@ -624,267 +1119,12 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#438202683">Response</button>
- <div id="438202683" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics",
- "properties" : {
- "counts" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:Counts",
- "properties" : {
- "numberRestoredCheckpoints" : {
- "type" : "integer"
- },
- "totalNumberCheckpoints" : {
- "type" : "integer"
- },
- "numberInProgressCheckpoints" : {
- "type" : "integer"
- },
- "numberCompletedCheckpoints" : {
- "type" : "integer"
- },
- "numberFailedCheckpoints" : {
- "type" : "integer"
- }
- }
- },
- "summary" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:Summary",
- "properties" : {
- "stateSize" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics",
- "properties" : {
- "minimum" : {
- "type" : "integer"
- },
- "maximum" : {
- "type" : "integer"
- },
- "average" : {
- "type" : "integer"
- }
- }
- },
- "duration" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- },
- "alignmentBuffered" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- }
- }
- },
- "latestCheckpoints" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:LatestCheckpoints",
- "properties" : {
- "completedCheckpointStatistics" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:CompletedCheckpointStatistics",
- "properties" : {
- "id" : {
- "type" : "integer"
- },
- "status" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "savepoint" : {
- "type" : "boolean"
- },
- "triggerTimestamp" : {
- "type" : "integer"
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- },
- "checkpointStatisticsPerTask" : {
- "type" : "object",
- "additionalProperties" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics",
- "properties" : {
- "checkpointId" : {
- "type" : "integer"
- },
- "checkpointStatus" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- }
- }
- }
- },
- "externalPath" : {
- "type" : "string"
- },
- "discarded" : {
- "type" : "boolean"
- }
- }
- },
- "savepointStatistics" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:CompletedCheckpointStatistics"
- },
- "failedCheckpointStatistics" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics:FailedCheckpointStatistics",
- "properties" : {
- "id" : {
- "type" : "integer"
- },
- "status" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "savepoint" : {
- "type" : "boolean"
- },
- "triggerTimestamp" : {
- "type" : "integer"
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- },
- "checkpointStatisticsPerTask" : {
- "type" : "object",
- "additionalProperties" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics"
- }
- },
- "failureTimestamp" : {
- "type" : "integer"
- },
- "failureMessage" : {
- "type" : "string"
- }
- }
- },
- "restoredCheckpointStatistics" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointingStatistics:RestoredCheckpointStatistics",
- "properties" : {
- "id" : {
- "type" : "integer"
- },
- "restoreTimestamp" : {
- "type" : "integer"
- },
- "savepoint" : {
- "type" : "boolean"
- },
- "externalPath" : {
- "type" : "string"
- }
- }
- }
- }
- },
- "history" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics",
- "properties" : {
- "id" : {
- "type" : "integer"
- },
- "status" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "savepoint" : {
- "type" : "boolean"
- },
- "triggerTimestamp" : {
- "type" : "integer"
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- },
- "checkpointStatisticsPerTask" : {
- "type" : "object",
- "additionalProperties" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics"
- }
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#1325385076">Response</button>
+ <div id="1325385076" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "any"
} </code>
</pre>
</div>
@@ -895,7 +1135,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/config</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -911,13 +1151,15 @@
<td colspan="2">
<ul>
<li><code>jobid</code> - description</li>
+<li><code>checkpointid</code> - description</li>
+<li><code>vertexid</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-583364334">Request</button>
- <div id="-583364334" class="collapse">
+ <button data-toggle="collapse" data-target="#723836914">Request</button>
+ <div id="723836914" class="collapse">
<pre>
<code>
{} </code>
@@ -927,12 +1169,108 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1680506711">Response</button>
- <div id="-1680506711" class="collapse">
+ <button data-toggle="collapse" data-target="#664379972">Response</button>
+ <div id="664379972" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails",
+ "properties" : {
+ "checkpointId" : {
+ "type" : "integer"
+ },
+ "checkpointStatus" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ },
+ "summary" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:Summary",
+ "properties" : {
+ "stateSize" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics",
+ "properties" : {
+ "minimum" : {
+ "type" : "integer"
+ },
+ "maximum" : {
+ "type" : "integer"
+ },
+ "average" : {
+ "type" : "integer"
+ }
+ }
+ },
+ "duration" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ },
+ "checkpointDuration" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:CheckpointDuration",
+ "properties" : {
+ "synchronousDuration" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ },
+ "asynchronousDuration" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ }
+ }
+ },
+ "checkpointAlignment" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:CheckpointAlignment",
+ "properties" : {
+ "bufferedData" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ },
+ "duration" : {
+ "type" : "object",
+ "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
+ }
+ }
+ }
+ }
+ },
+ "subtaskCheckpointStatistics" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:SubtaskCheckpointStatistics",
+ "properties" : {
+ "index" : {
+ "type" : "integer"
+ },
+ "checkpointStatus" : {
+ "type" : "string"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -943,7 +1281,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/:checkpointid</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -960,14 +1298,13 @@
<ul>
<li><code>jobid</code> - description</li>
<li><code>checkpointid</code> - description</li>
-<li><code>vertexid</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#2012912423">Request</button>
- <div id="2012912423" class="collapse">
+ <button data-toggle="collapse" data-target="#-450903614">Request</button>
+ <div id="-450903614" class="collapse">
<pre>
<code>
{} </code>
@@ -977,108 +1314,80 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1953455481">Response</button>
- <div id="1953455481" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails",
- "properties" : {
- "checkpointId" : {
- "type" : "integer"
- },
- "checkpointStatus" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- },
- "summary" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:Summary",
- "properties" : {
- "stateSize" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics",
- "properties" : {
- "minimum" : {
- "type" : "integer"
- },
- "maximum" : {
- "type" : "integer"
- },
- "average" : {
- "type" : "integer"
- }
- }
- },
- "duration" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- },
- "checkpointDuration" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:CheckpointDuration",
- "properties" : {
- "synchronousDuration" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- },
- "asynchronousDuration" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- }
- }
- },
- "checkpointAlignment" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatisticsWithSubtaskDetails:CheckpointAlignment",
- "properties" : {
- "bufferedData" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- },
- "duration" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:MinMaxAvgStatistics"
- }
- }
- }
- }
- },
- "subtaskCheckpointStatistics" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:SubtaskCheckpointStatistics",
- "properties" : {
- "index" : {
- "type" : "integer"
- },
- "checkpointStatus" : {
- "type" : "string"
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#1821144940">Response</button>
+ <div id="1821144940" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics",
+ "properties" : {
+ "id" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "savepoint" : {
+ "type" : "boolean"
+ },
+ "triggerTimestamp" : {
+ "type" : "integer"
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ },
+ "checkpointStatisticsPerTask" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics",
+ "properties" : {
+ "checkpointId" : {
+ "type" : "integer"
+ },
+ "checkpointStatus" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
+ },
+ "latestAckTimestamp" : {
+ "type" : "integer"
+ },
+ "stateSize" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "alignmentBuffered" : {
+ "type" : "integer"
+ },
+ "numSubtasks" : {
+ "type" : "integer"
+ },
+ "numAckSubtasks" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1089,7 +1398,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/checkpoints/:checkpointid</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/config</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1105,14 +1414,13 @@
<td colspan="2">
<ul>
<li><code>jobid</code> - description</li>
-<li><code>checkpointid</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#838171895">Request</button>
- <div id="838171895" class="collapse">
+ <button data-toggle="collapse" data-target="#1648775609">Request</button>
+ <div id="1648775609" class="collapse">
<pre>
<code>
{} </code>
@@ -1122,80 +1430,39 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1184746847">Response</button>
- <div id="-1184746847" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:CheckpointStatistics",
- "properties" : {
- "id" : {
- "type" : "integer"
- },
- "status" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "savepoint" : {
- "type" : "boolean"
- },
- "triggerTimestamp" : {
- "type" : "integer"
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- },
- "checkpointStatisticsPerTask" : {
- "type" : "object",
- "additionalProperties" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:checkpoints:TaskCheckpointStatistics",
- "properties" : {
- "checkpointId" : {
- "type" : "integer"
- },
- "checkpointStatus" : {
- "type" : "string",
- "enum" : [ "IN_PROGRESS", "COMPLETED", "FAILED" ]
- },
- "latestAckTimestamp" : {
- "type" : "integer"
- },
- "stateSize" : {
- "type" : "integer"
- },
- "duration" : {
- "type" : "integer"
- },
- "alignmentBuffered" : {
- "type" : "integer"
- },
- "numSubtasks" : {
- "type" : "integer"
- },
- "numAckSubtasks" : {
- "type" : "integer"
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#-1215495906">Response</button>
+ <div id="-1215495906" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobConfigInfo",
+ "properties" : {
+ "jobId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "jobName" : {
+ "type" : "string"
+ },
+ "executionConfigInfo" : {
+ "type" : "any"
+ }
+ }
} </code>
</pre>
</div>
@@ -1206,7 +1473,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/config</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/exceptions</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1227,8 +1494,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1357116178">Request</button>
- <div id="-1357116178" class="collapse">
+ <button data-toggle="collapse" data-target="#-494359301">Request</button>
+ <div id="-494359301" class="collapse">
<pre>
<code>
{} </code>
@@ -1238,39 +1505,12 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#73579603">Response</button>
- <div id="73579603" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobConfigInfo",
- "properties" : {
- "jobId" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
- "properties" : {
- "upperPart" : {
- "type" : "integer"
- },
- "lowerPart" : {
- "type" : "integer"
- },
- "bytes" : {
- "type" : "array",
- "items" : {
- "type" : "integer"
- }
- }
- }
- },
- "jobName" : {
- "type" : "string"
- },
- "executionConfigInfo" : {
- "type" : "any"
- }
- }
+ <button data-toggle="collapse" data-target="#-1465234270">Response</button>
+ <div id="-1465234270" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "any"
} </code>
</pre>
</div>
@@ -1281,7 +1521,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/exceptions</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/execution-result</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1302,8 +1542,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#794716208">Request</button>
- <div id="794716208" class="collapse">
+ <button data-toggle="collapse" data-target="#-1141690839">Request</button>
+ <div id="-1141690839" class="collapse">
<pre>
<code>
{} </code>
@@ -1313,12 +1553,79 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-176158761">Response</button>
- <div id="-176158761" class="collapse">
+ <button data-toggle="collapse" data-target="#-1847991759">Response</button>
+ <div id="-1847991759" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:JobExecutionResultResponseBody",
+ "properties" : {
+ "status" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:queue:QueueStatus",
+ "properties" : {
+ "id" : {
+ "type" : "string",
+ "enum" : [ "IN_PROGRESS", "COMPLETED" ]
+ }
+ }
+ },
+ "jobExecutionResult" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:jobmaster:JobResult",
+ "properties" : {
+ "jobId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:api:common:JobID",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ },
+ "accumulatorResults" : {
+ "type" : "object",
+ "additionalProperties" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:util:SerializedValue<org:apache:flink:util:OptionalFailure<java:lang:Object>>",
+ "properties" : {
+ "byteArray" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ },
+ "netRuntime" : {
+ "type" : "integer"
+ },
+ "serializedThrowable" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:java:util:Optional<org:apache:flink:util:SerializedThrowable>",
+ "properties" : {
+ "present" : {
+ "type" : "boolean"
+ }
+ }
+ },
+ "success" : {
+ "type" : "boolean"
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1360,8 +1667,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1792172223">Request</button>
- <div id="-1792172223" class="collapse">
+ <button data-toggle="collapse" data-target="#1213719564">Request</button>
+ <div id="1213719564" class="collapse">
<pre>
<code>
{} </code>
@@ -1371,30 +1678,30 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1481443862">Response</button>
- <div id="-1481443862" class="collapse">
+ <button data-toggle="collapse" data-target="#1524447925">Response</button>
+ <div id="1524447925" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
- "properties" : {
- "metrics" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
- "properties" : {
- "id" : {
- "type" : "string"
- },
- "value" : {
- "type" : "string"
- }
- }
- }
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
+ "properties" : {
+ "metrics" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
+ "properties" : {
+ "id" : {
+ "type" : "string"
+ },
+ "value" : {
+ "type" : "string"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1426,8 +1733,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-895161707">Request</button>
- <div id="-895161707" class="collapse">
+ <button data-toggle="collapse" data-target="#2110730080">Request</button>
+ <div id="2110730080" class="collapse">
<pre>
<code>
{} </code>
@@ -1437,18 +1744,18 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#597567777">Response</button>
- <div id="597567777" class="collapse">
+ <button data-toggle="collapse" data-target="#-691507732">Response</button>
+ <div id="-691507732" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobPlanInfo",
- "properties" : {
- "jsonPlan" : {
- "type" : "string"
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobPlanInfo",
+ "properties" : {
+ "jsonPlan" : {
+ "type" : "string"
+ }
+ }
} </code>
</pre>
</div>
@@ -1459,10 +1766,10 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/accumulators</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/rescaling</strong></td>
</tr>
<tr>
- <td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
+ <td class="text-left" style="width: 20%">Verb: <code>PATCH</code></td>
<td class="text-left">Response code: <code>200 OK</code></td>
</tr>
<tr>
@@ -1475,14 +1782,23 @@
<td colspan="2">
<ul>
<li><code>jobid</code> - description</li>
-<li><code>vertexid</code> - description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">Query parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>parallelism</code> (mandatory): description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-2003025577">Request</button>
- <div id="-2003025577" class="collapse">
+ <button data-toggle="collapse" data-target="#1601881923">Request</button>
+ <div id="1601881923" class="collapse">
<pre>
<code>
{} </code>
@@ -1492,12 +1808,33 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#736007659">Response</button>
- <div id="736007659" class="collapse">
+ <button data-toggle="collapse" data-target="#971862112">Response</button>
+ <div id="971862112" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:handler:async:TriggerResponse",
+ "properties" : {
+ "triggerId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:TriggerId",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1508,7 +1845,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/metrics</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/rescaling/:triggerid</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1524,57 +1861,109 @@
<td colspan="2">
<ul>
<li><code>jobid</code> - description</li>
-<li><code>vertexid</code> - description</li>
+<li><code>triggerid</code> - description</li>
</ul>
</td>
</tr>
<tr>
- <td colspan="2">Query parameters</td>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#1396498187">Request</button>
+ <div id="1396498187" class="collapse">
+ <pre>
+ <code>
+{} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#-436584949">Response</button>
+ <div id="-436584949" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "any"
+} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ </tbody>
+</table>
+<table class="table table-bordered">
+ <tbody>
+ <tr>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/savepoints</strong></td>
+ </tr>
+ <tr>
+ <td class="text-left" style="width: 20%">Verb: <code>POST</code></td>
+ <td class="text-left">Response code: <code>202 Accepted</code></td>
+ </tr>
+ <tr>
+ <td colspan="2">description</td>
+ </tr>
+ <tr>
+ <td colspan="2">Path parameters</td>
</tr>
<tr>
<td colspan="2">
<ul>
-<li><code>get</code> (optional): description</li>
+<li><code>jobid</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#197623875">Request</button>
- <div id="197623875" class="collapse">
+ <button data-toggle="collapse" data-target="#256459122">Request</button>
+ <div id="256459122" class="collapse">
<pre>
<code>
-{} </code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:savepoints:SavepointTriggerRequestBody",
+ "properties" : {
+ "targetDirectory" : {
+ "type" : "string"
+ },
+ "cancelJob" : {
+ "type" : "boolean"
+ }
+ }
+} </code>
</pre>
</div>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#508352236">Response</button>
- <div id="508352236" class="collapse">
+ <button data-toggle="collapse" data-target="#-591687676">Response</button>
+ <div id="-591687676" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
- "properties" : {
- "metrics" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
- "properties" : {
- "id" : {
- "type" : "string"
- },
- "value" : {
- "type" : "string"
- }
- }
- }
- }
- }
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:handler:async:TriggerResponse",
+ "properties" : {
+ "triggerId" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:TriggerId",
+ "properties" : {
+ "upperPart" : {
+ "type" : "integer"
+ },
+ "lowerPart" : {
+ "type" : "integer"
+ },
+ "bytes" : {
+ "type" : "array",
+ "items" : {
+ "type" : "integer"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1585,7 +1974,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/savepoints/:triggerid</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1601,25 +1990,63 @@
<td colspan="2">
<ul>
<li><code>jobid</code> - description</li>
-<li><code>vertexid</code> - description</li>
-<li><code>subtaskindex</code> - description</li>
+<li><code>triggerid</code> - description</li>
</ul>
</td>
</tr>
<tr>
- <td colspan="2">Query parameters</td>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#-679507407">Request</button>
+ <div id="-679507407" class="collapse">
+ <pre>
+ <code>
+{} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <button data-toggle="collapse" data-target="#1782376753">Response</button>
+ <div id="1782376753" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "any"
+} </code>
+ </pre>
+ </div>
+ </td>
+ </tr>
+ </tbody>
+</table>
+<table class="table table-bordered">
+ <tbody>
+ <tr>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid</strong></td>
+ </tr>
+ <tr>
+ <td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
+ <td class="text-left">Response code: <code>200 OK</code></td>
+ </tr>
+ <tr>
+ <td colspan="2">description</td>
+ </tr>
+ <tr>
+ <td colspan="2">Path parameters</td>
</tr>
<tr>
<td colspan="2">
<ul>
-<li><code>get</code> (optional): description</li>
+<li><code>jobid</code> - description</li>
+<li><code>vertexid</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-570514556">Request</button>
- <div id="-570514556" class="collapse">
+ <button data-toggle="collapse" data-target="#155996506">Request</button>
+ <div id="155996506" class="collapse">
<pre>
<code>
{} </code>
@@ -1629,30 +2056,12 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-259786195">Response</button>
- <div id="-259786195" class="collapse">
+ <button data-toggle="collapse" data-target="#-1181366619">Response</button>
+ <div id="-1181366619" class="collapse">
<pre>
<code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
- "properties" : {
- "metrics" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
- "properties" : {
- "id" : {
- "type" : "string"
- },
- "value" : {
- "type" : "string"
- }
- }
- }
- }
- }
+{
+ "type" : "any"
} </code>
</pre>
</div>
@@ -1663,7 +2072,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/subtasktimes</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/accumulators</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1685,8 +2094,8 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1181229237">Request</button>
- <div id="-1181229237" class="collapse">
+ <button data-toggle="collapse" data-target="#1002866210">Request</button>
+ <div id="1002866210" class="collapse">
<pre>
<code>
{} </code>
@@ -1696,12 +2105,12 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#2091701353">Response</button>
- <div id="2091701353" class="collapse">
+ <button data-toggle="collapse" data-target="#-553067850">Response</button>
+ <div id="-553067850" class="collapse">
<pre>
<code>
-{
- "type" : "any"
+{
+ "type" : "any"
} </code>
</pre>
</div>
@@ -1712,7 +2121,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/overview</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/backpressure</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1722,9 +2131,20 @@
<td colspan="2">description</td>
</tr>
<tr>
+ <td colspan="2">Path parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>jobid</code> - description</li>
+<li><code>vertexid</code> - description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1581342131">Request</button>
- <div id="-1581342131" class="collapse">
+ <button data-toggle="collapse" data-target="#-587292255">Request</button>
+ <div id="-587292255" class="collapse">
<pre>
<code>
{} </code>
@@ -1734,42 +2154,45 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1331669657">Response</button>
- <div id="-1331669657" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:handler:legacy:messages:ClusterOverviewWithVersion",
- "properties" : {
- "numJobsRunningOrPending" : {
- "type" : "integer"
- },
- "numJobsFinished" : {
- "type" : "integer"
- },
- "numJobsCancelled" : {
- "type" : "integer"
- },
- "numJobsFailed" : {
- "type" : "integer"
- },
- "numTaskManagersConnected" : {
- "type" : "integer"
- },
- "numSlotsTotal" : {
- "type" : "integer"
- },
- "numSlotsAvailable" : {
- "type" : "integer"
- },
- "version" : {
- "type" : "string"
- },
- "commitId" : {
- "type" : "string"
- }
- }
+ <button data-toggle="collapse" data-target="#1388088916">Response</button>
+ <div id="1388088916" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobVertexBackPressureInfo",
+ "properties" : {
+ "status" : {
+ "type" : "string",
+ "enum" : [ "DEPRECATED", "OK" ]
+ },
+ "backpressureLevel" : {
+ "type" : "string",
+ "enum" : [ "OK", "LOW", "HIGH" ]
+ },
+ "endTimestamp" : {
+ "type" : "integer"
+ },
+ "subtasks" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:JobVertexBackPressureInfo:SubtaskBackPressureInfo",
+ "properties" : {
+ "subtask" : {
+ "type" : "integer"
+ },
+ "backpressureLevel" : {
+ "type" : "string",
+ "enum" : [ "OK", "LOW", "HIGH" ]
+ },
+ "ratio" : {
+ "type" : "number"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1780,7 +2203,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/taskmanagers</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/metrics</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1790,9 +2213,30 @@
<td colspan="2">description</td>
</tr>
<tr>
+ <td colspan="2">Path parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>jobid</code> - description</li>
+<li><code>vertexid</code> - description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
+ <td colspan="2">Query parameters</td>
+ </tr>
+ <tr>
+ <td colspan="2">
+ <ul>
+<li><code>get</code> (optional): description</li>
+ </ul>
+ </td>
+ </tr>
+ <tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1212462017">Request</button>
- <div id="-1212462017" class="collapse">
+ <button data-toggle="collapse" data-target="#-1091451634">Request</button>
+ <div id="-1091451634" class="collapse">
<pre>
<code>
{} </code>
@@ -1802,70 +2246,30 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#1694259450">Response</button>
- <div id="1694259450" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:taskmanager:TaskManagersInfo",
- "properties" : {
- "taskManagerInfos" : {
- "type" : "array",
- "items" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:taskmanager:TaskManagerInfo",
- "properties" : {
- "resourceId" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:clusterframework:types:ResourceID",
- "properties" : {
- "resourceIdString" : {
- "type" : "string"
- },
- "resourceID" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:clusterframework:types:ResourceID"
- }
- }
- },
- "address" : {
- "type" : "string"
- },
- "dataPort" : {
- "type" : "integer"
- },
- "lastHeartbeat" : {
- "type" : "integer"
- },
- "numberSlots" : {
- "type" : "integer"
- },
- "numberAvailableSlots" : {
- "type" : "integer"
- },
- "hardwareDescription" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:instance:HardwareDescription",
- "properties" : {
- "numberOfCPUCores" : {
- "type" : "integer"
- },
- "sizeOfPhysicalMemory" : {
- "type" : "integer"
- },
- "sizeOfJvmHeap" : {
- "type" : "integer"
- },
- "sizeOfManagedMemory" : {
- "type" : "integer"
- }
- }
- }
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#-780723273">Response</button>
+ <div id="-780723273" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:MetricCollectionResponseBody",
+ "properties" : {
+ "metrics" : {
+ "type" : "array",
+ "items" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:Metric",
+ "properties" : {
+ "id" : {
+ "type" : "string"
+ },
+ "value" : {
+ "type" : "string"
+ }
+ }
+ }
+ }
+ }
} </code>
</pre>
</div>
@@ -1876,7 +2280,7 @@
<table class="table table-bordered">
<tbody>
<tr>
- <td class="text-left" colspan="2"><strong>/taskmanagers/:taskmanagerid</strong></td>
+ <td class="text-left" colspan="2"><strong>/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex</strong></td>
</tr>
<tr>
<td class="text-left" style="width: 20%">Verb: <code>GET</code></td>
@@ -1891,14 +2295,16 @@
<tr>
<td colspan="2">
<ul>
-<li><code>taskmanagerid</code> - description</li>
+<li><code>jobid</code> - description</li>
+<li><code>vertexid</code> - description</li>
+<li><code>subtaskindex</code> - description</li>
</ul>
</td>
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1209460381">Request</button>
- <div id="-1209460381" class="collapse">
+ <button data-toggle="collapse" data-target="#-1504229989">Request</button>
+ <div id="-1504229989" class="collapse">
<pre>
<code>
{} </code>
@@ -1908,61 +2314,661 @@
</tr>
<tr>
<td colspan="2">
- <button data-toggle="collapse" data-target="#-1726867379">Response</button>
- <div id="-1726867379" class="collapse">
- <pre>
- <code>
-{
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:taskmanager:TaskManagerDetailsInfo",
- "properties" : {
- "resourceId" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:clusterframework:types:ResourceID",
- "properties" : {
- "resourceIdString" : {
- "type" : "string"
- },
- "resourceID" : {
- "type" : "object",
- "$ref" : "urn:jsonschema:org:apache:flink:runtime:clusterframework:types:ResourceID"
- }
- }
- },
- "address" : {
- "type" : "string"
- },
- "dataPort" : {
- "type" : "integer"
- },
- "lastHeartbeat" : {
- "type" : "integer"
- },
- "numberSlots" : {
- "type" : "integer"
- },
- "numberAvailableSlots" : {
- "type" : "integer"
- },
- "hardwareDescription" : {
- "type" : "object",
- "id" : "urn:jsonschema:org:apache:flink:runtime:instance:HardwareDescription",
- "properties" : {
- "numberOfCPUCores" : {
- "type" : "integer"
- },
- "sizeOfPhysicalMemory" : {
- "type" : "integer"
- },
- "sizeOfJvmHeap" : {
- "type" : "integer"
- },
- "sizeOfManagedMemory" : {
- "type" : "integer"
- }
- }
- }
- }
+ <button data-toggle="collapse" data-target="#772003294">Response</button>
+ <div id="772003294" class="collapse">
+ <pre>
+ <code>
+{
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",
+ "properties" : {
+ "subtaskIndex" : {
+ "type" : "integer"
+ },
+ "status" : {
+ "type" : "string",
+ "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING", "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
+ },
+ "attempt" : {
+ "type" : "integer"
+ },
+ "host" : {
+ "type" : "string"
+ },
+ "startTime" : {
+ "type" : "integer"
+ },
+ "endTime" : {
+ "type" : "integer"
+ },
+ "duration" : {
+ "type" : "integer"
+ },
+ "ioMetricsInfo" : {
+ "type" : "object",
+ "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
+ "properties" : {
+ "bytesRead" : {
+ "type" : "integer"
+ },
+ "bytesReadComplete" : {
+ "type" : "boolean"
+ },
+ "bytesWritten" : {
+ "type" : "integer"
+ },
+ "bytesWrittenComplete" : {
+ "type" : "boolean"
+ },
+ "recordsRead" : {
+ "type" : "integer"
+ },
+ "recordsReadComplet
<TRUNCATED>