From ed16c2dc50aca4974621df5c7bc26822a427a6f6 Mon Sep 17 00:00:00 2001 From: wangqh <1095193290@qq.com> Date: Fri, 24 Jan 2025 00:47:04 +0800 Subject: [PATCH 1/3] Update ElasticsearchDataSinkOptions.java --- .../elasticsearch/sink/ElasticsearchDataSinkOptions.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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. */ From 1024667c4e794e95f15e30fddba7d9df804f2278 Mon Sep 17 00:00:00 2001 From: wangqh <1095193290@qq.com> Date: Sat, 25 Jan 2025 15:34:09 +0800 Subject: [PATCH 2/3] Update elasticsearch.md --- .../docs/connectors/pipeline-connectors/elasticsearch.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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. From e0dd302f348d75424b59d49f9db6e3bab33162c7 Mon Sep 17 00:00:00 2001 From: wangqh <1095193290@qq.com> Date: Sat, 25 Jan 2025 15:41:31 +0800 Subject: [PATCH 3/3] Update elasticsearch.md --- .../docs/connectors/pipeline-connectors/elasticsearch.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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为单位)。