[ 
https://issues.apache.org/jira/browse/FLUME-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Zhe Liu updated FLUME-3277:
---------------------------
    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. 
{code:java}
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){code}

  was:
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. 
{code:java}
//代码占位符
{code}
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)
{code:java}
//代码占位符
{code}


> Flume connect to ElasticSearch 6.4 failed after adding es jars into flume 
> directory
> -----------------------------------------------------------------------------------
>
>                 Key: FLUME-3277
>                 URL: https://issues.apache.org/jira/browse/FLUME-3277
>             Project: Flume
>          Issue Type: Bug
>          Components: Sinks+Sources
>    Affects Versions: 1.8.0
>            Reporter: Zhe Liu
>            Priority: Major
>             Fix For: 1.8.0
>
>
> 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. 
> {code:java}
> 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){code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to