[hotfix][tests] Remove Kafka testFailOnDeploy test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f4e0cdf6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f4e0cdf6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f4e0cdf6 Branch: refs/heads/release-1.5 Commit: f4e0cdf6d82d4acbbf91a45c58c72dd48822833a Parents: ff3a0ec Author: zentol <ches...@apache.org> Authored: Wed Mar 7 13:38:03 2018 +0100 Committer: zentol <ches...@apache.org> Committed: Fri Apr 6 15:24:02 2018 +0200 ---------------------------------------------------------------------- .../connectors/kafka/Kafka010ITCase.java | 6 --- .../connectors/kafka/Kafka011ITCase.java | 5 -- .../connectors/kafka/Kafka08ITCase.java | 5 -- .../connectors/kafka/Kafka09ITCase.java | 5 -- .../connectors/kafka/KafkaConsumerTestBase.java | 49 -------------------- 5 files changed, 70 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f4e0cdf6/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java index 06f627d..a038c8e 100644 --- a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java @@ -81,12 +81,6 @@ public class Kafka010ITCase extends KafkaConsumerTestBase { public void testCancelingFullTopic() throws Exception { runCancelingOnFullInputTest(); } - - @Test(timeout = 60000) - public void testFailOnDeploy() throws Exception { - runFailOnDeployTest(); - } - // --- source to partition mappings and exactly once --- @Test(timeout = 60000) http://git-wip-us.apache.org/repos/asf/flink/blob/f4e0cdf6/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java index fd6eb61..f48f87a 100644 --- a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java @@ -90,11 +90,6 @@ public class Kafka011ITCase extends KafkaConsumerTestBase { runCancelingOnFullInputTest(); } - @Test(timeout = 60000) - public void testFailOnDeploy() throws Exception { - runFailOnDeployTest(); - } - // --- source to partition mappings and exactly once --- @Test(timeout = 60000) http://git-wip-us.apache.org/repos/asf/flink/blob/f4e0cdf6/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08ITCase.java b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08ITCase.java index 6abccde..5af219e 100644 --- a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08ITCase.java @@ -75,11 +75,6 @@ public class Kafka08ITCase extends KafkaConsumerTestBase { } @Test(timeout = 60000) - public void testFailOnDeploy() throws Exception { - runFailOnDeployTest(); - } - - @Test(timeout = 60000) public void testInvalidOffset() throws Exception { final int parallelism = 1; http://git-wip-us.apache.org/repos/asf/flink/blob/f4e0cdf6/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java index 3594854..f022c8e 100644 --- a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java @@ -55,11 +55,6 @@ public class Kafka09ITCase extends KafkaConsumerTestBase { runCancelingOnFullInputTest(); } - @Test(timeout = 60000) - public void testFailOnDeploy() throws Exception { - runFailOnDeployTest(); - } - // --- source to partition mappings and exactly once --- @Test(timeout = 60000) http://git-wip-us.apache.org/repos/asf/flink/blob/f4e0cdf6/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java index f07c0bb..f9d745e 100644 --- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java +++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java @@ -1113,55 +1113,6 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBase { } /** - * Tests that the source can be properly canceled when reading full partitions. - */ - public void runFailOnDeployTest() throws Exception { - final String topic = "failOnDeployTopic"; - - createTestTopic(topic, 2, 1); - - DeserializationSchema<Integer> schema = - new TypeInformationSerializationSchema<>(BasicTypeInfo.INT_TYPE_INFO, new ExecutionConfig()); - - StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); - env.setParallelism(12); // needs to be more that the mini cluster has slots - env.getConfig().disableSysoutLogging(); - - Properties props = new Properties(); - props.putAll(standardProps); - props.putAll(secureProps); - FlinkKafkaConsumerBase<Integer> kafkaSource = kafkaServer.getConsumer(topic, schema, props); - - env - .addSource(kafkaSource) - .addSink(new DiscardingSink<Integer>()); - - try { - env.execute("test fail on deploy"); - fail("this test should fail with an exception"); - } - catch (JobExecutionException e) { - - // validate that we failed due to a NoResourceAvailableException - Throwable cause = e.getCause(); - int depth = 0; - boolean foundResourceException = false; - - while (cause != null && depth++ < 20) { - if (cause instanceof NoResourceAvailableException) { - foundResourceException = true; - break; - } - cause = cause.getCause(); - } - - assertTrue("Wrong exception", foundResourceException); - } - - deleteTestTopic(topic); - } - - /** * Test producing and consuming into multiple topics. * @throws Exception */
