[jira] [Assigned] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess

[ https://issues.apache.org/jira/browse/FLINK-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-5080: - Assignee: Aleksandr Salatich > Cassandra connector ignores saveAsync result

[jira] [Assigned] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-11747: -- Assignee: Aleksandr Salatich > Elasticsearch 6 connector - Expose

[jira] [Commented] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778147#comment-16778147 ] Aleksandr Salatich commented on FLINK-11747: [~yosami] you can get RestHighLevelClient

[jira] [Assigned] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-6227: - Assignee: (was: Aleksandr Salatich) > Introduce the

[jira] [Commented] (FLINK-11393) Activate default shuffle implementation and remove legacy code

[ https://issues.apache.org/jira/browse/FLINK-11393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1653#comment-1653 ] Aleksandr Salatich commented on FLINK-11393: [~zjwang] Do you mind if I try? It seems not so

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777098#comment-16777098 ] Aleksandr Salatich commented on FLINK-6227: --- Yes, it's really pretty hard to understand what is

[jira] [Assigned] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-6227: - Assignee: Aleksandr Salatich > Introduce the DataConsumptionException for

[jira] [Assigned] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

[ https://issues.apache.org/jira/browse/FLINK-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich reassigned FLINK-9685: - Assignee: Aleksandr Salatich > Flink should support hostname-substitution for

[jira] [Updated] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

[ https://issues.apache.org/jira/browse/FLINK-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Salatich updated FLINK-9685: -- Labels: pull-request-available (was: ) > Flink should support hostname-substitution

[jira] [Commented] (FLINK-11320) Support user callback in Kafka sink

[ https://issues.apache.org/jira/browse/FLINK-11320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772020#comment-16772020 ] Aleksandr Salatich commented on FLINK-11320: [~allenxwang] is it actual task? Is it OK for

[jira] [Comment Edited] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771865#comment-16771865 ] Aleksandr Salatich edited comment on FLINK-6227 at 2/19/19 12:15 PM: -

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771865#comment-16771865 ] Aleksandr Salatich commented on FLINK-6227: --- [~zjwang] yes, I would like to try, but i don't

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771145#comment-16771145 ] Aleksandr Salatich commented on FLINK-11632: [~1u0] is it just proposal or i can take this

[jira] [Comment Edited] (FLINK-9165) Improve CassandraSinkBase to send Collections

[ https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769268#comment-16769268 ] Aleksandr Salatich edited comment on FLINK-9165 at 2/15/19 12:45 PM: -

[jira] [Commented] (FLINK-9165) Improve CassandraSinkBase to send Collections

[ https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769268#comment-16769268 ] Aleksandr Salatich commented on FLINK-9165: --- [~Bekreth] [~Zentol] is this task relevant? >

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769238#comment-16769238 ] Aleksandr Salatich commented on FLINK-6227: --- [~zjwang] hi, are you working on it? > Introduce