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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444781#comment-17444781 ] John Lonergan commented on FLINK-17464: --- Sorry my error. How do I stop getting no

[jira] [Closed] (FLINK-14088) Couchbase connector - sink with checkpointing support

[ https://issues.apache.org/jira/browse/FLINK-14088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-14088. - Resolution: Abandoned > Couchbase connector - sink with checkpointing support >

[jira] [Closed] (FLINK-14238) ParquetPojoInputFormat logging bug

[ https://issues.apache.org/jira/browse/FLINK-14238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-14238. - Resolution: Abandoned > ParquetPojoInputFormat logging bug > --

[jira] [Closed] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-13588. - > StreamTask.handleAsyncException throws away the exception cause >

[jira] [Closed] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method

[ https://issues.apache.org/jira/browse/FLINK-16920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-16920. - Resolution: Abandoned > Flink UI cancel uses an undocumented rest api and uses GET rather than a

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-17464. - Resolution: Abandoned > Stanalone HA Cluster crash with non-recoverable cluster state - need to

[jira] [Closed] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-17469. - Resolution: Abandoned > Support override of DEFAULT_JOB_NAME with system property for > StreamE

[jira] [Closed] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-17545. - Resolution: Abandoned > Resource leak JDBCUpsertOutputFormat > -

[jira] [Closed] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-17723. - Resolution: Abandoned > Written design for flink threading model and guarantees made to the vari

[jira] [Closed] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan closed FLINK-14174. - Resolution: Abandoned > Don't swallow exception when rethrowing type mismatches with side output

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330875#comment-17330875 ] John Lonergan commented on FLINK-17464: --- As far as I know this is still a critical

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

[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117724#comment-17117724 ] John Lonergan commented on FLINK-17969: --- +1 Really please to see this - I asked a

[jira] [Commented] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108440#comment-17108440 ] John Lonergan commented on FLINK-17545: --- (Yeah - I know there's quite a few places

[jira] [Updated] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17723: -- Description: I enjoy using Flink but ... Do we have a written design for the threading model

[jira] [Updated] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17723: -- Description: I enjoy using Flink but ... Do we have a written design for the threading model

[jira] [Updated] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17723: -- Description: Do we have a written design for the threading model including the guarantees mad

[jira] [Updated] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17723: -- Description: Do we have a written design for the threading model including the guarantees mad

[jira] [Created] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

John Lonergan created FLINK-17723: - Summary: Written design for flink threading model and guarantees made to the various structual components Key: FLINK-17723 URL: https://issues.apache.org/jira/browse/FLINK-17723

[jira] [Commented] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107760#comment-17107760 ] John Lonergan commented on FLINK-17544: --- Off which branch. BTW Theres a load of ot

[jira] [Commented] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107578#comment-17107578 ] John Lonergan commented on FLINK-17545: --- Been hit by further failures due to this

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106292#comment-17106292 ] John Lonergan commented on FLINK-17464: --- Hi folk - what are our options to make th

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:42 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:39 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:38 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:37 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:35 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:35 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:34 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:34 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:32 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:29 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:26 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:25 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:23 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:17 PM:

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan commented on FLINK-17469: --- What I'm really after is to be able to pr

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101132#comment-17101132 ] John Lonergan commented on FLINK-17464: --- I meant arch because this problem wouldn'

[jira] [Updated] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17544: -- Description: Encountered a situation where I get an NPE from JDBCUpsertOutputFormat. This occ

[jira] [Updated] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17545: -- Description: See also Flink-17544 for background to this scenario. Synchronisation in JDBCUps

[jira] [Updated] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17545: -- Description: See also FLINK-17544 for background to this scenario. Synchronisation in JDBCUps

[jira] [Updated] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17545: -- Description: See also A related observation is synchronisation in JDBCUpsertOutputFormat and

[jira] [Updated] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17545: -- Summary: Resource leak JDBCUpsertOutputFormat (was: CLONE - NPE JDBCUpsertOutputFormat) > Re

[jira] [Created] (FLINK-17545) CLONE - NPE JDBCUpsertOutputFormat

John Lonergan created FLINK-17545: - Summary: CLONE - NPE JDBCUpsertOutputFormat Key: FLINK-17545 URL: https://issues.apache.org/jira/browse/FLINK-17545 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17544: -- Description: Encountered a situation where I get an NPE from JDBCUpsertOutputFormat. This occ

[jira] [Created] (FLINK-17544) NPE JDBCUpsertOutputFormat

John Lonergan created FLINK-17544: - Summary: NPE JDBCUpsertOutputFormat Key: FLINK-17544 URL: https://issues.apache.org/jira/browse/FLINK-17544 Project: Flink Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099232#comment-17099232 ] John Lonergan commented on FLINK-17464: --- Yep think failing the job is the lesser e

[jira] [Updated] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17469: -- Description: We are running multiple jobs on a shared standalone HA Cluster. We want to be ab

[jira] [Updated] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17469: -- Description: We are running multiple jobs on a shared standalone HA Cluster. We want to be ab

[jira] [Created] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

John Lonergan created FLINK-17469: - Summary: Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment Key: FLINK-17469 URL: https://issues.apache.org/jira/browse/FLINK-17469

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

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17464: -- Description: When recovering job graphs after a failover of the JobManager, or after a restar

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

John Lonergan created FLINK-17464: - Summary: Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service Key: FLINK-17464 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Commented] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078842#comment-17078842 ] John Lonergan commented on FLINK-17059: --- Hi what release version is available? Tha

[jira] [Commented] (FLINK-15540) flink-shaded-hadoop-2-uber bundles wrong dependency versions

[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078839#comment-17078839 ] John Lonergan commented on FLINK-15540: --- Is a working version released? > flink-s

[jira] [Issue Comment Deleted] (FLINK-15540) flink-shaded-hadoop-2-uber bundles wrong dependency versions

[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-15540: -- Comment: was deleted (was: Is a working version released?) > flink-shaded-hadoop-2-uber bundl

[jira] [Updated] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17059: -- Description: The uploaded pom for flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom has a

[jira] [Updated] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17059: -- Description: The uploaded pom for flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom has a

[jira] [Updated] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-17059: -- Description: The uploaded pom for flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom has a

[jira] [Created] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

John Lonergan created FLINK-17059: - Summary: flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle Key: FLINK-17059 URL: https://issues.apache.org/jira/browse/FLINK-17059 Project: Flink

[jira] [Commented] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI.

[ https://issues.apache.org/jira/browse/FLINK-9536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073582#comment-17073582 ] John Lonergan commented on FLINK-9536: -- Re access to multiple rolled logs or chunkin

[jira] [Updated] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method

[ https://issues.apache.org/jira/browse/FLINK-16920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-16920: -- Description: We were trying to build proxy that excluded all mutating operations and the docu

[jira] [Created] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method

John Lonergan created FLINK-16920: - Summary: Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method Key: FLINK-16920 URL: https://issues.apache.org/jira/browse/FLINK-16920

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013767#comment-17013767 ] John Lonergan commented on FLINK-3929: -- This approach alone doesn't consider the imp

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007567#comment-17007567 ] John Lonergan commented on FLINK-15174: --- Hi any update on this PR? Hoping to make

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan edited comment on FLINK-15174 at 12/10/19 12:37 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan edited comment on FLINK-15174 at 12/10/19 12:36 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan edited comment on FLINK-15174 at 12/10/19 12:35 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan edited comment on FLINK-15174 at 12/10/19 12:32 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan edited comment on FLINK-15174 at 12/10/19 12:30 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992502#comment-16992502 ] John Lonergan commented on FLINK-15174: --- I agree. As it stands the certs can only

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

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984305#comment-16984305 ] John Lonergan commented on FLINK-14170: --- Will do > Support hadoop < 2.7 with Stre

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

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953637#comment-16953637 ] John Lonergan edited comment on FLINK-14170 at 10/17/19 11:25 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953637#comment-16953637 ] John Lonergan edited comment on FLINK-14170 at 10/17/19 11:24 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953637#comment-16953637 ] John Lonergan commented on FLINK-14170: --- Hi I disagree with that approach as it's

[jira] [Updated] (FLINK-14238) ParquetPojoInputFormat logging bug

[ https://issues.apache.org/jira/browse/FLINK-14238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14238: -- Issue Type: Bug (was: Improvement) > ParquetPojoInputFormat logging bug > ---

[jira] [Created] (FLINK-14238) ParquetPojoInputFormat logging bug

John Lonergan created FLINK-14238: - Summary: ParquetPojoInputFormat logging bug Key: FLINK-14238 URL: https://issues.apache.org/jira/browse/FLINK-14238 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Description: The change made by https://github.com/apache/flink/pull/4663/files introduces a

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Description: The change made by https://github.com/apache/flink/pull/4663/files introduces a

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Issue Type: Bug (was: Improvement) > Don't swallow exception when rethrowing type mismatches

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Description: The change made by https://github.com/apache/flink/pull/4663/files introduces a

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Description: The change made by https://github.com/apache/flink/pull/4663/files introduces a

[jira] [Created] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

John Lonergan created FLINK-14174: - Summary: Don't swallow exception when rethrowing type mismatches with side outputs Key: FLINK-14174 URL: https://issues.apache.org/jira/browse/FLINK-14174 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935904#comment-16935904 ] John Lonergan commented on FLINK-14170: --- Yep it's unnecessarily restrictive and ac

[jira] [Created] (FLINK-14121) upgrade tocommons-compress:1.19 due to CVE

John Lonergan created FLINK-14121: - Summary: upgrade tocommons-compress:1.19 due to CVE Key: FLINK-14121 URL: https://issues.apache.org/jira/browse/FLINK-14121 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-14088) Couchbase connector - sink with checkpointing support

John Lonergan created FLINK-14088: - Summary: Couchbase connector - sink with checkpointing support Key: FLINK-14088 URL: https://issues.apache.org/jira/browse/FLINK-14088 Project: Flink Issue

[jira] [Comment Edited] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910497#comment-16910497 ] John Lonergan edited comment on FLINK-10382 at 8/19/19 3:48 PM: --

[jira] [Comment Edited] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910497#comment-16910497 ] John Lonergan edited comment on FLINK-10382 at 8/19/19 3:47 PM: --

[jira] [Commented] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910497#comment-16910497 ] John Lonergan commented on FLINK-10382: --- Just fell over this same problem - Fundam

[jira] [Commented] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908529#comment-16908529 ] John Lonergan commented on FLINK-13588: --- See [https://github.com/apache/flink/pull

[jira] [Commented] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907109#comment-16907109 ] John Lonergan commented on FLINK-13588: --- Hi yes that's how we"fixed" it because it

[jira] [Commented] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903278#comment-16903278 ] John Lonergan commented on FLINK-13588: --- Don't agree. If there is context then th

[jira] [Created] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

John Lonergan created FLINK-13588: - Summary: StreamTask.handleAsyncException throws away the exception cause Key: FLINK-13588 URL: https://issues.apache.org/jira/browse/FLINK-13588 Project: Flink

[jira] [Commented] (FLINK-3988) Add data set connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507259#comment-15507259 ] John Lonergan commented on FLINK-3988: -- Anyone fancy collaborating? > Add data set c

[jira] [Commented] (FLINK-3987) Add data stream connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507255#comment-15507255 ] John Lonergan commented on FLINK-3987: -- Anyone fancy collaborating? > Add data strea