我想知道本地执行环境中flink作业的状态何时发生变化;这对于编写更具弹性的测试很有用,因为到目前为止我发现的其他替代方法是关于放松超时和类似的。如果有一个函数我可以调用来获取当前状态,那么即使是轮询也比我现在的状态有所改进。我看到在api文档中有几个类看起来很有前途,但是我真的找不到一种方法来用一种有意义的方式来连接它们以使其工作。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!