This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3f3e5306460497a920a111fc43a5e322fa729c80 Author: Nico Kruber <[email protected]> AuthorDate: Wed Jul 31 02:50:15 2019 +0200 [hotfix][tests] fix topic name in FlinkKafkaProducerITCase#testScaleUpAfterScalingDown() --- .../flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java index 1097fd6..2242e81 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java @@ -386,7 +386,7 @@ public class FlinkKafkaProducerITCase extends KafkaTestBase { */ @Test public void testScaleUpAfterScalingDown() throws Exception { - String topic = "scale-down-before-first-checkpoint"; + String topic = "scale-up-after-scaling-down"; final int parallelism1 = 4; final int parallelism2 = 2;
