[
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:
[
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
[
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
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:
[
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
[
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
[
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
>
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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:
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:
[
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
[
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
[
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
>
[
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
>
[
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
[
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
>
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
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
23 matches
Mail list logo