Repository: flink Updated Branches: refs/heads/master c71675f7c -> 1e9fff4ab
[FLINK-3488] [tests] Fix flakey test Kafka08ITCase.testBigRecordJob This closes #1998 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bd1c245c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bd1c245c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bd1c245c Branch: refs/heads/master Commit: bd1c245cbffa4781672c63d144277bb4e244d7f6 Parents: c71675f Author: Joshi <rekhajo...@gmail.com> Authored: Tue May 17 11:00:00 2016 -0700 Committer: Stephan Ewen <se...@apache.org> Committed: Tue May 17 20:13:11 2016 +0200 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/KafkaConsumerTestBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/bd1c245c/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java index cc9205c..3ba8cff 100644 --- a/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java +++ b/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java @@ -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);
