本地代码截图：
环境上在flink中跑beam截图：
在自己本地跑beam的pipeline获取state可以获取到DONE，但是在环境上结合flink同一行代码获取的state是UNKONW，这个是为什么呀，o(╥﹏╥)o
