开发者社区> 问答> 正文

FileInputFormat切片机制中job提交的步骤是什么呢?

FileInputFormat切片机制中job提交的步骤是什么呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-05 23:51:44 273 0
1 条回答
写回答
取消 提交回答
  • 1)创建给集群提交数据的Stag路径

    2)获取jobid ,并创建job路径

    3)拷贝jar包到集群

    4)计算切片,生成切片规划文件

    5)向Stag路径写xml配置文件

    6)提交job,返回提交状态

    2021-12-06 10:09:57
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
俞航翔|基于Log的通用增量Checkpoint 立即下载
《Apache Flink-重新定义计算》PDF下载 立即下载

相关实验场景

更多