commit | 39674bf118eda8d5884690881aa1418377d70050 | [log] [tgz] |
---|---|---|
author | Aljoscha Krettek <aljoscha@apache.org> | Tue Aug 25 10:25:17 2020 +0200 |
committer | MartijnVisser <martijn@2symbols.com> | Mon Apr 04 15:45:43 2022 +0200 |
tree | f28ca856be0d3a0ff1412d42b3055f34c6341a35 | |
parent | 3f9b642b3e7246c6072cddeda42fd7a410850595 [diff] |
[FLINK-17159] Harden ElasticsearchSinkITCase Before, it could happen that the embedded node is not ready. Now we wait for nodes/data nodes to be live before returning from the initialization method.