Hi Salva,
I already answered on SO [1], but I'll replicate it here:
With Flink 1.9, you cannot dynamically broadcast to all channels anymore.
Your StreamPartitioner has to statically specify if it's a broadcast with
isBroadcast. Then, selectChannel is never invoked.
Do you have a specific use
Thanks Chesnay! Just to be clear, this how my current code looks like:
```
unionChannel = broadcastChannel.broadcast().union(singleChannel)
result = new DataStream<>(
unionChannel.getExecutionEnvironment(),
new PartitionTransformation<>(unionChannel.getTransformation(), new
You should be able to implement this on the DataStream API level using
DataStream#broadcast and #union like this:
input = ...
singleChannel = input.filter(x -> !x.isBroadCastPartitioning);
broadcastChannel = input.filter(x -> x.isBroadCastPartitioning);
result =
I am trying to migrate a custom dynamic partitioner from Flink 1.7 to Flink
1.9. The original partitioner implemented the `selectChannels` method within
the `StreamPartitioner` interface like this:
```java
// Original: working for Flink 1.7
//@Override
public int[]
