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

2021-11-16 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444781#comment-17444781 ] John Lonergan commented on FLINK-17464: --- Sorry my error. How do I stop getting notifications on

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

2021-11-12 Thread John Lonergan (Jira)
[ 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

2021-11-12 Thread John Lonergan (Jira)
[ 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

2021-11-12 Thread John Lonergan (Jira)
[ 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

2021-11-12 Thread John Lonergan (Jira)
[ 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

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

2021-11-12 Thread John Lonergan (Jira)
[ 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

2021-11-12 Thread John Lonergan (Jira)
[ 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 >

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

2021-11-12 Thread John Lonergan (Jira)
[ 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

2021-11-12 Thread John Lonergan (Jira)
[ 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

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

2021-11-12 Thread John Lonergan (Jira)
[ 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

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

2021-04-23 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330875#comment-17330875 ] John Lonergan commented on FLINK-17464: --- As far as I know this is still a critical problem however

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

2020-05-27 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117724#comment-17117724 ] John Lonergan commented on FLINK-17969: --- +1 Really please to see this - I asked about this exact

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

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

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

2020-05-15 Thread John Lonergan (Jira)
[ 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

2020-05-15 Thread John Lonergan (Jira)
[ 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

2020-05-15 Thread John Lonergan (Jira)
[ 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

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

2020-05-15 Thread John Lonergan (Jira)
[ 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

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

2020-05-15 Thread John Lonergan (Jira)
John Lonergan created FLINK-17723: - Summary: Written design for flink threading model and guarantees made to the various structual components Key: FLINK-17723 URL:

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

2020-05-14 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107760#comment-17107760 ] John Lonergan commented on FLINK-17544: --- Off which branch. BTW Theres a load of other problems in

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

2020-05-14 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107578#comment-17107578 ] John Lonergan commented on FLINK-17545: --- Been hit by further failures due to this class. This time

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

2020-05-13 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106292#comment-17106292 ] John Lonergan commented on FLINK-17464: --- Hi folk - what are our options to make this infra

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

2020-05-12 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2020-05-12 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105785#comment-17105785 ] John Lonergan commented on FLINK-17469: --- What I'm really after is to be able to provide the job

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

2020-05-06 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101132#comment-17101132 ] John Lonergan commented on FLINK-17464: --- I meant arch because this problem wouldn't take the

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

2020-05-06 Thread John Lonergan (Jira)
[ 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

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

2020-05-06 Thread John Lonergan (Jira)
[ 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

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

2020-05-06 Thread John Lonergan (Jira)
[ 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

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

2020-05-06 Thread John Lonergan (Jira)
[ 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

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

2020-05-06 Thread John Lonergan (Jira)
[ 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) >

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

2020-05-06 Thread John Lonergan (Jira)
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

2020-05-06 Thread John Lonergan (Jira)
[ 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

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

2020-05-06 Thread John Lonergan (Jira)
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

2020-05-04 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099232#comment-17099232 ] John Lonergan commented on FLINK-17464: --- Yep think failing the job is the lesser evil. A wrecked

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

2020-04-29 Thread John Lonergan (Jira)
[ 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

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

2020-04-29 Thread John Lonergan (Jira)
[ 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

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

2020-04-29 Thread John Lonergan (Jira)
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

2020-04-29 Thread John Lonergan (Jira)
[ 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

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

2020-04-29 Thread John Lonergan (Jira)
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:

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

2020-04-08 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078842#comment-17078842 ] John Lonergan commented on FLINK-17059: --- Hi what release version is available? Thanks >

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

2020-04-08 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078839#comment-17078839 ] John Lonergan commented on FLINK-15540: --- Is a working version released? >

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

2020-04-08 Thread John Lonergan (Jira)
[ 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

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

2020-04-08 Thread John Lonergan (Jira)
[ 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

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

2020-04-08 Thread John Lonergan (Jira)
[ 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

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

2020-04-08 Thread John Lonergan (Jira)
[ 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

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

2020-04-08 Thread John Lonergan (Jira)
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.

2020-04-02 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073582#comment-17073582 ] John Lonergan commented on FLINK-9536: -- Re access to multiple rolled logs or chunking a single log..

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

2020-04-01 Thread John Lonergan (Jira)
[ 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

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

2020-04-01 Thread John Lonergan (Jira)
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

2020-01-12 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013767#comment-17013767 ] John Lonergan commented on FLINK-3929: -- This approach alone doesn't consider the impact of password

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

2020-01-03 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007567#comment-17007567 ] John Lonergan commented on FLINK-15174: --- Hi any update on this PR? Hoping to make use of it

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

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

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

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

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

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

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

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

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

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

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

2019-12-10 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992502#comment-16992502 ] John Lonergan commented on FLINK-15174: --- I agree. As it stands the certs can only act as a

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

2019-11-28 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984305#comment-16984305 ] John Lonergan commented on FLINK-14170: --- Will do > Support hadoop < 2.7 with

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

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

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

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

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

2019-10-17 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953637#comment-16953637 ] John Lonergan commented on FLINK-14170: --- Hi I disagree with that approach as it's impact time to

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

2019-09-26 Thread John Lonergan (Jira)
[ 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

2019-09-26 Thread John Lonergan (Jira)
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

2019-09-23 Thread John Lonergan (Jira)
[ 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

2019-09-23 Thread John Lonergan (Jira)
[ 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

2019-09-23 Thread John Lonergan (Jira)
[ 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

2019-09-23 Thread John Lonergan (Jira)
[ 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

2019-09-23 Thread John Lonergan (Jira)
[ 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

2019-09-23 Thread John Lonergan (Jira)
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

2019-09-23 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935904#comment-16935904 ] John Lonergan commented on FLINK-14170: --- Yep it's unnecessarily restrictive and actually breaks

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

2019-09-18 Thread John Lonergan (Jira)
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:

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

2019-09-16 Thread John Lonergan (Jira)
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

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

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

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

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

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

2019-08-19 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910497#comment-16910497 ] John Lonergan commented on FLINK-10382: --- Just fell over this same problem - Fundamentally this

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

2019-08-15 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908529#comment-16908529 ] John Lonergan commented on FLINK-13588: --- See [https://github.com/apache/flink/pull/9456] Hi done

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

2019-08-14 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907109#comment-16907109 ] John Lonergan commented on FLINK-13588: --- Hi yes that's how we"fixed" it because it limits the

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

2019-08-08 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903278#comment-16903278 ] John Lonergan commented on FLINK-13588: --- Don't agree. If there is context then the code should

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

2019-08-05 Thread John Lonergan (JIRA)
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

2016-09-20 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15507259#comment-15507259 ] John Lonergan commented on FLINK-3988: -- Anyone fancy collaborating? > Add data set connector to

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

2016-09-20 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15507255#comment-15507255 ] John Lonergan commented on FLINK-3987: -- Anyone fancy collaborating? > Add data stream connector to