(flink-connector-elasticsearch) branch main updated: [FLINK-39716] Fix time unit for network timeout options

[guoweijie]

This is an automated email from the ASF dual-hosted git repository.

reswqa pushed a commit to branch main
in repository 
https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git


The following commit(s) were added to refs/heads/main by this push:
     new 0bd8ce3  [FLINK-39716] Fix time unit for network timeout options
0bd8ce3 is described below

commit 0bd8ce30f02b01ded1e0d80861404fb62cb9e4fc
Author: reswqa <res...@163.com>
AuthorDate: Wed May 20 14:59:37 2026 +0800

    [FLINK-39716] Fix time unit for network timeout options
---
 .../connector/elasticsearch/table/ElasticsearchDynamicSink.java     | 6 +++---
 .../connector/elasticsearch/table/ElasticsearchDynamicSource.java   | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
 
b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
index a522613..be53630 100644
--- 
a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
+++ 
b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
@@ -167,15 +167,15 @@ class ElasticsearchDynamicSink implements 
DynamicTableSink {
 
         if (config.getConnectionRequestTimeout().isPresent()) {
             builder.setConnectionRequestTimeout(
-                    (int) 
config.getConnectionRequestTimeout().get().getSeconds());
+                    (int) 
config.getConnectionRequestTimeout().get().toMillis());
         }
 
         if (config.getConnectionTimeout().isPresent()) {
-            builder.setConnectionTimeout((int) 
config.getConnectionTimeout().get().getSeconds());
+            builder.setConnectionTimeout((int) 
config.getConnectionTimeout().get().toMillis());
         }
 
         if (config.getSocketTimeout().isPresent()) {
-            builder.setSocketTimeout((int) 
config.getSocketTimeout().get().getSeconds());
+            builder.setSocketTimeout((int) 
config.getSocketTimeout().get().toMillis());
         }
 
         return SinkV2Provider.of(builder.build(), 
config.getParallelism().orElse(null));
diff --git 
a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSource.java
 
b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSource.java
index 5250b4b..eb5b56b 100644
--- 
a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSource.java
+++ 
b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSource.java
@@ -121,15 +121,15 @@ public class ElasticsearchDynamicSource implements 
LookupTableSource, SupportsPr
 
         if (config.getConnectionRequestTimeout().isPresent()) {
             builder.setConnectionRequestTimeout(
-                    (int) 
config.getConnectionRequestTimeout().get().getSeconds());
+                    (int) 
config.getConnectionRequestTimeout().get().toMillis());
         }
 
         if (config.getConnectionTimeout().isPresent()) {
-            builder.setConnectionTimeout((int) 
config.getConnectionTimeout().get().getSeconds());
+            builder.setConnectionTimeout((int) 
config.getConnectionTimeout().get().toMillis());
         }
 
         if (config.getSocketTimeout().isPresent()) {
-            builder.setSocketTimeout((int) 
config.getSocketTimeout().get().getSeconds());
+            builder.setSocketTimeout((int) 
config.getSocketTimeout().get().toMillis());
         }
 
         return builder.build();