我正在尝试编写一个junit测试,它有两个资源和操作符,第一个操作符用于将数据持久化为状态,然后第二个操作符将检索状态out。我发现有线的东西是第二个运算符总是在第一个运算符之前运行,第一个运算符将数据持久化为状态。所以,我的问题是如何在同一个flink作业程序中控制任务的执行顺序?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!