提交 bd1c245c 编写于 作者: J Joshi 提交者: Stephan Ewen

[FLINK-3488] [tests] Fix flakey test Kafka08ITCase.testBigRecordJob

This closes #1998
上级 c71675f7
......@@ -840,7 +840,7 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBase {
// add producing topology
Properties producerProps = new Properties();
producerProps.setProperty("max.request.size", Integer.toString(1024 * 1024 * 14));
producerProps.setProperty("max.request.size", Integer.toString(1024 * 1024 * 15));
producerProps.setProperty("retries", "3");
producerProps.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokerConnectionStrings);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册