[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750331#comment-17750331 ] LEONID ILYEVSKY commented on FLINK-30998: - [~reta] [~martijnvisser]  Thanks for merging my PR.

[jira] [Commented] (FLINK-24736) Non vulenerable jar files for Apache Flink 1.14.4

[ https://issues.apache.org/jira/browse/FLINK-24736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749887#comment-17749887 ] LEONID ILYEVSKY commented on FLINK-24736: - Half a year later, in 1.18-SNAPSHOT, it is still the

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689390#comment-17689390 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] here is the new PR:

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689126#comment-17689126 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] Please let me know if you need me to fix

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688142#comment-17688142 ] Leonid Ilyevsky commented on FLINK-30998: - Hi [~reta] , > Sorry, I didn't get the context for

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687956#comment-17687956 ] Leonid Ilyevsky commented on FLINK-30998: - Hi [~reta] , Thanks for your help. The commit that

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687502#comment-17687502 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] here is my pull request:

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687343#comment-17687343 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] Thanks, please let me know how to submit my

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687111#comment-17687111 ] Leonid Ilyevsky commented on FLINK-30998: - This morning I successfully tested my solution. The

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686802#comment-17686802 ] Leonid Ilyevsky commented on FLINK-30998: - I actually looked at the code related to

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686787#comment-17686787 ] Leonid Ilyevsky commented on FLINK-30998: - I now found that previously the required

[jira] [Created] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

Leonid Ilyevsky created FLINK-30998: --- Summary: Add optional exception handler to flink-connector-opensearch Key: FLINK-30998 URL: https://issues.apache.org/jira/browse/FLINK-30998 Project: Flink

[jira] [Commented] (FLINK-24736) Non vulenerable jar files for Apache Flink 1.14.4

[ https://issues.apache.org/jira/browse/FLINK-24736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678399#comment-17678399 ] Leonid Ilyevsky commented on FLINK-24736: - The same problem in the latest version 1.16.0.  I

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477903#comment-17477903 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] So maybe the jobs that were not archived

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477868#comment-17477868 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] Yes, I found something interesting. This

[jira] [Updated] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-25581: Attachment: error.log > Jobmanager does not archive completed jobs >

[jira] [Comment Edited] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472825#comment-17472825 ] Leonid Ilyevsky edited comment on FLINK-25581 at 1/11/22, 3:36 PM: ---

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472825#comment-17472825 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] One more question: when the archiving is

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472761#comment-17472761 ] Leonid Ilyevsky commented on FLINK-25581: - I just would like to clarify. According to

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472187#comment-17472187 ] Leonid Ilyevsky commented on FLINK-25581: - Yes, I did. There were no errors. Also I saw it

[jira] [Created] (FLINK-25581) Jobmanager does not archive completed jobs

Leonid Ilyevsky created FLINK-25581: --- Summary: Jobmanager does not archive completed jobs Key: FLINK-25581 URL: https://issues.apache.org/jira/browse/FLINK-25581 Project: Flink Issue Type:

[jira] [Closed] (FLINK-23980) Jobmanager dies upon receiving REST API plan request

[ https://issues.apache.org/jira/browse/FLINK-23980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky closed FLINK-23980. --- Resolution: Not A Bug The jobmanager termination happened because client code called

[jira] [Commented] (FLINK-23980) Jobmanager dies upon receiving REST API plan request

[ https://issues.apache.org/jira/browse/FLINK-23980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405795#comment-17405795 ] Leonid Ilyevsky commented on FLINK-23980: - Thanks [~chesnay], I will test this and then close

[jira] [Commented] (FLINK-23980) Jobmanager dies upon receiving REST API plan request

[ https://issues.apache.org/jira/browse/FLINK-23980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405756#comment-17405756 ] Leonid Ilyevsky commented on FLINK-23980: - Thanks for asking about the exit call. I don't have

[jira] [Comment Edited] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405378#comment-17405378 ] Leonid Ilyevsky edited comment on FLINK-23952 at 8/26/21, 5:28 PM: ---

[jira] [Comment Edited] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405378#comment-17405378 ] Leonid Ilyevsky edited comment on FLINK-23952 at 8/26/21, 5:21 PM: ---

[jira] [Comment Edited] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405378#comment-17405378 ] Leonid Ilyevsky edited comment on FLINK-23952 at 8/26/21, 5:20 PM: ---

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405378#comment-17405378 ] Leonid Ilyevsky commented on FLINK-23952: - [~chesnay] Thanks for pointing this out. I added it

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405162#comment-17405162 ] Leonid Ilyevsky commented on FLINK-23952: - Thanks [~xtsong], I am going to try what I planned

[jira] [Commented] (FLINK-23980) Jobmanager dies upon receiving REST API plan request

[ https://issues.apache.org/jira/browse/FLINK-23980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405156#comment-17405156 ] Leonid Ilyevsky commented on FLINK-23980: - Sure, I just tried that, but nothing new there

[jira] [Comment Edited] (FLINK-23981) Delete file request returns an error even though the operation succeeded

[ https://issues.apache.org/jira/browse/FLINK-23981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405148#comment-17405148 ] Leonid Ilyevsky edited comment on FLINK-23981 at 8/26/21, 11:10 AM:

[jira] [Commented] (FLINK-23981) Delete file request returns an error even though the operation succeeded

[ https://issues.apache.org/jira/browse/FLINK-23981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405148#comment-17405148 ] Leonid Ilyevsky commented on FLINK-23981: - I am sure that the file actually gets deleted. I

[jira] [Created] (FLINK-23981) Delete file request returns an error even though the operation succeeded

Leonid Ilyevsky created FLINK-23981: --- Summary: Delete file request returns an error even though the operation succeeded Key: FLINK-23981 URL: https://issues.apache.org/jira/browse/FLINK-23981

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404748#comment-17404748 ] Leonid Ilyevsky commented on FLINK-23952: - [~chesnay] , I have some ideas about how I want to

[jira] [Created] (FLINK-23980) Jobmanager dies upon receiving REST API plan request

Leonid Ilyevsky created FLINK-23980: --- Summary: Jobmanager dies upon receiving REST API plan request Key: FLINK-23980 URL: https://issues.apache.org/jira/browse/FLINK-23980 Project: Flink

[jira] [Closed] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky closed FLINK-23952. --- Resolution: Not A Problem > Taskmanager fails to start complaining about missing

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404688#comment-17404688 ] Leonid Ilyevsky commented on FLINK-23952: - Thanks [~chesnay], this was helpful. > Taskmanager

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404589#comment-17404589 ] Leonid Ilyevsky commented on FLINK-23952: - After I set all those parameters in configuration

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404567#comment-17404567 ] Leonid Ilyevsky commented on FLINK-23952: - I think I know what is going on. When I started with

[jira] [Commented] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

[ https://issues.apache.org/jira/browse/FLINK-23952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404531#comment-17404531 ] Leonid Ilyevsky commented on FLINK-23952: - [~xtsong] I have my own python script to start the

[jira] [Created] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option

Leonid Ilyevsky created FLINK-23952: --- Summary: Taskmanager fails to start complaining about missing configuration option Key: FLINK-23952 URL: https://issues.apache.org/jira/browse/FLINK-23952

[jira] [Created] (FLINK-21385) AvroDeserializationSchema corrupted after getting invalid data

Leonid Ilyevsky created FLINK-21385: --- Summary: AvroDeserializationSchema corrupted after getting invalid data Key: FLINK-21385 URL: https://issues.apache.org/jira/browse/FLINK-21385 Project: Flink

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168050#comment-17168050 ] Leonid Ilyevsky commented on FLINK-18770: - Thanks [~aljoscha]. I actually did some debugging

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167957#comment-17167957 ] Leonid Ilyevsky commented on FLINK-18770: - [~aljoscha]  I fixed the build, and I see the same

[jira] [Updated] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18770: Attachment: FlinkTest.scala > Emitting element fails in KryoSerializer >

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167914#comment-17167914 ] Leonid Ilyevsky commented on FLINK-18770: - [~aljoscha] I see some problem in my project - by

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167889#comment-17167889 ] Leonid Ilyevsky commented on FLINK-18770: - Please see the main function of my app in

[jira] [Updated] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18770: Attachment: run_command.txt > Emitting element fails in KryoSerializer >

[jira] [Updated] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18770: Attachment: AppMain.java > Emitting element fails in KryoSerializer >

[jira] [Created] (FLINK-18770) Emitting element fails in KryoSerializer

Leonid Ilyevsky created FLINK-18770: --- Summary: Emitting element fails in KryoSerializer Key: FLINK-18770 URL: https://issues.apache.org/jira/browse/FLINK-18770 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167223#comment-17167223 ] Leonid Ilyevsky commented on FLINK-18733: - Thanks [~trohrmann]. It seems the

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166543#comment-17166543 ] Leonid Ilyevsky commented on FLINK-18733: - Problem solved. I noticed that your distribution

[jira] [Comment Edited] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166507#comment-17166507 ] Leonid Ilyevsky edited comment on FLINK-18733 at 7/28/20, 3:44 PM: ---

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166507#comment-17166507 ] Leonid Ilyevsky commented on FLINK-18733: - Till, Just now I found this: 

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166458#comment-17166458 ] Leonid Ilyevsky commented on FLINK-18733: - Hi [~trohrmann] The addresses I am using are

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165787#comment-17165787 ] Leonid Ilyevsky commented on FLINK-18733: - [~trohrmann] please see two logs from that run, and

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-liquidnt-taskexecutor-0-nj1dvloglab01.liquidnet.biz.log > Jobmanager

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-liquidnt-standalonesession-0-nj1dvloglab01.liquidnet.biz.log >

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-conf.yaml > Jobmanager cannot start in HA mode with Zookeeper >

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Description: When configured in HA mode, the Jobmanager cannot start at all. First, it

[jira] [Created] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

Leonid Ilyevsky created FLINK-18733: --- Summary: Jobmanager cannot start in HA mode with Zookeeper Key: FLINK-18733 URL: https://issues.apache.org/jira/browse/FLINK-18733 Project: Flink

[jira] [Commented] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails

[ https://issues.apache.org/jira/browse/FLINK-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071367#comment-17071367 ] Leonid Ilyevsky commented on FLINK-16728: - Hi [~zhuzh], thanks for the explanation. Of course,

[jira] [Updated] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails

[ https://issues.apache.org/jira/browse/FLINK-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-16728: Description: At some point I noticed that a few jobs got stuck (they basically stopped

[jira] [Created] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails

Leonid Ilyevsky created FLINK-16728: --- Summary: Taskmanager dies after job got stuck and canceling fails Key: FLINK-16728 URL: https://issues.apache.org/jira/browse/FLINK-16728 Project: Flink

[jira] [Commented] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-12548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041991#comment-17041991 ] Leonid Ilyevsky commented on FLINK-12548: - [~sjwiesman] Seth,  Yes, I meant multiple slots.

[jira] [Commented] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-12548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041134#comment-17041134 ] Leonid Ilyevsky commented on FLINK-12548: - Now testing with Flink version 1.10.0. The "Error

[jira] [Closed] (FLINK-15976) Build snapshots for Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-15976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky closed FLINK-15976. --- Release Note: Release 1.10.0 is out, so this issue is irrelevant now. Resolution:

[jira] [Created] (FLINK-15976) Build snapshots for Scala 2.12

Leonid Ilyevsky created FLINK-15976: --- Summary: Build snapshots for Scala 2.12 Key: FLINK-15976 URL: https://issues.apache.org/jira/browse/FLINK-15976 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15410) Solace JCSMP connectors

Leonid Ilyevsky created FLINK-15410: --- Summary: Solace JCSMP connectors Key: FLINK-15410 URL: https://issues.apache.org/jira/browse/FLINK-15410 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957049#comment-16957049 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks everybody. When can we see this artifact in

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937789#comment-16937789 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] The test looks good. When do you think we

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936895#comment-16936895 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I actually tried Flink 1.9.0 with ES

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936083#comment-16936083 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks [~yanghua]. I could not download the file (did

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933794#comment-16933794 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I saw you wrote the code and created a

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928593#comment-16928593 ] Leonid Ilyevsky commented on FLINK-13025: - [~StephanEwen] sure, will do. > Elasticsearch 7.x

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928149#comment-16928149 ] Leonid Ilyevsky commented on FLINK-13025: - [~aljoscha] I doubt that you can create one "modern"

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923467#comment-16923467 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] It would be great if you could do it soon,

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922836#comment-16922836 ] Leonid Ilyevsky commented on FLINK-13025: - I just confirmed that using elasticsearch6 connector

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921420#comment-16921420 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I believe [~limbo] is using elasticsearch6

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16918045#comment-16918045 ] Leonid Ilyevsky commented on FLINK-13025: - We certainly need a new connector for Elasticsearch

[jira] [Closed] (FLINK-13886) Need to develop flink-connector-elasticsearch7

[ https://issues.apache.org/jira/browse/FLINK-13886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky closed FLINK-13886. --- Release Note: See https://issues.apache.org/jira/browse/FLINK-13025 Resolution:

[jira] [Updated] (FLINK-13886) Need to develop flink-connector-elasticsearch7

[ https://issues.apache.org/jira/browse/FLINK-13886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-13886: Affects Version/s: 1.8.0 1.8.1 > Need to develop

[jira] [Updated] (FLINK-13886) Need to develop flink-connector-elasticsearch7

[ https://issues.apache.org/jira/browse/FLINK-13886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-13886: Component/s: Connectors / ElasticSearch Affects Version/s: 1.9.0 > Need to

[jira] [Created] (FLINK-13886) Need to develop flink-connector-elasticsearch7

Leonid Ilyevsky created FLINK-13886: --- Summary: Need to develop flink-connector-elasticsearch7 Key: FLINK-13886 URL: https://issues.apache.org/jira/browse/FLINK-13886 Project: Flink Issue

[jira] [Created] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer

Leonid Ilyevsky created FLINK-12548: --- Summary: FlinkKafkaConsumer issues configuring underlying KafkaConsumer Key: FLINK-12548 URL: https://issues.apache.org/jira/browse/FLINK-12548 Project: Flink