[jira] [Created] (FLINK-31122) Expose MetricGroup to Committer of new Unified Sink v2

Theo Diefenthal created FLINK-31122: --- Summary: Expose MetricGroup to Committer of new Unified Sink v2 Key: FLINK-31122 URL: https://issues.apache.org/jira/browse/FLINK-31122 Project: Flink

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282124#comment-17282124 ] Theo Diefenthal commented on FLINK-21028: - Hi [~pnowojski] , there really isn't

[jira] [Comment Edited] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282124#comment-17282124 ] Theo Diefenthal edited comment on FLINK-21028 at 2/10/21, 12:08 AM: --

[jira] [Commented] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline

[ https://issues.apache.org/jira/browse/FLINK-21029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268045#comment-17268045 ] Theo Diefenthal commented on FLINK-21029: - Ah you are right again. I ghought for

[jira] [Comment Edited] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268016#comment-17268016 ] Theo Diefenthal edited comment on FLINK-21028 at 1/19/21, 4:34 PM: ---

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268016#comment-17268016 ] Theo Diefenthal commented on FLINK-21028: - Sadly, I don't have any DEBUG logs he

[jira] [Commented] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline

[ https://issues.apache.org/jira/browse/FLINK-21029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267995#comment-17267995 ] Theo Diefenthal commented on FLINK-21029: - Hi [~trohrmann] , good question indee

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267989#comment-17267989 ] Theo Diefenthal commented on FLINK-21028: - Hi Till, thanks for your feedback. O

[jira] [Created] (FLINK-21030) Broken job restart for job with disjoint graph

Theo Diefenthal created FLINK-21030: --- Summary: Broken job restart for job with disjoint graph Key: FLINK-21030 URL: https://issues.apache.org/jira/browse/FLINK-21030 Project: Flink Issue Ty

[jira] [Created] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline

Theo Diefenthal created FLINK-21029: --- Summary: Failure of shutdown lead to restart of (connected) pipeline Key: FLINK-21029 URL: https://issues.apache.org/jira/browse/FLINK-21029 Project: Flink

[jira] [Created] (FLINK-21028) Streaming application didn't stop properly

Theo Diefenthal created FLINK-21028: --- Summary: Streaming application didn't stop properly Key: FLINK-21028 URL: https://issues.apache.org/jira/browse/FLINK-21028 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264243#comment-17264243 ] Theo Diefenthal commented on FLINK-17074: - What would now be the preferred appro

[jira] [Commented] (FLINK-19382) Introducing ReplayableSourceStateBackend

[ https://issues.apache.org/jira/browse/FLINK-19382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201972#comment-17201972 ] Theo Diefenthal commented on FLINK-19382: - Hi Yun Tang, Sorry, I'm not familiar

[jira] [Created] (FLINK-19383) Per Partition State

Theo Diefenthal created FLINK-19383: --- Summary: Per Partition State Key: FLINK-19383 URL: https://issues.apache.org/jira/browse/FLINK-19383 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19382) Introducing ReplayableSourceStateBackend

Theo Diefenthal created FLINK-19382: --- Summary: Introducing ReplayableSourceStateBackend Key: FLINK-19382 URL: https://issues.apache.org/jira/browse/FLINK-19382 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment

[ https://issues.apache.org/jira/browse/FLINK-10443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104557#comment-17104557 ] Theo Diefenthal commented on FLINK-10443: - At least, in Flink 1.9.1 it's still a

[jira] [Created] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

Theo Diefenthal created FLINK-17348: --- Summary: Expose metric group to ascendingTimestampExtractor Key: FLINK-17348 URL: https://issues.apache.org/jira/browse/FLINK-17348 Project: Flink Issu

[jira] [Comment Edited] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

[ https://issues.apache.org/jira/browse/FLINK-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043610#comment-17043610 ] Theo Diefenthal edited comment on FLINK-12410 at 2/24/20 4:57 PM:

[jira] [Comment Edited] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

[ https://issues.apache.org/jira/browse/FLINK-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043610#comment-17043610 ] Theo Diefenthal edited comment on FLINK-12410 at 2/24/20 3:46 PM:

[jira] [Commented] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

[ https://issues.apache.org/jira/browse/FLINK-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043610#comment-17043610 ] Theo Diefenthal commented on FLINK-12410: - It is indeed very annoying. I think,

[jira] [Commented] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985965#comment-16985965 ] Theo Diefenthal commented on FLINK-13418: - I think that the major concern here i

[jira] [Commented] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907102#comment-16907102 ] Theo Diefenthal commented on FLINK-13418: - I see this issue as highly important

[jira] [Commented] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845210#comment-16845210 ] Theo Diefenthal commented on FLINK-12579: - Prometheus can deal with Infinity/NaN

[jira] [Updated] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theo Diefenthal updated FLINK-12579: Description: When using the InfluxDB metrics, the logs are polluted by lots of warnings du

[jira] [Updated] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theo Diefenthal updated FLINK-12579: Description: When using the InfluxDB metrics, the logs are polluted by lots of warnings du

[jira] [Updated] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

[ https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theo Diefenthal updated FLINK-12579: Description: When using the InfluxDB metrics, the logs are polluted by lots of warnings du

[jira] [Created] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors

Theo Diefenthal created FLINK-12579: --- Summary: Influx Metric exporter throws a lot of negative infinity errors Key: FLINK-12579 URL: https://issues.apache.org/jira/browse/FLINK-12579 Project: Flink