如何引入flink-connector-filesystem依赖。

你可以通过以下步骤引入flink-connector-filesystem依赖：

1. 在你的pom.xml文件中添加以下依赖：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-connector-filesystem</artifactId>
  <version>${flink.version}</version>
</dependency>

其中`${flink.version}`是你使用的Flink版本号。

2. 重新构建和打包你的项目，以使新的依赖生效。

在你的代码中，你可以使用以下方式来引用flink-connector-filesystem：

import org.apache.flink.streaming.connectors.fs.FileSystemSink;
import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink;

注意：`org.apache.flink.streaming.connectors.fs.FileSystemSink`已被弃用，建议使用`org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink`。

相关问题

flink-sql-connector 和flink-connector 区别

Flink-SQL-Connector 和 Flink-Connector 都是 Apache Flink 的连接器，但它们的主要区别在于用途和功能。

Flink-SQL-Connector 是为了支持 Flink SQL 而开发的一组连接器，它们包括 JDBC、Elasticsearch、Kafka、HBase、JMS、Cassandra、Hive 和 MySQL 等。这些连接器可以将 Flink SQL 的查询结果发送到特定的数据源中，或从特定的数据源中读取数据并用于 Flink SQL 查询。因此，Flink-SQL-Connector 的主要用途是支持 Flink SQL 查询操作。

Flink-Connector 则是一个更通用的连接器框架，它提供了一种通用的方式来与外部系统进行交互，例如读写文件、消息队列、数据库、NoSQL 数据库、流处理引擎等。Flink-Connector 提供了一组接口和类来支持开发者编写自定义的连接器，以便与其他系统集成。因此，Flink-Connector 的主要用途是支持 Flink 与其他系统的交互操作，而不仅仅是支持 Flink SQL 查询操作。

flink-connector-mysql-cdc 和 mysql-connector-java 依赖冲突

flink-connector-mysql-cdc 是一个用于将 MySQL 数据库中的数据变化捕捉到 Flink 流处理应用程序中的库。它依赖于 mysql-connector-java 库来连接 MySQL 数据库。如果你在项目中同时引入了 flink-connector-mysql-cdc 和 mysql-connector-java，可能会出现依赖冲突的问题。

具体来说，如果你在项目中引入了不同版本的 mysql-connector-java 和 flink-connector-mysql-cdc，可能会导致编译错误或者运行时异常。解决这个问题的一种方法是将 mysql-connector-java 库排除掉，让 flink-connector-mysql-cdc 使用你指定的版本的 mysql-connector-java 库。例如，在使用 Maven 进行构建时，可以在 flink-connector-mysql-cdc 的依赖项中添加 exclude 标签，如下所示：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-connector-mysql-cdc</artifactId>
  <version>${flink.version}</version>
  <exclusions>
    <exclusion>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
    </exclusion>
  </exclusions>
</dependency>

这样就可以避免 flink-connector-mysql-cdc 和 mysql-connector-java 的依赖冲突了。