Question about the custom partitioner

Posted by Xingcan Cui on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Question-about-the-custom-partitioner-tp13721.html

Hi all,

I want to duplicate records to multiple downstream tasks (not all of them thus the

Broadcasting should not work) in stream environment.

However, it seems that the current custom partitioner can return only one partition index.

Why this restriction exists or do I miss something?

Thanks,

Xingcan