This is an automated email from the ASF dual-hosted git repository. leonard pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3106f14c06c8ee619afc516cb627b83e5ec4ca74 Author: Hang Ruan <[email protected]> AuthorDate: Tue Feb 15 20:43:30 2022 +0800 [hotfix][tests][connector/kafka] Disable KafkaSink metric tests until FLINK-26126 has been fixed --- .../org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java | 9 +++++++++ .../java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java | 9 +++++++++ 2 files changed, 18 insertions(+) diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java index 4234f7a..32210c6 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java @@ -205,6 +205,15 @@ public class KafkaSinkITCase extends TestLogger { @TestContext KafkaSinkExternalContextFactory sinkContext = new KafkaSinkExternalContextFactory(kafka.getContainer(), Collections.emptyList()); + + @Disabled("Skip metric test until FLINK-26126 fixed") + @TestTemplate + @Override + public void testMetrics( + TestEnvironment testEnv, + DataStreamSinkExternalContext<String> externalContext, + CheckpointingMode semantic) + throws Exception {} } @Test diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java index 520491e..ff845f4 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java @@ -84,4 +84,13 @@ public class KafkaSinkE2ECase extends SinkTestSuiteBase<String> { .toURL())); public KafkaSinkE2ECase() throws Exception {} + + @Disabled("Skip metric test until FLINK-26126 fixed") + @TestTemplate + @Override + public void testMetrics( + TestEnvironment testEnv, + DataStreamSinkExternalContext<String> externalContext, + CheckpointingMode semantic) + throws Exception {} }
