Re: Use Partitioner to forward messages to subtask by index

Hi Joshua, It is possible, but fragile, as it depends on the internal code that Flink uses to calculate a hash for a key, and the max operator parallelism, etc. See makeKeyForOperatorIndex

Use Partitioner to forward messages to subtask by index

Is it possible to use a custom Partitioner to forward messages to a downstream substask by the subtask's index? I realize that it would not be safe to rely upon this across job restarts but this does not effect my particular application. I attempted to return a partition number identical to the