Skip to content

Commit 2ae5332

Browse files
committed
Fixed a bug in the default value of the config option record.size.max.bytes
see: https://github.com/apache/flink/blob/release-1.20.3/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java#L363-L366 Signed-off-by: Pei Yu <125331682@qq.com>
1 parent 099b982 commit 2ae5332

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ Pipeline Connector Options
160160
<tr>
161161
<td>record.size.max.bytes</td>
162162
<td>optional</td>
163-
<td style="word-wrap: break-word;">10485760</td>
163+
<td style="word-wrap: break-word;">5242880</td>
164164
<td>Long</td>
165165
<td>单个记录的最大大小(以byte为单位)。</td>
166166
</tr>

docs/content/docs/connectors/pipeline-connectors/elasticsearch.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ Pipeline Connector Options
160160
<tr>
161161
<td>record.size.max.bytes</td>
162162
<td>optional</td>
163-
<td style="word-wrap: break-word;">10485760</td>
163+
<td style="word-wrap: break-word;">5242880</td>
164164
<td>Long</td>
165165
<td>The maximum size of a single record in bytes.</td>
166166
</tr>

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public class ElasticsearchDataSinkOptions {
7474
public static final ConfigOption<Long> MAX_RECORD_SIZE_IN_BYTES =
7575
ConfigOptions.key("record.size.max.bytes")
7676
.longType()
77-
.defaultValue(10L * 1024L * 1024L)
77+
.defaultValue(5L * 1024L * 1024L)
7878
.withDescription("The maximum size of a single record in bytes.");
7979

8080
/** The version of Elasticsearch to connect to. */

0 commit comments

Comments
 (0)