Viktor Feklin created FLINK-25462: ------------------------------------- Summary: Allow override partitioning for KeyedStream Key: FLINK-25462 URL: https://issues.apache.org/jira/browse/FLINK-25462 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.14.2 Reporter: Viktor Feklin
Currently there is no way to override partitioning for KeyedStream. --------------------- Use case: We use Kafka Source to read from topic where all records partitioned by some key. We use same key for KeyedStream (all records with same key readed localy). We want to handle keyed events localy - because the load is already ballaced. Actualy events shuffle between nodes (because KeyedStream hardcoded with KeyGroupStreamPartitioner) and there is no way to stop this usless and expensive work (in our case). -- This message was sent by Atlassian Jira (v8.20.1#820001)