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/09/03 08:12:47 UTC
[flink] branch master updated: [hotfix][conf] Remove references to
deprecated WebOptions
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 1c44ba2 [hotfix][conf] Remove references to deprecated WebOptions
1c44ba2 is described below
commit 1c44ba209469d29f8f9e7aab454c50c5b4ddbf8f
Author: maqingxiang <35...@users.noreply.github.com>
AuthorDate: Mon Sep 3 16:12:37 2018 +0800
[hotfix][conf] Remove references to deprecated WebOptions
---
docs/dev/execution_plans.md | 2 +-
docs/monitoring/back_pressure.md | 6 +++---
docs/monitoring/checkpoint_monitoring.md | 2 +-
docs/monitoring/rest_api.md | 2 +-
flink-dist/src/main/resources/flink-conf.yaml | 4 ++--
flink-jepsen/src/jepsen/flink/db.clj | 4 ++--
.../runtime/webmonitor/handlers/legacy/JarAccessDeniedHandler.java | 2 +-
7 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/docs/dev/execution_plans.md b/docs/dev/execution_plans.md
index 881c54e..29a3641 100644
--- a/docs/dev/execution_plans.md
+++ b/docs/dev/execution_plans.md
@@ -72,7 +72,7 @@ __Web Interface__
Flink offers a web interface for submitting and executing jobs. The interface is part of the JobManager's
web interface for monitoring, per default running on port 8081. Job submission via this interfaces requires
-that you have set `jobmanager.web.submit.enable: true` in `flink-conf.yaml`.
+that you have set `web.submit.enable: true` in `flink-conf.yaml`.
You may specify program arguments before the job is executed. The plan visualization enables you to show
the execution plan before executing the Flink job.
diff --git a/docs/monitoring/back_pressure.md b/docs/monitoring/back_pressure.md
index 28a4dd2..0cc4644 100644
--- a/docs/monitoring/back_pressure.md
+++ b/docs/monitoring/back_pressure.md
@@ -55,9 +55,9 @@ In order to not overload the task managers with stack trace samples, the web int
You can configure the number of samples for the job manager with the following configuration keys:
-- `jobmanager.web.backpressure.refresh-interval`: Time after which available stats are deprecated and need to be refreshed (DEFAULT: 60000, 1 min).
-- `jobmanager.web.backpressure.num-samples`: Number of stack trace samples to take to determine back pressure (DEFAULT: 100).
-- `jobmanager.web.backpressure.delay-between-samples`: Delay between stack trace samples to determine back pressure (DEFAULT: 50, 50 ms).
+- `web.backpressure.refresh-interval`: Time after which available stats are deprecated and need to be refreshed (DEFAULT: 60000, 1 min).
+- `web.backpressure.num-samples`: Number of stack trace samples to take to determine back pressure (DEFAULT: 100).
+- `web.backpressure.delay-between-samples`: Delay between stack trace samples to determine back pressure (DEFAULT: 50, 50 ms).
## Example
diff --git a/docs/monitoring/checkpoint_monitoring.md b/docs/monitoring/checkpoint_monitoring.md
index 0a66ca5..f382504 100644
--- a/docs/monitoring/checkpoint_monitoring.md
+++ b/docs/monitoring/checkpoint_monitoring.md
@@ -70,7 +70,7 @@ You can configure the number of recent checkpoints that are remembered for the h
{% highlight yaml %}
# Number of recent checkpoints that are remembered
-jobmanager.web.checkpoints.history: 15
+web.checkpoints.history: 15
{% endhighlight %}
### Summary Tab
diff --git a/docs/monitoring/rest_api.md b/docs/monitoring/rest_api.md
index ec92051..eefc8b9 100644
--- a/docs/monitoring/rest_api.md
+++ b/docs/monitoring/rest_api.md
@@ -661,7 +661,7 @@ Content-Type: application/x-java-archive
#### Run a Program (POST)
-Send a `POST` request to `/jars/:jarid/run`. The `jarid` parameter is the file name of the program JAR in the configured web frontend upload directory (configuration key `jobmanager.web.upload.dir`).
+Send a `POST` request to `/jars/:jarid/run`. The `jarid` parameter is the file name of the program JAR in the configured web frontend upload directory (configuration key `web.upload.dir`).
You can specify the following query parameters (all optional):
diff --git a/flink-dist/src/main/resources/flink-conf.yaml b/flink-dist/src/main/resources/flink-conf.yaml
index f4ec6a7..efdf33e 100644
--- a/flink-dist/src/main/resources/flink-conf.yaml
+++ b/flink-dist/src/main/resources/flink-conf.yaml
@@ -126,7 +126,7 @@ parallelism.default: 1
# The address under which the web-based runtime monitor listens.
#
-#jobmanager.web.address: 0.0.0.0
+#web.address: 0.0.0.0
# The port under which the web-based runtime monitor listens.
# A value of -1 deactivates the web server.
@@ -136,7 +136,7 @@ rest.port: 8081
# Flag to specify whether job submission is enabled from the web-based
# runtime monitor. Uncomment to disable.
-#jobmanager.web.submit.enable: false
+#web.submit.enable: false
#==============================================================================
# Advanced
diff --git a/flink-jepsen/src/jepsen/flink/db.clj b/flink-jepsen/src/jepsen/flink/db.clj
index becc551..79ed8a4 100644
--- a/flink-jepsen/src/jepsen/flink/db.clj
+++ b/flink-jepsen/src/jepsen/flink/db.clj
@@ -51,7 +51,7 @@
:high-availability.zookeeper.quorum (zookeeper-quorum test)
:high-availability.storageDir (str (:ha-storage-dir test) "/ha")
:state.savepoints.dir (str (:ha-storage-dir test) "/savepoints")
- :web.port 8081
+ :rest.port 8081
:rest.bind-address "0.0.0.0"
:taskmanager.numberOfTaskSlots taskmanager-slots
:yarn.application-attempts 99999
@@ -219,7 +219,7 @@
"-Djobmanager.rpc.address=$(hostname -f) "
"-Djobmanager.heap.mb=2048 "
"-Djobmanager.rpc.port=6123 "
- "-Djobmanager.web.port=8081 "
+ "-rest.port=8081 "
"-Dmesos.resourcemanager.tasks.mem=2048 "
"-Dtaskmanager.heap.mb=2048 "
"-Dtaskmanager.numberOfTaskSlots=2 "
diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/legacy/JarAccessDeniedHandler.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/legacy/JarAccessDeniedHandler.java
index 1600a3b..631b097 100644
--- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/legacy/JarAccessDeniedHandler.java
+++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/legacy/JarAccessDeniedHandler.java
@@ -31,7 +31,7 @@ import java.util.concurrent.Executor;
public class JarAccessDeniedHandler extends AbstractJsonRequestHandler {
private static final String ERROR_MESSAGE = "{\"error\": \"Web submission interface is not " +
- "available for this cluster. To enable it, set the configuration key ' jobmanager.web.submit.enable.'\"}";
+ "available for this cluster. To enable it, set the configuration key ' web.submit.enable.'\"}";
public JarAccessDeniedHandler(Executor executor) {
super(executor);