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

Fix Elasticsearch version interference

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.3.0, 1.3.1
    • Fix Version/s: 1.3.2, 1.4.0
    • Component/s: Streaming Connectors
    • Labels:
      None

      Description

      At least two users have encountered problems with shading in the Elasticsearch connector:

      The problem seems to be (quote from the second mail):

      I've found out the source of the problem when I build flink locally.
      elastic-search base depends on (by default) ES version 1.7.1 that depends on
      asm 4.1 and that version is shaded to elasticsearch-base-jar. I tried to set
      elasticsearch.version property in Maven to 5.1.2 (the same as elasticsearch5
      connector) but then elasticsearch-base does not compile:
      
      [ERROR] Failed to execute goal
      org.apache.maven.plugins:maven-compiler-plugin:3.1:testCompile
      (default-testCompile) on project flink-connector-elasticsearch-base_2.11:
      Compilation failure
      [ERROR]
      /home/adebski/Downloads/flink-release-1.3.1/flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java:[491,92]
      no suitable constructor found for
      BulkItemResponse(int,java.lang.String,org.elasticsearch.action.ActionResponse)
      [ERROR] constructor
      org.elasticsearch.action.bulk.BulkItemResponse.BulkItemResponse(int,java.lang.String,org.elasticsearch.action.DocWriteResponse)
      is not applicable
      [ERROR] (argument mismatch; org.elasticsearch.action.ActionResponse cannot
      be converted to org.elasticsearch.action.DocWriteResponse)
      [ERROR] constructor
      org.elasticsearch.action.bulk.BulkItemResponse.BulkItemResponse(int,java.lang.String,org.elasticsearch.action.bulk.BulkItemResponse.Failure)
      is not applicable
      [ERROR] (argument mismatch; org.elasticsearch.action.ActionResponse cannot
      be converted to org.elasticsearch.action.bulk.BulkItemResponse.Failure)
      

      To me, it seems like we have to get rid of the "base" package and have two completely separate packages.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Adebski Adebski
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: