jackylau created FLINK-18236:
--------------------------------
Summary: flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right
Key: FLINK-18236
URL:
https://issues.apache.org/jira/browse/FLINK-18236 Project: Flink
Issue Type: Bug
Components: Connectors / ElasticSearch
Affects Versions: 1.10.0
Reporter: jackylau
Fix For: 1.11.0, 1.12.0
we can see there are diffirent tests
runElasticsearchSinkTest
runElasticsearchSinkCborTest
runElasticsearchSinkSmileTest
runElasticSearchSinkTest
etc.
And use SourceSinkDataTestKit.verifyProducedSinkData(client, index) to ensure the correctness of results. But all of them use the same index.
That is to say, if the second unit test sink doesn't send successfully. they are also equal when use verifyProducedSinkData
--
This message was sent by Atlassian Jira
(v8.3.4#803005)