Flink Job子任务需要几分钟才能启动，而源代码可以立即启动

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.datastream.DataStream;

public class SimpleFlinkJob {
    public static void main(String[] args) throws Exception {
        // 创建执行环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 从数据源读取数据
        DataStream<String> text = env.readTextFile("input.txt");

        // 数据处理逻辑
        DataStream<Integer> counts = text.map(new Tokenizer()).keyBy(0).sum(1);

        // 输出结果
        counts.print();

        // 执行作业
        env.execute("Simple Flink Job");
    }

    public static final class Tokenizer implements MapFunction<String, Tuple2<String, Integer>> {
        @Override
        public Tuple2<String, Integer> map(String value) {
            return new Tuple2<>(value, 1);
        }
    }
}