我需要为StreamingFileSink创建的文件配置文件名。我使用ParquetAvroWriters.forGenericRecord
创建镶木地板文件。发现我使用.forBulkFormat()
时无法使用.withOutputFileConfig()
(使用.forRowFormat()
时可用。
它开始使用Flink 1.11