Flink在日志文件夹中生成输出文件，但不打印任何内容

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.util.Collector;

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

        // 从日志文件夹中读取数据流
        DataStream<String> logStream = env.readTextFile("path/to/log/folder");

        // 对日志数据进行处理，生成输出文件
        DataStream<String> output = logStream.flatMap(new FlatMapFunction<String, String>() {
            @Override
            public void flatMap(String value, Collector<String> out) {
                // 在这里可以对日志数据进行处理，生成输出文件
                // 例如，可以将日志数据写入到文件中
                // 注意：这里只是示例，具体的处理逻辑需要根据实际需求进行编写
                // 这里不打印任何内容，只生成输出文件
            }
        });

        // 执行任务
        env.execute("Log Processing Job");
    }
}