Re: [DISCUSS] Drop Scala 2.11

2020-09-21 Thread Theo Diefenthal
We use a Cloudera 6.3 cluster in prod. I'd guess that it's still widely used in prod as those cloudera upgrades for major versions are planned long time ahead and take a significant amount of resources in big data lakes. On that 6.3. cluster, if I open spark-shell, I still see scala 2.11 in use

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

2020-04-23 Thread Theo Diefenthal (Jira)
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

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

2019-05-21 Thread Theo Diefenthal (JIRA)
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

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

2020-09-23 Thread Theo Diefenthal (Jira)
Theo Diefenthal created FLINK-19382: --- Summary: Introducing ReplayableSourceStateBackend Key: FLINK-19382 URL: https://issues.apache.org/jira/browse/FLINK-19382 Project: Flink Issue Type

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

2020-09-23 Thread Theo Diefenthal (Jira)
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-31122) Expose MetricGroup to Committer of new Unified Sink v2

2023-02-17 Thread Theo Diefenthal (Jira)
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] [Created] (FLINK-21028) Streaming application didn't stop properly

2021-01-19 Thread Theo Diefenthal (Jira)
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

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

2021-01-19 Thread Theo Diefenthal (Jira)
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-21030) Broken job restart for job with disjoint graph

2021-01-19 Thread Theo Diefenthal (Jira)
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