ps:本文依赖于Flink1.13

1.Flink 由于扩大并行度导致启动失败，扩大下列参数

1
2
3

akka.ask.timeout=5min
taskmanager.slot.timeout=5min
client.timeout=5min

2.Flink 由于扩大并行度导致jobmanager与taskmanager连接超时，个别模块启动失败

1

akka.tcp.timeout=5min

#This is My First Code
作为镇站之宝

1
2
3
4
5

public class HelloWorld{
    public static void main(String[] args) {
        System.out.println("hello world");
    }
}