我正在测试Flink 1.3.0中的弹性特征。我有一个checkpointing启用和固定延迟重启策略的工作。当我终止一个TaskManager JVM时,一段时间后,作业在其余节点上正确重新启动。但是,当我添加新节点时,作业不会自动重新启动以使用它。如何重新启动flink作业以使用添加的TaskManager
我试图用bin/flink stop <jobId>
,但它总是给我java.lang.IllegalStateException: Job with ID <jobId> is not stoppable.
我怎样才能重新启动作业,以利用额外的节点?