[FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest::testScaleUp() Previously, the testScaleUp() test was taking too much resources and causing test resources to be terminated before the test could finish. This commit lowers the intensity of the test, while still retaining the verified behaviour (i.e., when restoring the Kafka consumer with higher parallelism and more Kafka partitions).
This closes #5201. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/74135c9d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/74135c9d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/74135c9d Branch: refs/heads/release-1.4 Commit: 74135c9db11728f2189b6b4ccae90b1d4ccb84c1 Parents: f462f77 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Thu Dec 21 13:41:48 2017 -0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Jan 5 22:04:51 2018 -0800 ---------------------------------------------------------------------- .../streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/74135c9d/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java index 168cfd5..6ccfeb1 100644 --- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java +++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java @@ -516,7 +516,7 @@ public class FlinkKafkaConsumerBaseTest { @Test public void testScaleUp() throws Exception { - testRescaling(5, 2, 15, 1000); + testRescaling(5, 2, 8, 30); } @Test
