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 2019/11/15 19:57:55 UTC
[flink] branch master updated (2b0a8ce -> 671029d)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2b0a8ce [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests
add 0d181e9 [FLINK-14663[tests] Support starting individual Job-/TaskManagers
add 44538e1 [FLINK-11463][tests] Support job submissions
add 3f92bd4 [FLINK-11463][tests] Add utilities
add 04aabae [FLINK-11463][tests] Always run in a fresh copy of the distribution
add 4d033ce [hotfix][tests] Remove optional usage
add 8fb5f1b [hotfix][tests] Use TestUtils#copyDirectory
add 751184d [FLINK-11465][tests] Add FlinkResource
add f0be162 [FLINK-11464][tests] Add DownloadCache
add 5221c26 [FLINK-11466][tests] Add KafkaResource
add 499fe56 [FLINK-11468][tests] Setup surefire execution
add 33b5663 [FLINK-11467][kafka][tests] Port Kafka Streaming E2E test
add 671029d [FLINK-11463][tests] Modify logging
No new revisions were added by this update.
Summary of changes:
.travis.yml | 49 +--
.../flink-end-to-end-tests-common-kafka/pom.xml | 140 ++++++++
.../flink/tests/util/kafka/KafkaResource.java | 112 +++++++
.../tests/util/kafka/KafkaResourceFactory.java | 36 ++
.../util/kafka/LocalStandaloneKafkaResource.java | 368 +++++++++++++++++++++
.../kafka/LocalStandaloneKafkaResourceFactory.java | 37 +++
.../tests/util/kafka/StreamingKafkaITCase.java | 173 ++++++++++
.../src/test/resources/log4j-test.properties | 27 ++
.../flink/tests/util/AutoClosableProcess.java | 8 +-
.../apache/flink/tests/util/FlinkDistribution.java | 135 +++++---
.../org/apache/flink/tests/util/TestUtils.java | 114 +++++++
.../activation/OperatingSystemRestriction.java | 62 ++++
.../tests/util/cache/AbstractDownloadCache.java | 152 +++++++++
.../flink/tests/util/cache/DownloadCache.java | 56 ++++
.../tests/util/cache/DownloadCacheFactory.java | 36 ++
.../apache/flink/tests/util/cache/LolCache.java | 70 ++++
.../flink/tests/util/cache/LolCacheFactory.java | 45 +++
.../tests/util/cache/PersistingDownloadCache.java | 81 +++++
.../util/cache/PersistingDownloadCacheFactory.java | 53 +++
.../tests/util/cache/TravisDownloadCache.java | 78 +++++
.../util/cache/TravisDownloadCacheFactory.java | 60 ++++
.../apache/flink/tests/util/categories/Dummy.java | 25 ++
.../apache/flink/tests/util/categories/Hadoop.java | 25 ++
.../flink/tests/util/categories/PreCommit.java | 25 ++
.../flink/tests/util/categories/TravisGroup1.java | 25 ++
.../flink/tests/util/categories/TravisGroup2.java | 25 ++
.../flink/tests/util/categories/TravisGroup3.java | 25 ++
.../flink/tests/util/categories/TravisGroup4.java | 25 ++
.../flink/tests/util/categories/TravisGroup5.java | 25 ++
.../flink/tests/util/categories/TravisGroup6.java | 25 ++
.../flink/tests/util/flink/ClusterController.java | 38 +++
.../flink/tests/util/flink/FlinkResource.java | 66 ++++
.../tests/util/flink/FlinkResourceFactory.java | 36 ++
.../flink/tests/util/flink/JobController.java | 25 ++
.../flink/tests/util/flink/JobSubmission.java | 128 +++++++
.../util/flink/LocalStandaloneFlinkResource.java | 153 +++++++++
.../flink/LocalStandaloneFlinkResourceFactory.java | 37 +++
.../tests/util/parameters/ParameterProperty.java | 64 ++++
.../apache/flink/tests/util/util/FactoryUtils.java | 66 ++++
...che.flink.tests.util.cache.DownloadCacheFactory | 17 +
.../flink-metrics-availability-test/pom.xml | 33 --
.../metrics/tests/MetricsAvailabilityITCase.java | 3 +
.../flink-metrics-reporter-prometheus-test/pom.xml | 33 --
.../tests/PrometheusReporterEndToEndITCase.java | 3 +
.../flink-streaming-kafka-test/pom.xml | 6 +-
.../flink-streaming-kafka010-test/pom.xml | 6 +-
.../flink-streaming-kafka011-test/pom.xml | 6 +-
flink-end-to-end-tests/pom.xml | 29 +-
flink-end-to-end-tests/run-nightly-tests.sh | 3 +-
flink-end-to-end-tests/run-pre-commit-tests.sh | 6 +-
.../test-scripts/test_streaming_kafka.sh | 25 --
.../test-scripts/test_streaming_kafka010.sh | 26 --
.../test-scripts/test_streaming_kafka011.sh | 24 --
.../test-scripts/test_streaming_kafka_common.sh | 103 ------
tools/travis_watchdog.sh | 19 +-
55 files changed, 2743 insertions(+), 329 deletions(-)
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResourceFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResourceFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/log4j-test.properties
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/TestUtils.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/activation/OperatingSystemRestriction.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/AbstractDownloadCache.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/DownloadCache.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/DownloadCacheFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/LolCache.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/LolCacheFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/PersistingDownloadCache.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/PersistingDownloadCacheFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/TravisDownloadCache.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/TravisDownloadCacheFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/Dummy.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/Hadoop.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/PreCommit.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup1.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup2.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup3.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup4.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup5.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/categories/TravisGroup6.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/ClusterController.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkResource.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkResourceFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/JobController.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/JobSubmission.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResourceFactory.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/parameters/ParameterProperty.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/util/FactoryUtils.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/resources/META-INF/services/org.apache.flink.tests.util.cache.DownloadCacheFactory
delete mode 100755 flink-end-to-end-tests/test-scripts/test_streaming_kafka.sh
delete mode 100755 flink-end-to-end-tests/test-scripts/test_streaming_kafka010.sh
delete mode 100755 flink-end-to-end-tests/test-scripts/test_streaming_kafka011.sh
delete mode 100644 flink-end-to-end-tests/test-scripts/test_streaming_kafka_common.sh