Carlos045's questions

当 flink 中以批处理模式执行作业时，fileSink 按并行数生成多个文件，但我只想在一个文件中输出而不更改并行数，我该怎么做？

将parallel 放入5 中，FileSink 的输出中仅得到一个文件。

   OutputFileConfig config = OutputFileConfig
            .builder()
            .withPartPrefix("prefix")
            .withPartSuffix(".txt")
            .build();


    final FileSink<String> sinkfile = FileSink
            .forRowFormat(new Path("src/main/resources/output"), new SimpleStringEncoder<String>("UTF-8"))
            .withBucketAssigner(new BasePathBucketAssigner<>())
            .withOutputFileConfig(config)

            .build();