Hi Kevin,
Thanks for starting this thread.
This idea is something that was discussed in Kroxylicious (an open source
Kafka proxy, I'm a maintainer there). In that discussion [1] we came to the
conclusion that there are a couple of issues with implementing this:
1. Doesn't scale - very large messa
yux created FLINK-35781:
---
Summary: Make pipeline parallelism config optional
Key: FLINK-35781
URL: https://issues.apache.org/jira/browse/FLINK-35781
Project: Flink
Issue Type: Improvement
Com
xiangyu feng created FLINK-35780:
Summary: Support state migration from disabling to enabling ttl in
RocksDBState
Key: FLINK-35780
URL: https://issues.apache.org/jira/browse/FLINK-35780
Project: Flink
Ahmed Hamdy created FLINK-35779:
---
Summary: Update documentation for PubSubSinkV2
Key: FLINK-35779
URL: https://issues.apache.org/jira/browse/FLINK-35779
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-35778:
---
Summary: Escape URI reserved characters when creating file-merging
directories
Key: FLINK-35778
URL: https://issues.apache.org/jira/browse/FLINK-35778
Project: Flink
Gyula Fora created FLINK-35777:
--
Summary: Observe session jobs during cleanup
Key: FLINK-35777
URL: https://issues.apache.org/jira/browse/FLINK-35777
Project: Flink
Issue Type: Improvement