[flink] branch FLINK-19426-ci-loop created (now 5d509e9)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch FLINK-19426-ci-loop in repository https://gitbox.apache.org/repos/asf/flink.git. at 5d509e9 loop test No new revisions were added by this update.
[flink] 01/01: loop test
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a commit to branch FLINK-19426-ci-loop in repository https://gitbox.apache.org/repos/asf/flink.git commit 5d509e9dadc7878ac6002edb07191e85240b07eb Author: Andrey Zagrebin AuthorDate: Tue Sep 29 14:15:41 2020 +0200 loop test --- flink-end-to-end-tests/run-nightly-tests.sh | 157 +--- flink-end-to-end-tests/run-single-test.sh | 1 + tools/azure-pipelines/jobs-template.yml | 142 - 3 files changed, 5 insertions(+), 295 deletions(-) diff --git a/flink-end-to-end-tests/run-nightly-tests.sh b/flink-end-to-end-tests/run-nightly-tests.sh index 670d149..ed97b23 100755 --- a/flink-end-to-end-tests/run-nightly-tests.sh +++ b/flink-end-to-end-tests/run-nightly-tests.sh @@ -79,159 +79,10 @@ printf "\n\n printf "Running bash end-to-end tests\n" printf "==\n" - -# Checkpointing tests - - -run_test "Resuming Savepoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file true" -run_test "Resuming Savepoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file false" -run_test "Resuming Savepoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file true" -run_test "Resuming Savepoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file false" -run_test "Resuming Savepoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file true" -run_test "Resuming Savepoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file false" -run_test "Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false heap" -run_test "Resuming Savepoint (rocks, scale up, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false heap" -run_test "Resuming Savepoint (rocks, scale down, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false heap" -run_test "Resuming Savepoint (rocks, no parallelism change, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false rocks" - -run_test "Resuming Externalized Checkpoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true false" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 rocks true false"
[flink] branch FLINK-19426-ci-loop created (now 5d509e9)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch FLINK-19426-ci-loop in repository https://gitbox.apache.org/repos/asf/flink.git. at 5d509e9 loop test This branch includes the following new commits: new 5d509e9 loop test The 1 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.
[flink] 01/01: loop test
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a commit to branch FLINK-19426-ci-loop in repository https://gitbox.apache.org/repos/asf/flink.git commit 5d509e9dadc7878ac6002edb07191e85240b07eb Author: Andrey Zagrebin AuthorDate: Tue Sep 29 14:15:41 2020 +0200 loop test --- flink-end-to-end-tests/run-nightly-tests.sh | 157 +--- flink-end-to-end-tests/run-single-test.sh | 1 + tools/azure-pipelines/jobs-template.yml | 142 - 3 files changed, 5 insertions(+), 295 deletions(-) diff --git a/flink-end-to-end-tests/run-nightly-tests.sh b/flink-end-to-end-tests/run-nightly-tests.sh index 670d149..ed97b23 100755 --- a/flink-end-to-end-tests/run-nightly-tests.sh +++ b/flink-end-to-end-tests/run-nightly-tests.sh @@ -79,159 +79,10 @@ printf "\n\n printf "Running bash end-to-end tests\n" printf "==\n" - -# Checkpointing tests - - -run_test "Resuming Savepoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file true" -run_test "Resuming Savepoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file false" -run_test "Resuming Savepoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file true" -run_test "Resuming Savepoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file false" -run_test "Resuming Savepoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file true" -run_test "Resuming Savepoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file false" -run_test "Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false heap" -run_test "Resuming Savepoint (rocks, scale up, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false heap" -run_test "Resuming Savepoint (rocks, scale down, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false heap" -run_test "Resuming Savepoint (rocks, no parallelism change, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false rocks" - -run_test "Resuming Externalized Checkpoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true false" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 rocks true false"
[flink] branch FLINK-19426-ci-loop created (now 5d509e9)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch FLINK-19426-ci-loop in repository https://gitbox.apache.org/repos/asf/flink.git. at 5d509e9 loop test This branch includes the following new commits: new 5d509e9 loop test The 1 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.
[flink] 02/02: loop test
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a commit to branch FLINK-19426-ci-loop-no-fix in repository https://gitbox.apache.org/repos/asf/flink.git commit acbbcd73cb46b2543477d9e5a3d22e7b027cf821 Author: Andrey Zagrebin AuthorDate: Tue Sep 29 14:15:41 2020 +0200 loop test --- flink-end-to-end-tests/run-nightly-tests.sh | 157 +--- flink-end-to-end-tests/run-single-test.sh | 1 + tools/azure-pipelines/jobs-template.yml | 142 - 3 files changed, 5 insertions(+), 295 deletions(-) diff --git a/flink-end-to-end-tests/run-nightly-tests.sh b/flink-end-to-end-tests/run-nightly-tests.sh index 670d149..ed97b23 100755 --- a/flink-end-to-end-tests/run-nightly-tests.sh +++ b/flink-end-to-end-tests/run-nightly-tests.sh @@ -79,159 +79,10 @@ printf "\n\n printf "Running bash end-to-end tests\n" printf "==\n" - -# Checkpointing tests - - -run_test "Resuming Savepoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file true" -run_test "Resuming Savepoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file false" -run_test "Resuming Savepoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file true" -run_test "Resuming Savepoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file false" -run_test "Resuming Savepoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file true" -run_test "Resuming Savepoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file false" -run_test "Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false heap" -run_test "Resuming Savepoint (rocks, scale up, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false heap" -run_test "Resuming Savepoint (rocks, scale down, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false heap" -run_test "Resuming Savepoint (rocks, no parallelism change, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false rocks" - -run_test "Resuming Externalized Checkpoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true false" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 rocks true false"
[flink] 01/02: [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388
This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a commit to branch FLINK-19426-ci-loop-no-fix
in repository https://gitbox.apache.org/repos/asf/flink.git
commit bcb32073b46964f66117541aa11876aeefa7d9ae
Author: Andrey Zagrebin
AuthorDate: Wed Sep 30 15:56:37 2020 +0200
[hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge
of FLINK-19388
---
.../runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
index a9c883c..aa8ecee 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
@@ -158,6 +158,7 @@ public class TaskManagerDetailsHandlerTest extends
TestLogger {
TASK_MANAGER_ID,
UUID.randomUUID().toString(),
0,
+ 0,
0L,
0,
0,
[flink] branch FLINK-19426-ci-loop-no-fix created (now acbbcd7)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch FLINK-19426-ci-loop-no-fix in repository https://gitbox.apache.org/repos/asf/flink.git. at acbbcd7 loop test This branch includes the following new commits: new bcb3207 [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388 new acbbcd7 loop 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.
[flink] branch FLINK-19426-ci-loop-no-fix created (now acbbcd7)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch FLINK-19426-ci-loop-no-fix in repository https://gitbox.apache.org/repos/asf/flink.git. at acbbcd7 loop test This branch includes the following new commits: new bcb3207 [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388 new acbbcd7 loop 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.
[flink] 02/02: loop test
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a commit to branch FLINK-19426-ci-loop-no-fix in repository https://gitbox.apache.org/repos/asf/flink.git commit acbbcd73cb46b2543477d9e5a3d22e7b027cf821 Author: Andrey Zagrebin AuthorDate: Tue Sep 29 14:15:41 2020 +0200 loop test --- flink-end-to-end-tests/run-nightly-tests.sh | 157 +--- flink-end-to-end-tests/run-single-test.sh | 1 + tools/azure-pipelines/jobs-template.yml | 142 - 3 files changed, 5 insertions(+), 295 deletions(-) diff --git a/flink-end-to-end-tests/run-nightly-tests.sh b/flink-end-to-end-tests/run-nightly-tests.sh index 670d149..ed97b23 100755 --- a/flink-end-to-end-tests/run-nightly-tests.sh +++ b/flink-end-to-end-tests/run-nightly-tests.sh @@ -79,159 +79,10 @@ printf "\n\n printf "Running bash end-to-end tests\n" printf "==\n" - -# Checkpointing tests - - -run_test "Resuming Savepoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file true" -run_test "Resuming Savepoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 file false" -run_test "Resuming Savepoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file true" -run_test "Resuming Savepoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file false" -run_test "Resuming Savepoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file true" -run_test "Resuming Savepoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file false" -run_test "Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false heap" -run_test "Resuming Savepoint (rocks, scale up, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false heap" -run_test "Resuming Savepoint (rocks, scale down, heap timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false heap" -run_test "Resuming Savepoint (rocks, no parallelism change, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false rocks" -run_test "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false rocks" - -run_test "Resuming Externalized Checkpoint (file, async, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, async, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (file, sync, scale down) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 4 2 file false true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true false" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 rocks true true" "skip_check_exceptions" -run_test "Resuming Externalized Checkpoint (rocks, non-incremental, scale up) end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 4 rocks true false"
[flink] 01/02: [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388
This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a commit to branch FLINK-19426-ci-loop-no-fix
in repository https://gitbox.apache.org/repos/asf/flink.git
commit bcb32073b46964f66117541aa11876aeefa7d9ae
Author: Andrey Zagrebin
AuthorDate: Wed Sep 30 15:56:37 2020 +0200
[hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge
of FLINK-19388
---
.../runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
index a9c883c..aa8ecee 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
@@ -158,6 +158,7 @@ public class TaskManagerDetailsHandlerTest extends
TestLogger {
TASK_MANAGER_ID,
UUID.randomUUID().toString(),
0,
+ 0,
0L,
0,
0,
[flink-statefun] branch release-2.2 updated: [docs] Add Haskell SDK to 3rd party SDKs
This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/release-2.2 by this push: new 0fc1c38 [docs] Add Haskell SDK to 3rd party SDKs 0fc1c38 is described below commit 0fc1c38b178dc2a6031790b43227d7d0809fc301 Author: Timothy Bess AuthorDate: Mon Sep 21 22:43:14 2020 -0400 [docs] Add Haskell SDK to 3rd party SDKs This closes #161. --- docs/sdk/external.md | 7 +++ 1 file changed, 7 insertions(+) diff --git a/docs/sdk/external.md b/docs/sdk/external.md index 66df5f5..0f1f048 100644 --- a/docs/sdk/external.md +++ b/docs/sdk/external.md @@ -42,3 +42,10 @@ None of these SDKs are managed by the Flink PMC and the normal rules of open sou - Maintainer: [Aljoscha Krettek](https://github.com/aljoscha) - Artifact: [crates.io](https://crates.io/crates/statefun) - License: [MIT License](https://github.com/aljoscha/statefun-rust/blob/main/LICENSE) + +## Haskell + +- Repository: [https://github.com/tdbgamer/flink-statefulfun-hs](https://github.com/tdbgamer/flink-statefulfun-hs) +- Maintainer: [Timothy Bess](https://github.com/tdbgamer) +- Artifact: [Hackage](https://hackage.haskell.org/package/flink-statefulfun-0.1.0.1) +- License: [MPL-2.0](https://github.com/tdbgamer/flink-statefulfun-hs/blob/master/LICENSE)
[flink-statefun] branch master updated: [docs] Add Haskell SDK to 3rd party SDKs
This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/master by this push: new 75b9dfe [docs] Add Haskell SDK to 3rd party SDKs 75b9dfe is described below commit 75b9dfec90c52d5cd41a97297ce1e768146fb745 Author: Timothy Bess AuthorDate: Mon Sep 21 22:43:14 2020 -0400 [docs] Add Haskell SDK to 3rd party SDKs This closes #161. --- docs/sdk/external.md | 7 +++ 1 file changed, 7 insertions(+) diff --git a/docs/sdk/external.md b/docs/sdk/external.md index 66df5f5..0f1f048 100644 --- a/docs/sdk/external.md +++ b/docs/sdk/external.md @@ -42,3 +42,10 @@ None of these SDKs are managed by the Flink PMC and the normal rules of open sou - Maintainer: [Aljoscha Krettek](https://github.com/aljoscha) - Artifact: [crates.io](https://crates.io/crates/statefun) - License: [MIT License](https://github.com/aljoscha/statefun-rust/blob/main/LICENSE) + +## Haskell + +- Repository: [https://github.com/tdbgamer/flink-statefulfun-hs](https://github.com/tdbgamer/flink-statefulfun-hs) +- Maintainer: [Timothy Bess](https://github.com/tdbgamer) +- Artifact: [Hackage](https://hackage.haskell.org/package/flink-statefulfun-0.1.0.1) +- License: [MPL-2.0](https://github.com/tdbgamer/flink-statefulfun-hs/blob/master/LICENSE)
[flink-shaded] annotated tag release-12.0-rc1 updated (c02c448 -> 876ec60)
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to annotated tag release-12.0-rc1 in repository https://gitbox.apache.org/repos/asf/flink-shaded.git. *** WARNING: tag release-12.0-rc1 was modified! *** from c02c448 (commit) to 876ec60 (tag) tagging c02c44840c25499c3f8937f34cfaa0757c03299d (commit) replaces release-11.0 by Robert Metzger on Tue Sep 29 19:44:46 2020 +0200 - Log - release-12.0-rc1 -BEGIN PGP SIGNATURE- iQIzBAABCAAdFiEEQ84pm8MFr/i5EqqVGD9pRNmDkVkFAl9zco4ACgkQGD9pRNmD kVlOxhAAloBWr8mbEPoBUEu1mhc84W0neSSHgsUG6x6PeAAZtr+y8kJhXslQTUQS IABuaec8h6gBh49OxFGaEx2Ejf1KkGYbiob8mb0wqSn76YbxD74lV30zoLtxoLL5 9cvQfwvC/FAsuesQvEJn2EJPUCMIasYXxRI/EWxCt+tpeHo4vI+69ZW8+l54xKUP QwNdicd6hDhhOIlwo/CPmybvDtOe+f6s/gt4MmldGU7Y+fSdKOkQVlnzMjzIlCdh 2ynA0mFVH+8g7LM0hVVtYWV1tDBERvDY58QBwbQioUxNPGmYUB5rlsSPK8w6XYi4 VvYFNicFQgqsvEXc+kSgWgwVG6vs3OyE/H5Ch6LNmQ98/moXt/Y843OUqpExj6n1 R4UV5FMR9VcLzG5xBRaGiK6zVbKfhR4BYPxJNAcNnel7mZzb2UAgrkaVZ64KqhzH 8VvsQ25NmvmxwBRTZBUF0sg8OM6+9kOG9EU1UY2clWHBOEY6iMZoHw02rzzobaNV nremV38OOY83CSVE6XO6Gg+kfsEM+iThKMUwcS7GLN6k1rCixhAwTdST3Dk2FTlA zP4GV4V14WUs6uN/aPsHX1cBtvJOJdEw9Ku2sKOPadHf6QcB2/cxcuJCww64+0FN fuj0RlOdPZj14nNhWg2/+7kPneN9yP5cQ/7m4L7zhd8dnp8mbYY= =ExXo -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
[flink] branch master updated (2725167 -> 237b5e0)
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2725167 [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388 add 237b5e0 [FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option No new revisions were added by this update. Summary of changes: docs/dev/table/connectors/formats/csv.md| 4 ++-- docs/dev/table/connectors/formats/csv.zh.md | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-)
[flink] branch master updated (2725167 -> 237b5e0)
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2725167 [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388 add 237b5e0 [FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option No new revisions were added by this update. Summary of changes: docs/dev/table/connectors/formats/csv.md| 4 ++-- docs/dev/table/connectors/formats/csv.zh.md | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-)
[flink] branch master updated (2725167 -> 237b5e0)
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2725167 [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388 add 237b5e0 [FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option No new revisions were added by this update. Summary of changes: docs/dev/table/connectors/formats/csv.md| 4 ++-- docs/dev/table/connectors/formats/csv.zh.md | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-)
[flink] branch master updated: [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388
This is an automated email from the ASF dual-hosted git repository.
azagrebin 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 2725167 [hotfix] Fix TaskManagerDetailsHandlerTest compilation
failure after merge of FLINK-19388
2725167 is described below
commit 2725167ca8900c34481ca6895ea2c52359fc42cc
Author: Andrey Zagrebin
AuthorDate: Wed Sep 30 15:56:37 2020 +0200
[hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge
of FLINK-19388
---
.../runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
index a9c883c..aa8ecee 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
@@ -158,6 +158,7 @@ public class TaskManagerDetailsHandlerTest extends
TestLogger {
TASK_MANAGER_ID,
UUID.randomUUID().toString(),
0,
+ 0,
0L,
0,
0,
[flink] branch master updated: [hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge of FLINK-19388
This is an automated email from the ASF dual-hosted git repository.
azagrebin 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 2725167 [hotfix] Fix TaskManagerDetailsHandlerTest compilation
failure after merge of FLINK-19388
2725167 is described below
commit 2725167ca8900c34481ca6895ea2c52359fc42cc
Author: Andrey Zagrebin
AuthorDate: Wed Sep 30 15:56:37 2020 +0200
[hotfix] Fix TaskManagerDetailsHandlerTest compilation failure after merge
of FLINK-19388
---
.../runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
index a9c883c..aa8ecee 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
@@ -158,6 +158,7 @@ public class TaskManagerDetailsHandlerTest extends
TestLogger {
TASK_MANAGER_ID,
UUID.randomUUID().toString(),
0,
+ 0,
0L,
0,
0,
[flink-statefun] branch release-2.2 updated: [revert][hotfix][docs] Update stable url
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/release-2.2 by this push: new cdb67a7 [revert][hotfix][docs] Update stable url cdb67a7 is described below commit cdb67a7e03b67de8e26ff06aa56da8a5e3c7295c Author: Seth Wiesman AuthorDate: Wed Sep 30 08:40:28 2020 -0500 [revert][hotfix][docs] Update stable url --- docs/_config.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/_config.yml b/docs/_config.yml index f8ba939..7432809 100644 --- a/docs/_config.yml +++ b/docs/_config.yml @@ -54,7 +54,7 @@ download_url: "https://flink.apache.org/downloads.html; # please use a protocol relative URL here baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2 -stable_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-stable +stable_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2 javadocs_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/
[flink-statefun] branch release-2.2 updated: [hotfix][docs] Update stable url
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/release-2.2 by this push: new d8261a2 [hotfix][docs] Update stable url d8261a2 is described below commit d8261a27a9101cac3d8daf747955c26eaa3a79e5 Author: Seth Wiesman AuthorDate: Wed Sep 30 08:35:18 2020 -0500 [hotfix][docs] Update stable url --- docs/_config.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/_config.yml b/docs/_config.yml index 7432809..f8ba939 100644 --- a/docs/_config.yml +++ b/docs/_config.yml @@ -54,7 +54,7 @@ download_url: "https://flink.apache.org/downloads.html; # please use a protocol relative URL here baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2 -stable_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2 +stable_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-stable javadocs_baseurl: //ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/
[flink] branch master updated (a25c01a -> 8d50daa)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a25c01a [FLINK-14422][runtime] Extended REST API to also include network memory usage. add 8d50daa [FLINK-19388][coordination] Do not remove logical slots from SharedSlot if it is releasing No new revisions were added by this update. Summary of changes: .../apache/flink/runtime/scheduler/SharedSlot.java | 21 + .../flink/runtime/scheduler/SharedSlotTest.java| 27 +- 2 files changed, 43 insertions(+), 5 deletions(-)
[flink] branch master updated: [FLINK-19388][coordination] Do not remove logical slots from SharedSlot if it is releasing
This is an automated email from the ASF dual-hosted git repository.
azagrebin 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 8d50daa [FLINK-19388][coordination] Do not remove logical slots from
SharedSlot if it is releasing
8d50daa is described below
commit 8d50daa7e13e00cffbd09efac73e6bea0e48ee5c
Author: Andrey Zagrebin
AuthorDate: Tue Sep 29 14:09:29 2020 +0200
[FLINK-19388][coordination] Do not remove logical slots from SharedSlot if
it is releasing
`SharedSlot#release` releases all logical slots in a loop over their
collection.
The logical slot releases lead to their execution failures.
This can cause cancellation of other executions sharing same slot.
The execution failure can cause cancelation of other sharing executions by
`Scheduler`.
The canceled executions subsequently call `SharedSlot#returnLogicalSlot`
which modifies the logical slot collection while it is being iterated in
`SharedSlot#release`,
if the canceled executions share the same slot. This leads to
`ConcurrentModificationException`.
To avoid the `ConcurrentModificationException`, the logical slot collection
can be copied before iterating it.
This closes #13511.
---
.../apache/flink/runtime/scheduler/SharedSlot.java | 21 +
.../flink/runtime/scheduler/SharedSlotTest.java| 27 +-
2 files changed, 43 insertions(+), 5 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java
index 1d55bbd..1525060 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java
@@ -35,9 +35,11 @@ import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
+import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.function.Consumer;
import java.util.function.Function;
+import java.util.stream.Collectors;
/**
* Shared slot implementation for the {@link
SlotSharingExecutionSlotAllocator}.
@@ -203,6 +205,7 @@ class SharedSlot implements SlotOwner, PhysicalSlot.Payload
{
}
private void removeLogicalSlotRequest(SlotRequestId
logicalSlotRequestId) {
+ LOG.debug("Remove {}",
getLogicalSlotString(logicalSlotRequestId));
Preconditions.checkState(
requestedLogicalSlots.removeKeyB(logicalSlotRequestId)
!= null,
"Trying to remove a logical slot request which has been
either already removed or never created.");
@@ -215,10 +218,19 @@ class SharedSlot implements SlotOwner,
PhysicalSlot.Payload {
slotContextFuture.isDone(),
"Releasing of the shared slot is expected only from its
successfully allocated physical slot ({})",
physicalSlotRequestId);
- for (ExecutionVertexID executionVertexId :
requestedLogicalSlots.keySetA()) {
- LOG.debug("Release {}",
getLogicalSlotString(executionVertexId));
+ LOG.debug("Release shared slot ({})", physicalSlotRequestId);
+
+ // copy the logical slot collection to avoid
ConcurrentModificationException
+ // if logical slot releases cause cancellation of other
executions
+ // which will try to call returnLogicalSlot and modify
requestedLogicalSlots collection
+ Map>
logicalSlotFutures = requestedLogicalSlots
+ .keySetA()
+ .stream()
+ .collect(Collectors.toMap(executionVertexId ->
executionVertexId, requestedLogicalSlots::getValueByKeyA));
+ for (Map.Entry> entry : logicalSlotFutures.entrySet()) {
+ LOG.debug("Release {}",
getLogicalSlotString(entry.getKey()));
CompletableFuture logicalSlotFuture =
-
requestedLogicalSlots.getValueByKeyA(executionVertexId);
+ entry.getValue();
Preconditions.checkNotNull(logicalSlotFuture);
Preconditions.checkState(
logicalSlotFuture.isDone(),
@@ -231,8 +243,9 @@ class SharedSlot implements SlotOwner, PhysicalSlot.Payload
{
}
private void releaseExternally() {
- if (state == State.ALLOCATED &&
requestedLogicalSlots.values().isEmpty()) {
+ if (state != State.RELEASED &&
requestedLogicalSlots.values().isEmpty()) {
state = State.RELEASED;
+ LOG.debug("Release shared slot externally ({})",
physicalSlotRequestId);
[flink-statefun] branch master updated: [hotfix][docs] Add 2.2 to previous docs list
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/master by this push: new 4fe04ea [hotfix][docs] Add 2.2 to previous docs list 4fe04ea is described below commit 4fe04ea351145f989e144f160425424987050f68 Author: Seth Wiesman AuthorDate: Wed Sep 30 08:26:27 2020 -0500 [hotfix][docs] Add 2.2 to previous docs list --- docs/_config.yml | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/_config.yml b/docs/_config.yml index f2acda8..b1f7a37 100644 --- a/docs/_config.yml +++ b/docs/_config.yml @@ -67,6 +67,7 @@ show_outdated_warning: false previous_docs: 2.0: https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.0 2.1: https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1 + 2.2: https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2 #-- # BUILD CONFIG
[flink] branch master updated (cacfd98 -> a25c01a)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) add 1e41c73 [FLINK-14422][runtime] Added memory-related getter methods. add cb0386f [FLINK-14422][runtime] Added metrics for total memory, available memory, used memory and number of used memory segments. add a25c01a [FLINK-14422][runtime] Extended REST API to also include network memory usage. No new revisions were added by this update. Summary of changes: docs/_includes/generated/rest_v1_dispatcher.html | 20 +- docs/monitoring/metrics.md | 24 ++- docs/monitoring/metrics.zh.md | 24 ++- .../src/test/resources/rest_api_v1.snapshot| 18 ++ .../io/network/buffer/NetworkBufferPool.java | 18 +- .../network/metrics/NettyShuffleMetricFactory.java | 46 - .../taskmanager/TaskManagerDetailsHandler.java | 17 +- .../taskmanager/TaskManagerDetailsHeaders.java | 2 +- .../taskmanager/TaskManagerDetailsInfo.java| 8 +- .../taskmanager/TaskManagerMetricsInfo.java| 127 +++-- .../io/network/buffer/NetworkBufferPoolTest.java | 59 +- .../utils/TestingResourceManagerGateway.java | 14 +- .../taskmanager/TaskManagerDetailsHandlerTest.java | 211 + .../taskmanager/TaskManagerDetailsInfoTest.java| 4 + 14 files changed, 554 insertions(+), 38 deletions(-) create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
[flink] branch master updated (cacfd98 -> a25c01a)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) add 1e41c73 [FLINK-14422][runtime] Added memory-related getter methods. add cb0386f [FLINK-14422][runtime] Added metrics for total memory, available memory, used memory and number of used memory segments. add a25c01a [FLINK-14422][runtime] Extended REST API to also include network memory usage. No new revisions were added by this update. Summary of changes: docs/_includes/generated/rest_v1_dispatcher.html | 20 +- docs/monitoring/metrics.md | 24 ++- docs/monitoring/metrics.zh.md | 24 ++- .../src/test/resources/rest_api_v1.snapshot| 18 ++ .../io/network/buffer/NetworkBufferPool.java | 18 +- .../network/metrics/NettyShuffleMetricFactory.java | 46 - .../taskmanager/TaskManagerDetailsHandler.java | 17 +- .../taskmanager/TaskManagerDetailsHeaders.java | 2 +- .../taskmanager/TaskManagerDetailsInfo.java| 8 +- .../taskmanager/TaskManagerMetricsInfo.java| 127 +++-- .../io/network/buffer/NetworkBufferPoolTest.java | 59 +- .../utils/TestingResourceManagerGateway.java | 14 +- .../taskmanager/TaskManagerDetailsHandlerTest.java | 211 + .../taskmanager/TaskManagerDetailsInfoTest.java| 4 + 14 files changed, 554 insertions(+), 38 deletions(-) create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
[flink] branch master updated (cacfd98 -> a25c01a)
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) add 1e41c73 [FLINK-14422][runtime] Added memory-related getter methods. add cb0386f [FLINK-14422][runtime] Added metrics for total memory, available memory, used memory and number of used memory segments. add a25c01a [FLINK-14422][runtime] Extended REST API to also include network memory usage. No new revisions were added by this update. Summary of changes: docs/_includes/generated/rest_v1_dispatcher.html | 20 +- docs/monitoring/metrics.md | 24 ++- docs/monitoring/metrics.zh.md | 24 ++- .../src/test/resources/rest_api_v1.snapshot| 18 ++ .../io/network/buffer/NetworkBufferPool.java | 18 +- .../network/metrics/NettyShuffleMetricFactory.java | 46 - .../taskmanager/TaskManagerDetailsHandler.java | 17 +- .../taskmanager/TaskManagerDetailsHeaders.java | 2 +- .../taskmanager/TaskManagerDetailsInfo.java| 8 +- .../taskmanager/TaskManagerMetricsInfo.java| 127 +++-- .../io/network/buffer/NetworkBufferPoolTest.java | 59 +- .../utils/TestingResourceManagerGateway.java | 14 +- .../taskmanager/TaskManagerDetailsHandlerTest.java | 211 + .../taskmanager/TaskManagerDetailsInfoTest.java| 4 + 14 files changed, 554 insertions(+), 38 deletions(-) create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandlerTest.java
[flink] branch release0 created (now cacfd98)
This is an automated email from the ASF dual-hosted git repository. fhueske pushed a change to branch release0 in repository https://gitbox.apache.org/repos/asf/flink.git. at cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) No new revisions were added by this update.
[flink] branch release0 created (now cacfd98)
This is an automated email from the ASF dual-hosted git repository. fhueske pushed a change to branch release0 in repository https://gitbox.apache.org/repos/asf/flink.git. at cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) No new revisions were added by this update.
[flink] branch master updated (b4ae117 -> cacfd98)
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b4ae117 [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration (#13434) add cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) No new revisions were added by this update. Summary of changes: docs/dev/python/datastream_tutorial.zh.md | 55 --- 1 file changed, 28 insertions(+), 27 deletions(-)
[flink] branch master updated (b4ae117 -> cacfd98)
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b4ae117 [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration (#13434) add cacfd98 [FLINK-19430][docs-zh][python] Translate page datastream_tutorial into Chinese (#13498) No new revisions were added by this update. Summary of changes: docs/dev/python/datastream_tutorial.zh.md | 55 --- 1 file changed, 28 insertions(+), 27 deletions(-)
