flink集成elasticsearch5.4，运行异常解决

异常信息：

java.lang.NoSuchMethodError: io.netty.buffer.CompositeByteBuf.addComponents(ZLjava/lang/Iterable;)Lio/netty/buffer/CompositeByteBuf;

	at org.elasticsearch.transport.netty4.Netty4Utils.toByteBuf(Netty4Utils.java:122)

	at org.elasticsearch.transport.netty4.Netty4Transport.sendMessage(Netty4Transport.java:396)

	at org.elasticsearch.transport.netty4.Netty4Transport.sendMessage(Netty4Transport.java:95)

	at org.elasticsearch.transport.TcpTransport.internalSendMessage(TcpTransport.java:1121)

	at org.elasticsearch.transport.TcpTransport.sendRequestToChannel(TcpTransport.java:1110)

	at org.elasticsearch.transport.TcpTransport.executeHandshake(TcpTransport.java:1606)

	at org.elasticsearch.transport.TcpTransport.openConnection(TcpTransport.java:577)

	at org.elasticsearch.transport.TcpTransport.openConnection(TcpTransport.java:117)

	at org.elasticsearch.transport.TransportService.openConnection(TransportService.java:351)

	at org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.doSample(TransportClientNodesService.java:407)

	at org.elasticsearch.client.transport.TransportClientNodesService$NodeSampler.sample(TransportClientNodesService.java:357)

	at org.elasticsearch.client.transport.TransportClientNodesService.addTransportAddresses(TransportClientNodesService.java:198)

	at org.elasticsearch.client.transport.TransportClient.addTransportAddresses(TransportClient.java:332)

	at com.jd.bdp.apus.flink.jmq.utils.SecurityClient.client(SecurityClient.java:42)

	at com.jd.bdp.apus.flink.jmq.operators.JmpMapFunction.open(JmpMapFunction.java:49)

	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)

	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)

	at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:420)

	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:296)

	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)

	at java.lang.Thread.run(Thread.java:748)

 解决方案：

Settings settings = Settings.builder().put("cluster.name", ClusterName)
        .put("client.transport.sniff", false)
        .put("transport.type","netty3")
        .put("http.type", "netty3")
        .build();

  加红的两行:

     .put("transport.type","netty3")

     .put("http.type", "netty3")