[7/7] flink git commit: [FLINK-8910][e2e] Automated test for local recovery (including sticky allocation)
[FLINK-8910][e2e] Automated test for local recovery (including sticky
allocation)
This closes #5676.
(cherry picked from commit 489e428)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da5b6d7a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da5b6d7a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/da5b6d7a
Branch: refs/heads/release-1.5
Commit: da5b6d7adcccb2531b6678be9aa127ebb0c15be1
Parents: fbe3cbf
Author: Stefan Richter
Authored: Tue Mar 6 10:35:44 2018 +0100
Committer: Stefan Richter
Committed: Thu May 17 10:10:56 2018 +0200
--
.../pom.xml | 96
...StickyAllocationAndLocalRecoveryTestJob.java | 478 +++
.../src/main/resources/log4j-test.properties| 27 ++
flink-end-to-end-tests/pom.xml | 1 +
flink-end-to-end-tests/run-nightly-tests.sh | 8 +
flink-end-to-end-tests/test-scripts/common.sh | 43 +-
.../test_local_recovery_and_scheduling.sh | 121 +
.../TaskExecutorLocalStateStoresManager.java| 2 +-
.../api/operators/BackendRestorerProcedure.java | 2 +
9 files changed, 773 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/da5b6d7a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
--
diff --git
a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
new file mode 100644
index 000..8ba7ef5
--- /dev/null
+++ b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
@@ -0,0 +1,96 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+
+ flink-end-to-end-tests
+ org.apache.flink
+ 1.5-SNAPSHOT
+
+ 4.0.0
+
+ flink-local-recovery-and-allocation-test
+ flink-local-recovery-and-allocation-test
+
+ jar
+
+
+
+ org.apache.flink
+ flink-core
+ ${project.version}
+
+
+ org.apache.flink
+
flink-streaming-java_${scala.binary.version}
+ ${project.version}
+
+
+ org.apache.flink
+
flink-statebackend-rocksdb_${scala.binary.version}
+ ${project.version}
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ log4j
+ log4j
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-jar-plugin
+ 2.4
+
+
+
+
StickyAllocationAndLocalRecoveryTestJob
+ package
+
+ jar
+
+
+
StickyAllocationAndLocalRecoveryTestJob
+
+
+
+
org.apache.flink.streaming.tests.StickyAllocationAndLocalRecoveryTestJob
+
+
+
+
+
org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.class
+
org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob$*.class
+
+
+
+
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/flink/blob/da5b6d7a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org
[7/7] flink git commit: [FLINK-8910][e2e] Automated test for local recovery (including sticky allocation)
[FLINK-8910][e2e] Automated test for local recovery (including sticky
allocation)
This closes #5676.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/489e4281
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/489e4281
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/489e4281
Branch: refs/heads/master
Commit: 489e42811157a9b2575f259f7cda2a2ee680d008
Parents: edece9c
Author: Stefan Richter
Authored: Tue Mar 6 10:35:44 2018 +0100
Committer: Stefan Richter
Committed: Thu May 17 10:03:04 2018 +0200
--
.../pom.xml | 96
...StickyAllocationAndLocalRecoveryTestJob.java | 478 +++
.../src/main/resources/log4j-test.properties| 27 ++
flink-end-to-end-tests/pom.xml | 1 +
flink-end-to-end-tests/run-nightly-tests.sh | 8 +
flink-end-to-end-tests/test-scripts/common.sh | 43 +-
.../test_local_recovery_and_scheduling.sh | 121 +
.../TaskExecutorLocalStateStoresManager.java| 2 +-
.../api/operators/BackendRestorerProcedure.java | 2 +
9 files changed, 773 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/489e4281/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
--
diff --git
a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
new file mode 100644
index 000..4b966e2
--- /dev/null
+++ b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
@@ -0,0 +1,96 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+
+ flink-end-to-end-tests
+ org.apache.flink
+ 1.6-SNAPSHOT
+
+ 4.0.0
+
+ flink-local-recovery-and-allocation-test
+ flink-local-recovery-and-allocation-test
+
+ jar
+
+
+
+ org.apache.flink
+ flink-core
+ ${project.version}
+
+
+ org.apache.flink
+
flink-streaming-java_${scala.binary.version}
+ ${project.version}
+
+
+ org.apache.flink
+
flink-statebackend-rocksdb_${scala.binary.version}
+ ${project.version}
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ log4j
+ log4j
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-jar-plugin
+ 2.4
+
+
+
+
StickyAllocationAndLocalRecoveryTestJob
+ package
+
+ jar
+
+
+
StickyAllocationAndLocalRecoveryTestJob
+
+
+
+
org.apache.flink.streaming.tests.StickyAllocationAndLocalRecoveryTestJob
+
+
+
+
+
org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.class
+
org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob$*.class
+
+
+
+
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/flink/blob/489e4281/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org/apache/flink/streaming/tests/StickyAlloca
