You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/06/03 07:20:48 UTC

[flink] branch master updated: [FLINK-18052] Increase timeout for ES Search API in IT Cases

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

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 773ad7d  [FLINK-18052] Increase timeout for ES Search API in IT Cases
773ad7d is described below

commit 773ad7d0aa6b507c6d003bb554ee45566741cede
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Tue Jun 2 08:51:35 2020 +0200

    [FLINK-18052] Increase timeout for ES Search API in IT Cases
    
    This closes #12434
---
 .../elasticsearch/table/Elasticsearch6DynamicSinkITCase.java | 12 ++++++++----
 .../elasticsearch/table/Elasticsearch7DynamicSinkITCase.java | 12 ++++++++----
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
index 3c09653..41a67f6 100644
--- a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
+++ b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
@@ -219,17 +219,21 @@ public class Elasticsearch6DynamicSinkITCase {
 
 		// search API does not return documents that were not indexed, we might need to query
 		// the index a few times
-		Deadline deadline = Deadline.fromNow(Duration.ofSeconds(1));
+		Deadline deadline = Deadline.fromNow(Duration.ofSeconds(30));
 		SearchHits hits;
 		do {
 			hits = client.prepareSearch(index)
 				.execute()
 				.actionGet()
 				.getHits();
-			if (hits.getTotalHits() == 0) {
-				Thread.sleep(100);
+			if (hits.getTotalHits() < 1) {
+				Thread.sleep(200);
 			}
-		} while (hits.getTotalHits() == 0 && deadline.hasTimeLeft());
+		} while (hits.getTotalHits() < 1 && deadline.hasTimeLeft());
+
+		if (hits.getTotalHits() < 1) {
+			throw new AssertionError("Could not retrieve results from Elasticsearch.");
+		}
 
 		Map<String, Object> result = hits.getAt(0).getSourceAsMap();
 		Map<Object, Object> expectedMap = new HashMap<>();
diff --git a/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java b/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
index 3b667dc..dbd1ff9 100644
--- a/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
+++ b/flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
@@ -211,17 +211,21 @@ public class Elasticsearch7DynamicSinkITCase {
 
 		// search API does not return documents that were not indexed, we might need to query
 		// the index a few times
-		Deadline deadline = Deadline.fromNow(Duration.ofSeconds(1));
+		Deadline deadline = Deadline.fromNow(Duration.ofSeconds(30));
 		SearchHits hits;
 		do {
 			hits = client.prepareSearch(index)
 				.execute()
 				.actionGet()
 				.getHits();
-			if (hits.getTotalHits().value == 0) {
-				Thread.sleep(100);
+			if (hits.getTotalHits().value < 1) {
+				Thread.sleep(200);
 			}
-		} while (hits.getTotalHits().value == 0 && deadline.hasTimeLeft());
+		} while (hits.getTotalHits().value < 1 && deadline.hasTimeLeft());
+
+		if (hits.getTotalHits().value < 1) {
+			throw new AssertionError("Could not retrieve results from Elasticsearch.");
+		}
 
 		Map<String, Object> result = hits.getAt(0).getSourceAsMap();
 		Map<Object, Object> expectedMap = new HashMap<>();