I can't work wtih elasticsearch2.3.3

[lovewanli]

24 Jun 2016 16:36:16,138 ERROR lifecycleSupervisor-1-1 - Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@161dbb35 counterGroup:{ name:null counters:{} } } - Exception follows. java.lang.IncompatibleClassChangeError: Found interface org.elasticsearch.common.settings.Settings, but class was expected at com.frontier45.flume.sink.elasticsearch2.client.ElasticSearchTransportClient.openClient(ElasticSearchTransportClient.java:195) at com.frontier45.flume.sink.elasticsearch2.client.ElasticSearchTransportClient.(ElasticSearchTransportClient.java:68) at com.frontier45.flume.sink.elasticsearch2.client.ElasticSearchClientFactory.getClient(ElasticSearchClientFactory.java:43) at com.frontier45.flume.sink.elasticsearch2.ElasticSearchSink.start(ElasticSearchSink.java:339) at org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46) at org.apache.flume.SinkRunner.start(SinkRunner.java:79) at org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:722) 24 Jun 2016 16:36:16,142 INFO lifecycleSupervisor-1-1 - ElasticSearch sink {} stopping

I got this error,

a1.sinks = k1 a1.sinks.k1.type = com.frontier45.flume.sink.elasticsearch2.ElasticSearchSink a1.sinks.k1.hostNames = 10.182.139.227:9300 a1.sinks.k1.indexName = cpic_log a1.sinks.k1.indexType = flume_kafka a1.sinks.k1.clusterName = logCollection a1.sinks.k1.batchSize = 4000 a1.sinks.k1.serializer = com.frontier45.flume.sink.elasticsearch2.ElasticSearchDynamicSerializer a1.sinks.k1.channel = c1

this my conf

any idea why i got error ? thank you.