如何配置flink环境

由于当前inlong-sort依赖的是flink1.9.3版本，因此在下载部署包时，请选择

flink环境配置完成后，可以通过浏览器访问flink的web ui，对应的地址是/{flink部署路径}/conf/masters文件中的地址

有了上述编译阶段产出的jar包后，就可以启动inlong-sort的应用了。

示例：

  • ./bin/flink run -c org.apache.inlong.sort.flink.Entrance inlong-sort-core-1.0-SNAPSHOT.jar --cluster-id my_application --zookeeper.quorum 127.0.0.1:2181 --zookeeper.path.root /inlong-sort --source.type tubemq --sink.type hive

  • 表示main class name

  • inlong-sort-core-1.0-SNAPSHOT.jar 为编译阶段产出的jar包

  • --zookeeper.quorum zk quorum
  • zk根目录
  • --source.type 数据源的种类, 当前支持：”tubemq”、”pulsar”

配置示例