akka.remote.transport.netty.NettyTransport - Remote connection to [null] failed with org.apache.flink.shaded.akka.org.jboss.netty.channel.ConnectTimeoutException: connection timed out: /172.16.23.246:57325
背景是单机起了一个flink集群,但是切换了网络,导致一致连接不上对应的网络,这里的ip使用的公网的ip,需要重启服务
Could not allocate all requires slots within timeout of 300000 ms. Slots required: 5, slots allocated: 2
背景是单机器了一个flink集群,但是默认配置是taskmanager.numberOfTaskSlots在flink-conf.yaml是设置成1。然而作业通过setParallelism设置了2,为什么会显示5还有为什么分配了2个呢?