Github user xccui commented on the issue: https://github.com/apache/flink/pull/5369 Ah ha, it doesn't matter. ð The test has been updated. Actually, I wanted to ensure that all the partitioning methods should cause the exception. However, that would be fussy and thus I only kept the broadcasted one.
---