[
https://issues.apache.org/jira/browse/FLUME-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614385#comment-17614385
]
Ralph Goers commented on FLUME-3277:
------------------------------------
The Flume Elastticsearch sink was never upgraded to any reasonable version of
ES and is no longer supported.
> 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
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
