我想了解一些关于 flink 恢复阶段的细节。操作员独立加载状态然后恢复?还是按照拓扑运算符的顺序,先按顺序从源加载状态,然后再恢复?
部署操作员后,状态恢复会独立进行。流程序的部署按拓扑顺序进行,但 Flink 不会等到部署的算子恢复其状态。相反,一旦它知道生产者将被部署到哪里,它就会急切地部署消费者。
我想了解一些关于 flink 恢复阶段的细节。操作员独立加载状态然后恢复?还是按照拓扑运算符的顺序,先按顺序从源加载状态,然后再恢复?
部署操作员后,状态恢复会独立进行。流程序的部署按拓扑顺序进行,但 Flink 不会等到部署的算子恢复其状态。相反,一旦它知道生产者将被部署到哪里,它就会急切地部署消费者。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium