Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r191738239
--- Diff: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ---
@@ -75,6 +76,8 @@ function verify_result {
}
function shutdown_elasticsearch_cluster {
+ local index=$1
--- End diff --
adjust existing usages in `test_streaming_elasticsearch.sh`---
