Skip to main content

Flink Jar

基于Flink官方提供的DataStream API，使用Java或者Scala语言进行实时计算任务的开发。该模式相比FlinkSQL拥有更高的自由度，同时对开发人员的能力要求也更高。目前平台支持用户在线下完成任务的开发，然后将代码打包成JAR上传至平台进行管理。

  • 任务上传

    首先通过资源管理上传任务JAR包，详见资源管理

  • 任务创建

    image-20220704112222989

  • 选择资源：下拉显示【资源管理】目录中上传的文件

  • Mainclass：所选择JAR包的入口函数

  • 命令行参数：请输入对应MainClass的入口命令行参数，例如 String[] args

  • 附加资源：关联上传至项目内的其他资源文件，例如Kerberos认证使用的krb5、Keytab文件等

    note

    多资源引用创建Flink任务时无法基于K8s进行运行和调度。

  • 任务管理

    image-20220704114051982

  • 任务详情：和FlinkSQL任务相同

    note

    FlinkJar任务的历史版本只做历史提交记录，不支持版本比对和回滚。

  • 环境参数：任务运行相关的参数配置可以参考Flink Execution Configuration

  • 任务设置：不支持脏数据管理，其他功能和FlinkSQL相同