StreamingFileSink为RowFormat配置文件名



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

它开始使用Flink 1.11

相关内容

  • 没有找到相关文章

最新更新