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
MyDynamicPartitioner())
)
```
The problem when migrating to Flink 1.9 is that MyDynamicPartitioner cannot
handle broadcasted elements as explained in the question description. So,
based on your reply, I guess I could do something like this:
```
resultSingleChannel = new DataStream<>(
singleChannel.getExecutionEnvironment(),
new PartitionTransformation<>(singleChannel.getTransformation(), new
MyDynamicPartitioner())
)
result = broadcastChannel.broadcast().union(resultSingleChannel)
```
I will give it a try and see if it works.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
