任意并行度全局状态从物理上就是不可行的，你可以了解一下分布式计算系统怎么部署物理作业的。“全局状态”要么依赖外部存储要么依赖实现（部署）细节。
你这个需求能不能自定义 KeyBy 细节（KeySelector）来实现？相关文档见 https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/api_concepts.html#define-keys-using-key-selector-functions Best, tison. star <[email protected]> 于2020年5月26日周二 下午6:42写道： > 请问，有全局状态组件吗？我有一个需求需要对数据里的id和name做映射，也就是如果两条数据的id或者name相同则映射成一个值；现在只能使用operator > state，并且并行度设置为1，来实现全局state > > > 谢谢 > > 发自我的iPhone
