[flink-connector-elasticsearch] 03/13: [FLINK-28177] Fix unstable test

[chesnay]

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

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

commit 13c029f82c96b6600d29596d67d6bbe7b2061d88
Author: kurt <dingweiqi...@163.com>
AuthorDate: Mon Sep 12 15:45:00 2022 +0200

    [FLINK-28177] Fix unstable test
---
 .../elasticsearch/table/Elasticsearch6DynamicSinkITCase.java       | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
 
b/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
index fd31844..8c31eb2 100644
--- 
a/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
+++ 
b/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
@@ -230,8 +230,11 @@ public class Elasticsearch6DynamicSinkITCase extends 
TestLogger {
 
     @Test
     public void testWritingDocumentsNoPrimaryKey() throws Exception {
-        TableEnvironment tableEnvironment =
-                TableEnvironment.create(EnvironmentSettings.inStreamingMode());
+        EnvironmentSettings settings = EnvironmentSettings.inStreamingMode();
+        settings.getConfiguration().setString("restart-strategy", 
"fixed-delay");
+        
settings.getConfiguration().setInteger("restart-strategy.fixed-delay.attempts", 
3);
+        // default fixed delay is 1 seconds
+        TableEnvironment tableEnvironment = TableEnvironment.create(settings);
 
         String index = "no-primary-key";
         String myType = "MyType";