diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md b/docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md
index 939cfc6d8bb..666dcfed3d7 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md
@@ -146,7 +146,7 @@ Pipeline Connector Options
batch.size.max.bytes |
optional |
- 5242880 |
+ 52428800 |
Long |
每个批量请求的缓冲操作在内存中的最大值(以byte为单位)。 |
diff --git a/docs/content/docs/connectors/pipeline-connectors/elasticsearch.md b/docs/content/docs/connectors/pipeline-connectors/elasticsearch.md
index 579d7015e9f..70413cf3593 100644
--- a/docs/content/docs/connectors/pipeline-connectors/elasticsearch.md
+++ b/docs/content/docs/connectors/pipeline-connectors/elasticsearch.md
@@ -146,7 +146,7 @@ Pipeline Connector Options
batch.size.max.bytes |
optional |
- 5242880 |
+ 52428800 |
Long |
The maximum size of batch requests in bytes. |
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java
index b2629040059..8323dd228ca 100644
--- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java
+++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java
@@ -59,7 +59,7 @@ public class ElasticsearchDataSinkOptions {
public static final ConfigOption MAX_BATCH_SIZE_IN_BYTES =
ConfigOptions.key("batch.size.max.bytes")
.longType()
- .defaultValue(5L * 1024L * 1024L)
+ .defaultValue(50L * 1024L * 1024L)
.withDescription("The maximum size of batch requests in bytes.");
/** The maximum time to wait for incomplete batches before flushing. */