This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6eeb7e1 [FLINK-23559][tests] Randomize periodic materialisation
interval in tests
add df962b2 [FLINK-25288][tests] Add savepoint/metric cases in source
suite of connector test framework
add 316f308 [FLINK-25288][tests][pulsar] Make pulsar e2e tests more robust
No new revisions were added by this update.
Summary of changes:
.../testutils/KafkaSourceExternalContext.java | 2 +-
.../util/flink/FlinkContainerTestEnvironment.java | 23 +-
.../FlinkContainerWithPulsarEnvironment.java | 16 +-
.../flink/runtime/testutils/CommonTestUtils.java | 30 +-
.../environment/MiniClusterTestEnvironment.java | 46 ++-
.../testframe/testsuites/SourceTestSuiteBase.java | 361 ++++++++++++++++++++-
...Assertions.java => ConnectorTestConstants.java} | 18 +-
.../connector/testframe/utils/MetricQuerier.java | 162 +++++++++
8 files changed, 630 insertions(+), 28 deletions(-)
copy
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/{CollectIteratorAssertions.java
=> ConnectorTestConstants.java} (60%)
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/MetricQuerier.java