Flink的每个key状态 和每个并行度的状态 怎么测试区分？

要测试Flink的每个key状态和每个并行度的状态，可以采用以下方法：

1. 编写测试程序：创建一个Flink程序，使用KeyedStream或DataStream API处理数据。在处理过程中，为每个key分配一个状态，并记录每个key的状态值。同时，设置并行度，观察不同并行度下key状态的变化情况。

2. 使用StateBackend：为了存储每个key的状态，可以使用Flink提供的StateBackend。例如，可以将状态存储到内存、文件系统或分布式存储系统中。通过配置不同的StateBackend，可以观察不同存储方式下key状态的表现。

3. 使用Operator State：除了KeyedState，Flink还支持Operator State。通过将状态存储在Operator中，可以更好地控制状态的生命周期和访问方式。可以通过配置不同的Operator State来观察它们对key状态的影响。

4. 使用Checkpoint机制：Flink提供了Checkpoint机制，可以在处理过程中定期保存状态。通过比较不同并行度下的Checkpoint结果，可以观察不同并行度下key状态的稳定性。

5. 使用监控工具：可以使用Flink提供的监控工具（如Web UI、Metrics等）来观察不同并行度下key状态的表现。这些工具可以帮助你实时查看和分析Flink程序的性能和状态信息。

通过以上方法，可以有效地测试Flink的每个key状态和每个并行度的状态，从而找到最佳配置和优化方案。