我正在通过扩展 Apache Flink 中的 org.apache.flink.api.common.functions.Partitioner 接口来实现自定义分区器。这需要我重写分区方法。我的问题是：我需要确保分区方法是线程安全的吗？
我在网上搜索过，但没有找到任何关于分区方法在 Flink 分布式处理环境中使用时的线程安全要求的明确资源。由于 Flink 作业可以与可能使用同一分区器实例的多个任务并行运行，因此如果该方法不是线程安全的，我担心潜在的竞争条件或不一致的分区。
任何有关相关文档的见解或指示将不胜感激。
不，Flink 的任何用户函数都无需担心线程安全。这是由框架本身处理的。