[jira] [Created] (FLINK-37912) Typing the DataStream interfaces

Joey Pereira created FLINK-37912: Summary: Typing the DataStream interfaces Key: FLINK-37912 URL: https://issues.apache.org/jira/browse/FLINK-37912 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer

Joey Pereira created FLINK-37864: Summary: Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer Key: FLINK-37864 URL: https://issues.apache.org/jira/browse/FLINK-37864 Project:

[jira] [Created] (FLINK-37863) DynamicKafkaSource support in PyFlink

Joey Pereira created FLINK-37863: Summary: DynamicKafkaSource support in PyFlink Key: FLINK-37863 URL: https://issues.apache.org/jira/browse/FLINK-37863 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

Joey Pereira created FLINK-21321: Summary: Change RocksDB incremental checkpoint re-scaling to use deleteRange Key: FLINK-21321 URL: https://issues.apache.org/jira/browse/FLINK-21321 Project: Flink

[jira] [Created] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

Joey Pereira created FLINK-17971: Summary: Speed up RocksDB bulk loading with SST generation and ingestion Key: FLINK-17971 URL: https://issues.apache.org/jira/browse/FLINK-17971 Project: Flink