Flink 自定義Sink 之 寫入HDFS

1、pom.xml添加依賴。 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-filesystem_${scala.binary.version}</artifactId> <version>${flink.version}</version> </dependency> <!--

>>阅读原文<<