[jira] [Comment Edited] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2020-06-03 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125396#comment-17125396 ] Bhagavan edited comment on FLINK-17969 at 6/3/20, 11:32 PM: PR:

[jira] [Commented] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2020-06-03 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125396#comment-17125396 ] Bhagavan commented on FLINK-17969: -- PR: https://github.com/apache/flink/pull/12472 > Enhance Flink

[jira] [Updated] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2020-05-27 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-17969: - Description: Problem statement: We use a shared session cluster (Standalone/Yarn) to execute jobs. All

[jira] [Created] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2020-05-27 Thread Bhagavan (Jira)
Bhagavan created FLINK-17969: Summary: Enhance Flink (Task) logging to include job name as context diagnostic information Key: FLINK-17969 URL: https://issues.apache.org/jira/browse/FLINK-17969 Project:

[jira] [Commented] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

2020-05-13 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106297#comment-17106297 ] Bhagavan commented on FLINK-17464: -- Maybe we need configuration parameter for standalone session

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-22 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021482#comment-17021482 ] Bhagavan commented on FLINK-15728: -- Also, I have found how to achieve upsert in Oracle and H2. I can

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-22 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021232#comment-17021232 ] Bhagavan commented on FLINK-15728: -- Raised PR https://github.com/apache/flink/pull/10926 >

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-22 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020991#comment-17020991 ] Bhagavan commented on FLINK-15728: -- Sorry, should have added more context. Added, H2Dialect as below

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020494#comment-17020494 ] Bhagavan commented on FLINK-15728: -- + added [~jark] as original work was reviewed  >

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15728: - Description: When using JDBCUpsertOutputFormat custom dialect e.g. H2/Oracle which uses 

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15728: - Description: When using JDBCUpsertOutputFormat custom dialect e.g. H2/Oracle which uses 

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15728: - Description: When using JDBCUpsertOutputFormat custom dialect e.g. H2/Oracle which uses 

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15728: - Description: When using JDBCUpsertOutputFormat custom dialect e.g. H2/Oracle which uses 

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

2020-01-21 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15728: - Summary: JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement (was:

[jira] [Created] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStaement

2020-01-21 Thread Bhagavan (Jira)
Bhagavan created FLINK-15728: Summary: JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStaement Key: FLINK-15728 URL: https://issues.apache.org/jira/browse/FLINK-15728 Project:

[jira] [Commented] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA

2020-01-07 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010030#comment-17010030 ] Bhagavan commented on FLINK-15174: -- The proposed setup is as you have noted. * KeyStore = specific

[jira] [Updated] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA

2019-12-10 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-15174: - Priority: Blocker (was: Major) > FLINK security using PKI mutual auth needs certificate pinning or

[jira] [Updated] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

2019-12-10 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-14170: - Priority: Major (was: Blocker) > Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder >

[jira] [Updated] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

2019-12-10 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagavan updated FLINK-14170: - Priority: Blocker (was: Major) > Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder >

[jira] [Comment Edited] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

2019-12-10 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992443#comment-16992443 ] Bhagavan edited comment on FLINK-14170 at 12/10/19 11:10 AM: - [~aljoscha] I

[jira] [Commented] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

2019-12-10 Thread Bhagavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992443#comment-16992443 ] Bhagavan commented on FLINK-14170: -- [~aljoscha] I have a PR for this please assign this ticket to me >

[jira] [Created] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA

2019-12-10 Thread Bhagavan (Jira)
Bhagavan created FLINK-15174: Summary: FLINK security using PKI mutual auth needs certificate pinning or Private CA Key: FLINK-15174 URL: https://issues.apache.org/jira/browse/FLINK-15174 Project: Flink

[jira] [Created] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

2019-09-23 Thread Bhagavan (Jira)
Bhagavan created FLINK-14170: Summary: Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder Key: FLINK-14170 URL: https://issues.apache.org/jira/browse/FLINK-14170 Project: Flink Issue