[jira] [Commented] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception

2018-09-04 Thread ting (JIRA) 


[ 
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16603872#comment-16603872
 ] 

ting commented on FLINK-10271:
--

It is duplicate of FLINK-10269.  I solve it via FLINK-10269.

> flink-connector-elasticsearch6_2.11 have exception
> --
>
> Key: FLINK-10271
> URL: https://issues.apache.org/jira/browse/FLINK-10271
> Project: Flink
>  Issue Type: Bug
>  Components: ElasticSearch Connector
>Affects Versions: 1.6.0
> Environment: LocalStreamEnvironment
>Reporter: ting
>Priority: Major
>   Original Estimate: 4h
>  Remaining Estimate: 4h
>
> org.apache.flink.runtime.client.JobExecutionException: 
> TimerException\{java.lang.NoSuchMethodError: 
> org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;}



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

[jira] [Commented] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception

2018-08-31 Thread Timo Walther (JIRA) 


[ 
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598567#comment-16598567
 ] 

Timo Walther commented on FLINK-10271:
--

[~TommyYang] please post the entire stack trace and some more information to 
reproduce this exception.

> flink-connector-elasticsearch6_2.11 have exception
> --
>
> Key: FLINK-10271
> URL: https://issues.apache.org/jira/browse/FLINK-10271
> Project: Flink
>  Issue Type: Bug
>  Components: ElasticSearch Connector
>Affects Versions: 1.6.0
> Environment: LocalStreamEnvironment
>Reporter: ting
>Priority: Major
>   Original Estimate: 4h
>  Remaining Estimate: 4h
>
> org.apache.flink.runtime.client.JobExecutionException: 
> TimerException\{java.lang.NoSuchMethodError: 
> org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;}



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

[jira] [Commented] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception

2018-08-31 Thread Timo Walther (JIRA) 


[ 
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598565#comment-16598565
 ] 

Timo Walther commented on FLINK-10271:
--

No it doesn't look like a duplicate. It is a different exception. But maybe 
also related to our current packaging.

> flink-connector-elasticsearch6_2.11 have exception
> --
>
> Key: FLINK-10271
> URL: https://issues.apache.org/jira/browse/FLINK-10271
> Project: Flink
>  Issue Type: Bug
>  Components: ElasticSearch Connector
>Affects Versions: 1.6.0
> Environment: LocalStreamEnvironment
>Reporter: ting
>Priority: Major
>   Original Estimate: 4h
>  Remaining Estimate: 4h
>
> org.apache.flink.runtime.client.JobExecutionException: 
> TimerException\{java.lang.NoSuchMethodError: 
> org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;}



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

[jira] [Commented] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception

2018-08-31 Thread ting (JIRA) 


[ 
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598539#comment-16598539
 ] 

ting commented on FLINK-10271:
--

The problem is different is with FLINK-10269， I don't see 
org.apache.flink.streaming.connectors.elasticsearch.BulkProcessorIndexer  in 
the flink project.

> flink-connector-elasticsearch6_2.11 have exception
> --
>
> Key: FLINK-10271
> URL: https://issues.apache.org/jira/browse/FLINK-10271
> Project: Flink
>  Issue Type: Bug
>  Components: ElasticSearch Connector
>Affects Versions: 1.6.0
> Environment: LocalStreamEnvironment
>Reporter: ting
>Priority: Major
>   Original Estimate: 4h
>  Remaining Estimate: 4h
>
> org.apache.flink.runtime.client.JobExecutionException: 
> TimerException\{java.lang.NoSuchMethodError: 
> org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;}



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

[jira] [Commented] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception

2018-08-31 Thread Dawid Wysakowicz (JIRA) 


[ 
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16598510#comment-16598510
 ] 

Dawid Wysakowicz commented on FLINK-10271:
--

This is probably duplicate of [FLINK-10269].

> flink-connector-elasticsearch6_2.11 have exception
> --
>
> Key: FLINK-10271
> URL: https://issues.apache.org/jira/browse/FLINK-10271
> Project: Flink
>  Issue Type: Bug
>  Components: ElasticSearch Connector
>Affects Versions: 1.6.0
> Environment: LocalStreamEnvironment
>Reporter: ting
>Priority: Major
>   Original Estimate: 4h
>  Remaining Estimate: 4h
>
> org.apache.flink.runtime.client.JobExecutionException: 
> TimerException\{java.lang.NoSuchMethodError: 
> org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;}



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