[jira] [Updated] (FLINK-28933) Support ON CONFLICT DO NOTHING in flink-jdbc-connector for Postgresql dialect

2022-08-11 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nir Tsruya updated FLINK-28933: --- Summary: Support ON CONFLICT DO NOTHING in flink-jdbc-connector for Postgresql dialect (was:

[jira] [Created] (FLINK-28933) Support ON CONFLICT DO NOTHING in flink-jdbc-connector

2022-08-11 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-28933: -- Summary: Support ON CONFLICT DO NOTHING in flink-jdbc-connector Key: FLINK-28933 URL: https://issues.apache.org/jira/browse/FLINK-28933 Project: Flink Issue

[jira] [Created] (FLINK-28933) Support ON CONFLICT DO NOTHING in flink-jdbc-connector

2022-08-11 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-28933: -- Summary: Support ON CONFLICT DO NOTHING in flink-jdbc-connector Key: FLINK-28933 URL: https://issues.apache.org/jira/browse/FLINK-28933 Project: Flink Issue

[jira] [Comment Edited] (FLINK-24477) Add MongoDB sink

2022-05-25 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542039#comment-17542039 ] Nir Tsruya edited comment on FLINK-24477 at 5/25/22 1:03 PM: - Thanks!

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2022-05-25 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542039#comment-17542039 ] Nir Tsruya commented on FLINK-24477: Thanks! > Add MongoDB sink > > >

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2022-05-07 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533328#comment-17533328 ] Nir Tsruya commented on FLINK-24477: Sorry [~martijnvisser] was finalizing the work for the dynamodb

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2022-05-05 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532209#comment-17532209 ] Nir Tsruya commented on FLINK-24477: [~martijnvisser] what is the process for creating this

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2022-05-04 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531708#comment-17531708 ] Nir Tsruya commented on FLINK-24477: Hey [~martijnvisser] I am very interested in working on that, I

[jira] [Commented] (FLINK-25965) Add a Couchbase sink

2022-02-07 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488104#comment-17488104 ] Nir Tsruya commented on FLINK-25965: I see, thank you very much for the heads up [~MartijnVisser] .

[jira] [Commented] (FLINK-25965) Add a Couchbase sink

2022-02-07 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488045#comment-17488045 ] Nir Tsruya commented on FLINK-25965: Thanks [~MartijnVisser] , I see. Does it mean that in order to

[jira] [Created] (FLINK-25965) Add a Couchbase sink

2022-02-06 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-25965: -- Summary: Add a Couchbase sink Key: FLINK-25965 URL: https://issues.apache.org/jira/browse/FLINK-25965 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25965) Add a Couchbase sink

2022-02-06 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-25965: -- Summary: Add a Couchbase sink Key: FLINK-25965 URL: https://issues.apache.org/jira/browse/FLINK-25965 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2022-02-06 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487689#comment-17487689 ] Nir Tsruya commented on FLINK-24477: [~MartijnVisser] sure. [~RocMarshal] I think that the first

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-01-23 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480586#comment-17480586 ] Nir Tsruya commented on FLINK-24229: Hey [~CrynetLogistics] , I created a pull request for the fatal

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-20 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479383#comment-17479383 ] Nir Tsruya commented on FLINK-25661: Hey [~dannycranmer] [~fpaul] sorry for ping. PR is ready, would

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-18 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478201#comment-17478201 ] Nir Tsruya commented on FLINK-25661: [~dannycranmer] yes thanks > Add Custom Fatal Exception

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-17 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477207#comment-17477207 ] Nir Tsruya commented on FLINK-25661: Hey [~fpaul] thanks [~CrynetLogistics] is already involved in

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-01-16 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476760#comment-17476760 ] Nir Tsruya commented on FLINK-24229: [~CrynetLogistics] I created this Jira

[jira] [Created] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-16 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-25661: -- Summary: Add Custom Fatal Exception handler in AsyncSinkWriter Key: FLINK-25661 URL: https://issues.apache.org/jira/browse/FLINK-25661 Project: Flink Issue

[jira] [Created] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-16 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-25661: -- Summary: Add Custom Fatal Exception handler in AsyncSinkWriter Key: FLINK-25661 URL: https://issues.apache.org/jira/browse/FLINK-25661 Project: Flink Issue

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-01-14 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476067#comment-17476067 ] Nir Tsruya commented on FLINK-24229: [~CrynetLogistics] the AsyncSinkWriter is already being used by

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2021-11-12 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442712#comment-17442712 ] Nir Tsruya commented on FLINK-24229: hey [~CrynetLogistics]  We are working on the AsyncSinkWriter

[jira] [Commented] (FLINK-24477) Add MongoDB sink

2021-10-08 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426013#comment-17426013 ] Nir Tsruya commented on FLINK-24477: Hey [~fabian.paul] thanks, yes! I would like to work on that :)

[jira] [Created] (FLINK-24477) Add MongoDB sink

2021-10-07 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-24477: -- Summary: Add MongoDB sink Key: FLINK-24477 URL: https://issues.apache.org/jira/browse/FLINK-24477 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-24477) Add MongoDB sink

2021-10-07 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-24477: -- Summary: Add MongoDB sink Key: FLINK-24477 URL: https://issues.apache.org/jira/browse/FLINK-24477 Project: Flink Issue Type: New Feature Components: