This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new c059458 [FLINK-25976][connectors/kinesis] Updating the default number
of in flight records to 50
c059458 is described below
commit c0594583cfd5099e401e455b3ec271307ae87449
Author: Zichen Liu <[email protected]>
AuthorDate: Mon Feb 7 20:02:29 2022 +0000
[FLINK-25976][connectors/kinesis] Updating the default number of in flight
records to 50
This closes #18652
---
docs/content.zh/docs/connectors/datastream/kinesis.md | 4 ++--
docs/content/docs/connectors/datastream/kinesis.md | 4 ++--
.../flink/connector/kinesis/sink/KinesisDataStreamsSinkBuilder.java | 6 +++---
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/docs/content.zh/docs/connectors/datastream/kinesis.md
b/docs/content.zh/docs/connectors/datastream/kinesis.md
index 8ea68fa..500db81 100644
--- a/docs/content.zh/docs/connectors/datastream/kinesis.md
+++ b/docs/content.zh/docs/connectors/datastream/kinesis.md
@@ -593,7 +593,7 @@ KinesisDataStreamsSink<String> kdsSink =
.setStreamName("your-stream-name")
// Required
.setFailOnError(false)
// Optional
.setMaxBatchSize(500)
// Optional
- .setMaxInFlightRequests(16)
// Optional
+ .setMaxInFlightRequests(50)
// Optional
.setMaxBufferedRequests(10_000)
// Optional
.setMaxBatchSizeInBytes(5 * 1024 * 1024)
// Optional
.setMaxTimeInBufferMS(5000)
// Optional
@@ -621,7 +621,7 @@ val kdsSink = KinesisDataStreamsSink.<String>builder()
.setStreamName("your-stream-name")
// Required
.setFailOnError(false)
// Optional
.setMaxBatchSize(500)
// Optional
- .setMaxInFlightRequests(16)
// Optional
+ .setMaxInFlightRequests(50)
// Optional
.setMaxBufferedRequests(10000)
// Optional
.setMaxBatchSizeInBytes(5 * 1024 * 1024)
// Optional
.setMaxTimeInBufferMS(5000)
// Optional
diff --git a/docs/content/docs/connectors/datastream/kinesis.md
b/docs/content/docs/connectors/datastream/kinesis.md
index 45e53a5..f91821b 100644
--- a/docs/content/docs/connectors/datastream/kinesis.md
+++ b/docs/content/docs/connectors/datastream/kinesis.md
@@ -605,7 +605,7 @@ KinesisDataStreamsSink<String> kdsSink =
.setStreamName("your-stream-name")
// Required
.setFailOnError(false)
// Optional
.setMaxBatchSize(500)
// Optional
- .setMaxInFlightRequests(16)
// Optional
+ .setMaxInFlightRequests(50)
// Optional
.setMaxBufferedRequests(10_000)
// Optional
.setMaxBatchSizeInBytes(5 * 1024 * 1024)
// Optional
.setMaxTimeInBufferMS(5000)
// Optional
@@ -633,7 +633,7 @@ val kdsSink = KinesisDataStreamsSink.<String>builder()
.setStreamName("your-stream-name")
// Required
.setFailOnError(false)
// Optional
.setMaxBatchSize(500)
// Optional
- .setMaxInFlightRequests(16)
// Optional
+ .setMaxInFlightRequests(50)
// Optional
.setMaxBufferedRequests(10000)
// Optional
.setMaxBatchSizeInBytes(5 * 1024 * 1024)
// Optional
.setMaxTimeInBufferMS(5000)
// Optional
diff --git
a/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkBuilder.java
b/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkBuilder.java
index ae57fbd..20b960f 100644
---
a/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkBuilder.java
+++
b/flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkBuilder.java
@@ -46,7 +46,7 @@ import java.util.Properties;
*
* <ul>
* <li>{@code maxBatchSize} will be 500
- * <li>{@code maxInFlightRequests} will be 16
+ * <li>{@code maxInFlightRequests} will be 50
* <li>{@code maxBufferedRequests} will be 10000
* <li>{@code maxBatchSizeInBytes} will be 5 MB i.e. {@code 5 * 1024 * 1024}
* <li>{@code maxTimeInBufferMS} will be 5000ms
@@ -62,8 +62,8 @@ public class KinesisDataStreamsSinkBuilder<InputT>
InputT, PutRecordsRequestEntry,
KinesisDataStreamsSinkBuilder<InputT>> {
private static final int DEFAULT_MAX_BATCH_SIZE = 500;
- private static final int DEFAULT_MAX_IN_FLIGHT_REQUESTS = 16;
- private static final int DEFAULT_MAX_BUFFERED_REQUESTS = 10000;
+ private static final int DEFAULT_MAX_IN_FLIGHT_REQUESTS = 50;
+ private static final int DEFAULT_MAX_BUFFERED_REQUESTS = 10_000;
private static final long DEFAULT_MAX_BATCH_SIZE_IN_B = 5 * 1024 * 1024;
private static final long DEFAULT_MAX_TIME_IN_BUFFER_MS = 5000;
private static final long DEFAULT_MAX_RECORD_SIZE_IN_B = 1 * 1024 * 1024;
