编写flink任务jar包--helloworld

Posted 张小凡vip

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了编写flink任务jar包--helloworld相关的知识,希望对你有一定的参考价值。

我们在之前的文章中已经成功部署了flink on k8s,并且成功运行了 wordcount.jar完成了单词统计的任务。

flink on k8s部署方案实践–详细步骤

那如果我们需要实现自己的处理逻辑和任务呢? 比如说 打印一个helloworld,我们就需要自己写一个jar包了,没有现成的包可以直接用了。

本篇文章记录如果写一个简单的jar包并在flink中运行,工具使用idea。

新建maven项目

File --》 New --》 Project

默认使用maven1.8版本 点击 next

命名为 flink-job 点击finish

以上是关于编写flink任务jar包--helloworld的主要内容,如果未能解决你的问题,请参考以下文章

编写flink任务jar包--helloworld

flink读取mongodb数据源批处理全量获取实践

flink读取mongodb数据源批处理全量获取实践

flink读取mongodb数据源批处理全量获取实践

flink读取mongodb数据源批处理全量获取实践

Apache Flink 任意 Jar 包上传致 RCE 漏洞复现