flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Carlos Gonzalez de Zarate (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3608) ImmutableSettings error in ElasticsearchSink
Date Tue, 15 Mar 2016 14:33:33 GMT

    [ 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:jira@apache.org]
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
carlos-gonzalez@ejie.eus
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)

Mime
View raw message