Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-3277

Flume connect to ElasticSearch 6.4 failed after adding es jars into flume directory

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.8.0
    • 1.8.0
    • Sinks+Sources
    • None
    • Important

    Description

      I use released flume 1.8.0 with ElasticSearch 6.4.2, after adding elasticsearch-6.4.2.jar and Lucune-core.7.4.0.jar into the library of Flume (tries adding all the jar file into flume as well, got the same effect), The flume always throws exception like the stack trace below. Can I get some help from this forum about the error I encountered. 

      java.lang.NoClassDefFoundError: org/elasticsearch/common/io/BytesStream at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.flume.sink.elasticsearch.ElasticSearchSink.configure(ElasticSearchSink.java:288) at org.apache.flume.conf.Configurables.configure(Configurables.java:41) at org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:411) at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:102) at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:141) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748)Caused by: java.lang.ClassNotFoundException: org.elasticsearch.common.io.BytesStream at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

      Attachments

        Activity

          People

            Unassigned Unassigned
            liuzhe1218 Zhe Liu
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: