You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by le...@apache.org on 2022/02/15 01:52:53 UTC

[flink] branch master updated (6eeb7e1 -> 316f308)

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