[
https://issues.apache.org/jira/browse/FLINK-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15195380#comment-15195380
]
Carlos Gonzalez de Zarate commented on FLINK-3608:
--------------------------------------------------
Hi Robert,
Thanks for your quick response.
I have installed the EL2 connector your referenced and works fine. Anyway, I'll
check periodically for the official EL 2 sink.
Regards,
Carlos
-----Mensaje original-----
De: Robert Metzger (JIRA) [mailto:[email protected]]
Enviado el: lunes, 14 de marzo de 2016 10:51
Para: Gonzalez De Zarate Alonso, Carlos
Asunto: [jira] [Commented] (FLINK-3608) ImmutableSettings error in
ElasticsearchSink
[
https://issues.apache.org/jira/browse/FLINK-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192997#comment-15192997
]
Robert Metzger commented on FLINK-3608:
---------------------------------------
Hi Carlos,
the issue is most likely that you are trying to use our elasticsearch code,
which has been implemented against EL 1.7.
There is the following JIRA: FLINK-3115 which will add support for EL 2 into
Flink.
We will soon add an EL 2 connector into Flink (most likely we'll start working
on it this week). In the meantime, check out this discussion on the mailing
list. A user implemented an EL 2 connector there:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/InetSocketAddress-is-not-serializable-when-building-ElasticSearch2-connector-td5296.html
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
________________________________
Carlos Gonzalez De Zarate Alonso
[email protected]
Tel. (+34) 945 017493
[https://posta.elkarlan.euskadi.eus/disclaimer/image001.gif]<http://www.euskadi.net/>
Mediterráneo, 14
01010 Vitoria-Gasteiz
Tel. (+34) 945 01 73 00*
Fax. (+34) 945 01 73 01
www.ejie.eus<http://www.ejie.eus/>
Legezko Oharra:
Mezu honek eta barnean izan ditzazkeen eranskinek, jabetzan edo legalki
babestua dagoen babespeko informazioa eduki dezakete. Mezuearren jasotzailea
izan ezean, igorleari jakinaraztea eta mezua berriz bidali eta gorde gabe
ezbatzea eskertuko genizuke, mezuaren baimenik gabeko erabilera legalki
debekatua bait dago.
Aviso legal:
Este mensaje incluyendo sus anexos pueden contener información confidencial, en
propiedad o legalmente protegida. Si usted no es el destinatario, le rogamos lo
comunique al remitente y proceda a borrarlo, sin reenviarlo ni conservarlo, ya
que su uso no autorizado está prohibido legalmente.
[https://posta.elkarlan.euskadi.eus/disclaimer/image002.gif]
Ez inprimatu mezu hau, behar-beharrezkoa ez bada. Paper-tona bat ekoizteko,
hamabost arbola mozten dira, eta 250.000 litro-ur kontsumitzen dira. Ingurumena
DENON ardura da.
No imprima este mensaje si no es realmente necesario. Una tonelada de papel
implica la tala de 15 árboles. y el consumo de 250.000 litros de agua. El Medio
Ambiente es cosa de TODOS
> ImmutableSettings error in ElasticsearchSink
> --------------------------------------------
>
> Key: FLINK-3608
> URL: https://issues.apache.org/jira/browse/FLINK-3608
> Project: Flink
> Issue Type: Bug
> Components: other
> Affects Versions: 0.10.1
> Reporter: Carlos Gonzalez de Zarate
> Labels: elasticsearch, features, sinks
>
> I'm trying to use ElasticsearchSink with Flink 0.10.2 and Elasticsearch
> 2.2.0, and I'm having the following error:
> java.lang.NoClassDefFoundError:
> org/elasticsearch/common/settings/ImmutableSettings
> at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink.open(ElasticsearchSink.java:177)
> at
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:89)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:286)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:213)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
> at java.lang.Thread.run(Thread.java:745)
> The problem seems to be the use of the class ImmutableSettings, that has been
> removed since Elastisearch 2.0. I imagine that with previous versions of
> Elasticsearch (i.e: 1.7.1) it will work correctly.
> Reference: https://github.com/elastic/elasticsearch/issues/13151
> Thanks in advanced,
> Carlos
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
