[flink] branch release-1.14 updated: [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was fixed.

[xtsong]

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new 4e68c45  [FLINK-23944][connector/pulsar] Enable 
PulsarSourceITCase.testTaskManagerFailure after test framework was fixed.
4e68c45 is described below

commit 4e68c4559619676995984565315411af8598af2e
Author: Yufan Sheng <yu...@streamnative.io>
AuthorDate: Wed Sep 8 23:13:06 2021 +0800

    [FLINK-23944][connector/pulsar] Enable 
PulsarSourceITCase.testTaskManagerFailure after test framework was fixed.
    
    This closes #17201
---
 .../flink/connector/pulsar/source/PulsarSourceITCase.java | 15 ---------------
 1 file changed, 15 deletions(-)

diff --git 
a/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
 
b/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
index ce7cce0..89457dc 100644
--- 
a/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
+++ 
b/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
@@ -23,17 +23,12 @@ import 
org.apache.flink.connector.pulsar.testutils.PulsarTestEnvironment;
 import 
org.apache.flink.connector.pulsar.testutils.cases.MultipleTopicConsumingContext;
 import 
org.apache.flink.connector.pulsar.testutils.cases.SingleTopicConsumingContext;
 import org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime;
-import org.apache.flink.connectors.test.common.environment.ClusterControllable;
 import 
org.apache.flink.connectors.test.common.environment.MiniClusterTestEnvironment;
-import org.apache.flink.connectors.test.common.environment.TestEnvironment;
-import org.apache.flink.connectors.test.common.external.ExternalContext;
 import 
org.apache.flink.connectors.test.common.junit.annotations.ExternalContextFactory;
 import 
org.apache.flink.connectors.test.common.junit.annotations.ExternalSystem;
 import org.apache.flink.connectors.test.common.junit.annotations.TestEnv;
 import org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase;
 
-import org.junit.jupiter.api.Disabled;
-
 /** Unite test class for {@link PulsarSource}. */
 @SuppressWarnings("unused")
 class PulsarSourceITCase extends SourceTestSuiteBase<String> {
@@ -53,14 +48,4 @@ class PulsarSourceITCase extends SourceTestSuiteBase<String> 
{
     @ExternalContextFactory
     PulsarTestContextFactory<String, MultipleTopicConsumingContext> 
multipleTopic =
             new PulsarTestContextFactory<>(pulsar, 
MultipleTopicConsumingContext::new);
-
-    @Disabled
-    @Override
-    public void testTaskManagerFailure(
-            TestEnvironment testEnv,
-            ExternalContext<String> externalContext,
-            ClusterControllable controller)
-            throws Exception {
-        super.testTaskManagerFailure(testEnv, externalContext, controller);
-    }
 }