projects / flink.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5b8dc10) | patch
[FLINK-27185][connector] Convert connector-base module to assertj
authorAlexander Preuß <11444089+alpreu@users.noreply.github.com>
Fri, 6 May 2022 09:07:06 +0000 (11:07 +0200)
committerMartijnVisser <martijn@2symbols.com>
Wed, 18 May 2022 14:28:28 +0000 (16:28 +0200)
commitd38b7d1a5baca26546335c5483275ad0ca1ccb87
tree795927718c71f37c05e1a081b550cead65d8473ftree | snapshot
parent5b8dc104f76f89e1774e0446788cb29ba7788d79commit | diff
[FLINK-27185][connector] Convert connector-base module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
17 files changed:
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTestUtils.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceITCase.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReaderTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumeratorTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitSerializerTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceITCase.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceMetricsITCase.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/synchronization/FutureCompletingBlockingQueueTest.java diff | blob | history
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/utils/SerdeUtilsTest.java diff | blob | history
flink-test-utils-parent/flink-test-utils/pom.xml diff | blob | history
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/metrics/testutils/MetricAssertions.java [new file with mode: 0644] blob
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/metrics/testutils/MetricMatchers.java [deleted file] blob | history
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkMetricsITCase.java diff | blob | history
Apache Flink