Skip to content

Commit dd3fcc1

Browse files
committed
Change WaitStrategy to forLogMessage
This approach seems to be more reliable.
1 parent 720946e commit dd3fcc1

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/elasticsearch/ElasticsearchDatabase.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,24 +21,20 @@
2121
import org.apache.flink.connector.jdbc.testutils.DatabaseExtension;
2222
import org.apache.flink.connector.jdbc.testutils.DatabaseMetadata;
2323
import org.apache.flink.util.FlinkRuntimeException;
24-
2524
import org.testcontainers.containers.wait.strategy.Wait;
2625
import org.testcontainers.elasticsearch.ElasticsearchContainer;
2726

2827
import java.time.Duration;
2928

3029
import static org.apache.flink.connector.jdbc.testutils.databases.elasticsearch.ElasticsearchMetadata.PASSWORD;
31-
import static org.apache.flink.connector.jdbc.testutils.databases.elasticsearch.ElasticsearchMetadata.USERNAME;
3230

3331
/** Elasticsearch database for testing. */
3432
public class ElasticsearchDatabase extends DatabaseExtension implements ElasticsearchImages {
3533

3634
private static final ElasticsearchContainer CONTAINER =
3735
new ElasticsearchContainer(ELASTICSEARCH_8)
3836
.waitingFor(
39-
Wait.forHttp("/_license")
40-
.withBasicCredentials(USERNAME, PASSWORD)
41-
.withReadTimeout(Duration.ofSeconds(5))
37+
Wait.forLogMessage(".*Node .* is selected as the current health node.*", 1)
4238
.withStartupTimeout(Duration.ofMinutes(5)));
4339

4440
private static ElasticsearchMetadata metadata;

0 commit comments

Comments
 (0)