[jira] [Commented] (FLINK-36922) Add warning when creating KryoSerializer for generic type

[ https://issues.apache.org/jira/browse/FLINK-36922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909318#comment-17909318 ] LEONID ILYEVSKY commented on FLINK-36922: - [~zhiyuan6] Thanks, I think you can s

[jira] [Created] (FLINK-36922) Add warning when creating KryoSerializer for generic type

LEONID ILYEVSKY created FLINK-36922: --- Summary: Add warning when creating KryoSerializer for generic type Key: FLINK-36922 URL: https://issues.apache.org/jira/browse/FLINK-36922 Project: Flink

[jira] [Created] (FLINK-36532) Kafka group offsets are not committed on stop with savepoint

LEONID ILYEVSKY created FLINK-36532: --- Summary: Kafka group offsets are not committed on stop with savepoint Key: FLINK-36532 URL: https://issues.apache.org/jira/browse/FLINK-36532 Project: Flink

[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&focusedCommentId=17750331#comment-17750331 ] LEONID ILYEVSKY commented on FLINK-30998: - [~reta] [~martijnvisser]  Thanks for

[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&focusedCommentId=17749887#comment-17749887 ] LEONID ILYEVSKY commented on FLINK-24736: - Half a year later, in 1.18-SNAPSHOT,

[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&focusedCommentId=17689390#comment-17689390 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] here is the new PR: [https:/

[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&focusedCommentId=17689126#comment-17689126 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] Please let me know if you nee

[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&focusedCommentId=17688142#comment-17688142 ] Leonid Ilyevsky commented on FLINK-30998: - Hi [~reta] , > Sorry, I didn't get t

[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&focusedCommentId=17687956#comment-17687956 ] Leonid Ilyevsky commented on FLINK-30998: - Hi [~reta] , Thanks for your help.

[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&focusedCommentId=17687502#comment-17687502 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] here is my pull request: [ht

[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&focusedCommentId=17687343#comment-17687343 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] Thanks, please let me know ho

[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&focusedCommentId=17687111#comment-17687111 ] Leonid Ilyevsky commented on FLINK-30998: - This morning I successfully tested 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&focusedCommentId=17686802#comment-17686802 ] Leonid Ilyevsky commented on FLINK-30998: - I actually looked at the code related

[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&focusedCommentId=17686787#comment-17686787 ] Leonid Ilyevsky commented on FLINK-30998: - I now found that previously the requi

[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&focusedCommentId=17678399#comment-17678399 ] Leonid Ilyevsky commented on FLINK-24736: - The same problem in the latest versio

[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&focusedCommentId=17477903#comment-17477903 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] So maybe the jobs that wer

[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&focusedCommentId=17477868#comment-17477868 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] Yes, I found something int

[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&focusedCommentId=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&focusedCommentId=17472825#comment-17472825 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] One more question: when th

[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&focusedCommentId=17472761#comment-17472761 ] Leonid Ilyevsky commented on FLINK-25581: - I just would like to clarify. Accordi

[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&focusedCommentId=17472187#comment-17472187 ] Leonid Ilyevsky commented on FLINK-25581: - Yes, I did. There were no errors. Als

[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 System.

[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&focusedCommentId=17405795#comment-17405795 ] Leonid Ilyevsky commented on FLINK-23980: - Thanks [~chesnay], I will test this a

[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&focusedCommentId=17405756#comment-17405756 ] Leonid Ilyevsky commented on FLINK-23980: - Thanks for asking about the exit call

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17405378#comment-17405378 ] Leonid Ilyevsky commented on FLINK-23952: - [~chesnay] Thanks for pointing this o

[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&focusedCommentId=17405162#comment-17405162 ] Leonid Ilyevsky commented on FLINK-23952: - Thanks [~xtsong], I am going to try w

[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&focusedCommentId=17405156#comment-17405156 ] Leonid Ilyevsky commented on FLINK-23980: - Sure, I just tried that, but nothing

[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&focusedCommentId=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&focusedCommentId=17405148#comment-17405148 ] Leonid Ilyevsky commented on FLINK-23981: - I am sure that the file actually gets

[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 Projec

[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&focusedCommentId=17404748#comment-17404748 ] Leonid Ilyevsky commented on FLINK-23952: - [~chesnay] , I have some ideas about

[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 Is

[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 configurati

[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&focusedCommentId=17404688#comment-17404688 ] Leonid Ilyevsky commented on FLINK-23952: - Thanks [~chesnay], this was helpful.

[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&focusedCommentId=17404589#comment-17404589 ] Leonid Ilyevsky commented on FLINK-23952: - After I set all those parameters in c

[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&focusedCommentId=17404567#comment-17404567 ] Leonid Ilyevsky commented on FLINK-23952: - I think I know what is going on. When

[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&focusedCommentId=17404531#comment-17404531 ] Leonid Ilyevsky commented on FLINK-23952: - [~xtsong] I have my own python script

[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 Proje

[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&focusedCommentId=17168050#comment-17168050 ] Leonid Ilyevsky commented on FLINK-18770: - Thanks [~aljoscha]. I actually did s

[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&focusedCommentId=17167957#comment-17167957 ] Leonid Ilyevsky commented on FLINK-18770: - [~aljoscha]  I fixed the build, and

[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&focusedCommentId=17167914#comment-17167914 ] Leonid Ilyevsky commented on FLINK-18770: - [~aljoscha] I see some problem in my

[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&focusedCommentId=17167889#comment-17167889 ] Leonid Ilyevsky commented on FLINK-18770: - Please see the main function of my ap

[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: Bu

[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&focusedCommentId=17167223#comment-17167223 ] Leonid Ilyevsky commented on FLINK-18733: - Thanks [~trohrmann]. It seems the ht

[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&focusedCommentId=17166543#comment-17166543 ] Leonid Ilyevsky commented on FLINK-18733: - Problem solved. I noticed that your d

[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&focusedCommentId=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&focusedCommentId=17166507#comment-17166507 ] Leonid Ilyevsky commented on FLINK-18733: - Till, Just now I found this: https:/

[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&focusedCommentId=17166458#comment-17166458 ] Leonid Ilyevsky commented on FLINK-18733: - Hi [~trohrmann] The addresses I am u

[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&focusedCommentId=17165787#comment-17165787 ] Leonid Ilyevsky commented on FLINK-18733: - [~trohrmann] please see two logs from

[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 can

[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 > Jobmanag

[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 is

[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 Issue

[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&focusedCommentId=17071367#comment-17071367 ] Leonid Ilyevsky commented on FLINK-16728: - Hi [~zhuzh], thanks for the explanati

[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 pr

[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&focusedCommentId=17041991#comment-17041991 ] Leonid Ilyevsky commented on FLINK-12548: - [~sjwiesman] Seth,  Yes, I meant mul

[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&focusedCommentId=17041134#comment-17041134 ] Leonid Ilyevsky commented on FLINK-12548: - Now testing with Flink version 1.10.0

[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: Won't

[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&focusedCommentId=16957049#comment-16957049 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks everybody. When can we see thi

[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&focusedCommentId=16937789#comment-16937789 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] The test looks good. When

[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&focusedCommentId=16936895#comment-16936895 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I actually tried Flink 1.9

[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&focusedCommentId=16936083#comment-16936083 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks [~yanghua]. I could not downlo

[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&focusedCommentId=16933794#comment-16933794 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I saw you wrote the code 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&focusedCommentId=16928593#comment-16928593 ] Leonid Ilyevsky commented on FLINK-13025: - [~StephanEwen] sure, will do. > Elas

[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&focusedCommentId=16928149#comment-16928149 ] Leonid Ilyevsky commented on FLINK-13025: - [~aljoscha] I doubt that you can crea

[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&focusedCommentId=16923467#comment-16923467 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] It would be great if you c

[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&focusedCommentId=16922836#comment-16922836 ] Leonid Ilyevsky commented on FLINK-13025: - I just confirmed that using elasticse

[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&focusedCommentId=16921420#comment-16921420 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I believe [~limbo] is usin

[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&focusedCommentId=16918045#comment-16918045 ] Leonid Ilyevsky commented on FLINK-13025: - We certainly need a new connector for

[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: Dupli

[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 flink-connector-el

[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 devel

[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 Ty

[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