Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18236

flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

    XMLWordPrintableJSON

Details

    Description

      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

       

      Attachments

        Issue Links

          Activity

            People

              jackylau Jacky Lau
              jackylau Jacky Lau
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: