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/16 01:31:57 UTC
[flink] 02/02: [hotfix][tests][connector/kafka] Disable KafkaSink metric tests until FLINK-26126 has been fixed
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 <ru...@hotmail.com>
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 {}
}