Is the partition method of a custom Partitioner implementation required to be thread-safe in Apache Flink?
I am implementing a custom partitioner by extending the org.apache.flink.api.common.functions.Partitioner interface in Apache Flink. This requires me to override the partition method. My question is: do I need to ensure that the partition method is thread-safe?