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/11/09 06:24:03 UTC
[flink] branch release-1.7 updated (365e29d -> 8c3a939)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 365e29d [hotfix][tests] Remove hard-coded scala versions
new d608eef [hotfix][docs] Clarify unit for network.request-backoff
new 8c3a939 [FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/_includes/generated/task_manager_configuration.html | 4 ++--
.../main/java/org/apache/flink/configuration/TaskManagerOptions.java | 4 ++--
.../test-scripts/test_high_parallelism_iterations.sh | 1 +
3 files changed, 5 insertions(+), 4 deletions(-)
[flink] 01/02: [hotfix][docs] Clarify unit for
network.request-backoff
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d608eef43b5c79857f12e3203fd301e5d3006708
Author: zentol <ch...@apache.org>
AuthorDate: Thu Nov 8 15:11:20 2018 +0100
[hotfix][docs] Clarify unit for network.request-backoff
---
docs/_includes/generated/task_manager_configuration.html | 4 ++--
.../main/java/org/apache/flink/configuration/TaskManagerOptions.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/docs/_includes/generated/task_manager_configuration.html b/docs/_includes/generated/task_manager_configuration.html
index 16c5d98..63bfb04 100644
--- a/docs/_includes/generated/task_manager_configuration.html
+++ b/docs/_includes/generated/task_manager_configuration.html
@@ -125,12 +125,12 @@
<tr>
<td><h5>taskmanager.network.request-backoff.initial</h5></td>
<td style="word-wrap: break-word;">100</td>
- <td>Minimum backoff for partition requests of input channels.</td>
+ <td>Minimum backoff in milliseconds for partition requests of input channels.</td>
</tr>
<tr>
<td><h5>taskmanager.network.request-backoff.max</h5></td>
<td style="word-wrap: break-word;">10000</td>
- <td>Maximum backoff for partition requests of input channels.</td>
+ <td>Maximum backoff in milliseconds for partition requests of input channels.</td>
</tr>
<tr>
<td><h5>taskmanager.numberOfTaskSlots</h5></td>
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
index 98fa47f..6d3ac45 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
@@ -316,7 +316,7 @@ public class TaskManagerOptions {
key("taskmanager.network.request-backoff.initial")
.defaultValue(100)
.withDeprecatedKeys("taskmanager.net.request-backoff.initial")
- .withDescription("Minimum backoff for partition requests of input channels.");
+ .withDescription("Minimum backoff in milliseconds for partition requests of input channels.");
/**
* Maximum backoff for partition requests of input channels.
@@ -325,7 +325,7 @@ public class TaskManagerOptions {
key("taskmanager.network.request-backoff.max")
.defaultValue(10000)
.withDeprecatedKeys("taskmanager.net.request-backoff.max")
- .withDescription("Maximum backoff for partition requests of input channels.");
+ .withDescription("Maximum backoff in milliseconds for partition requests of input channels.");
/**
* Boolean flag to enable/disable more detailed metrics about inbound/outbound network queue
[flink] 02/02: [FLINK-10825][tests] Increase request-backoff for
high-parallelism e2e test
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8c3a93992618da0fdfe2c02abc5175609913c0cf
Author: zentol <ch...@apache.org>
AuthorDate: Thu Nov 8 15:13:36 2018 +0100
[FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test
---
flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh b/flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh
index 582b5a0..93668d8 100755
--- a/flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh
+++ b/flink-end-to-end-tests/test-scripts/test_high_parallelism_iterations.sh
@@ -34,6 +34,7 @@ set_conf "taskmanager.memory.segment-size" "8kb"
set_conf "taskmanager.network.netty.server.numThreads" "1"
set_conf "taskmanager.network.netty.client.numThreads" "1"
+set_conf "taskmanager.network.request-backoff.max" "60000"
set_conf "taskmanager.numberOfTaskSlots" "1"