安装部署

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

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

    有了上述编译阶段产出的jar包后，就可以启动inlong-sort的应用了。提交方式可以参考如何提交flink作业。

    示例：

    • -c org.apache.inlong.sort.flink.Entrance 表示main class name

    • inlong-sort/sort-core-[version].jar 为编译阶段产出的jar包

    • 用来唯一标识一个inlong-sort作业，同inlong-manager中sort.appName配置一致
    • --zookeeper.quorum zk quorum，同inlong-manager中cluster.zk.url配置一致
    • --metrics.audit.proxy.hosts audit proxy 地址用于上报审计指标数据
    • --source.type 数据源的种类, 当前支持：”tubemq”、”pulsar”
    • --sink.type 存储系统的种类，当前支持：”clickhouse”、”hive”
    1. --cluster-id inlong_app --zookeeper.quorum 192.127.0.1:2181 \