Apache StreamPark系列教程第二篇——项目打包和开发

这篇具有很好参考价值的文章主要介绍了Apache StreamPark系列教程第二篇——项目打包和开发。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、项目打包

项目依赖maven、jdk8.0、前端(node、npm)

//下载代码
git clone

//maven打包相关内容
mvn -N io.takari:maven:wrapper
//前端打包相关内容
curl -sL https://rpm.nodesource.com/setup_16.x | bash -
yum -y install nodejs
npm -v
npm install -g pnpm

node 安装

wget https://nodejs.org/dist/v16.18.1/node-v16.18.1-linux-x64.tar.xz
tar -xvf node-v16.18.1-linux-x64.tar.xz
cd node-v16.18.1-linux-x64/bin
./node -v
ln -s /root/node-v16.18.1-linux-x64/bin/node /usr/local/bin/node
ln -s /root/node-v16.18.1-linux-x64/bin/npm /usr/local/bin/npm
cd ..
node -v
npm -v

默认是h2(内存数据库,项目重新启动,数据库信息丢失),因此建议修改为mysql,同时workspace路径目录也需要修改

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

 最后在mysql数据中分别执行schema和data文件,就可以正常访问streampark

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

修改上述配置文件信息再进行打包

//执行打包命令
sh build.sh

打包完成之后

tar -zxvf apache-streampark-2.2.0-SNAPSHOT-incubating-bin.tar.gz

cd apache-streampark_2.12-2.2.0-SNAPSHOT-incubating-bin

#启动
sh bin/startup.sh
#停止
sh bin/shutdown.sh

访问http://ip:10000 没问题即认为启动无误

二、集群配置信息

Flink 单机版本本地安装,注意StreamPark remote 模式

wget https://archive.apache.org/dist/flink/flink-1.14.5/flink-1.14.5-bin-scala_2.12.tgz

tar -zxvf flink-1.14.5-bin-scala_2.12.tgz

cd flink-1.14.5

./bin/start-cluster.sh

访问 http://ip:8081 认为无误

Flink Home 配置:/root/flink/flink-1.14.5  上述flink 的安装路径

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

 集群配置:http://localhost:8081 或者宿主机ip

Apache StreamPark系列教程第二篇——项目打包和开发,Flink,大数据

修改Application里面自带的Flink SQL demo 任务,即可成功运行

修改完成之后点击release(发布作业)然后start(启动作业),任务即可启动成功。

备注:Flink SQL demo会运行一段时间之后自动结束,因为代码里面设置自动生成数据是增量数据,如果想任务一直运行

去掉自增设置同时改为最小和最大值成为随机数
'fields.f_sequence.min'='1',
'fields.f_sequence.max'='500',

这样job就能一直运行起来 ,而不会运行一段时间就停止了。
 文章来源地址https://www.toymoban.com/news/detail-678446.html

到了这里,关于Apache StreamPark系列教程第二篇——项目打包和开发的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 进程组,会话的基础概念,以及进程组,会话,控制终端,前台后台之间的联系(系列文章第二篇)

    这个系列的文章有四篇,其目的是为了搞清楚 : 进程,shell,shell进程,终端,控制终端,前台进程,后台进程,控制进程,前台进程组,后台进程组,会话,守护进程,init进程,用户进程,系统进程 它们之间的联系与区别 系列文章第一篇传送门:全面理解shell进程、终端

    2024年02月04日
    浏览(84)
  • 二:原神本地服务器(sifu)搭建环境配置教程第二篇

    安装jdk 双击msi安装文件,一路到底就欧克,傻瓜式安装。  安装数据库 也是一路yes,后面在安装界面会有一个询问你是否安装最新版,可选可不选,不选安装会快些 中间提示服务启动不成功也无所谓,可以忽略。后面会教你怎么开  安装代理器  双击开始安装一路yes就行

    2024年02月13日
    浏览(54)
  • 【Apache-StreamPark】Flink 开发利器 StreamPark 的介绍、安装、使用

    StreamPark 核心由 streampark-core 和 streampark-console 组成 之前我们写 Flink SQL 基本上都是使用 Java 包装 SQL,打 jar 包,提交到服务器上。通过命令行方式提交代码,但这种方式始终不友好,流程繁琐,开发和运维成本太大。我们希望能够进一步简化流程,将 Flink TableEnvironment 抽象出

    2024年02月02日
    浏览(34)
  • Websocket获取B站直播间弹幕教程——第二篇、解包/拆包

    教程一、Websocket获取B站直播间弹幕教程 — 哔哩哔哩直播开放平台 我们连接上B站Websocket成功后,要做两件事情: 第一、发送鉴权包。 第二、发送心跳包,每30秒一次,维持websocket连接。 这两个包不是直接发送过去,而是要创建 byte数组 ,将一些数据 按B站协议格式 用大端序

    2024年02月06日
    浏览(60)
  • 【Spring进阶系列丨第二篇】Spring中的两大核心技术IoC(控制反转)与DI(依赖注入)

    我们都知道Spring 框架主要的优势是在 简化开发 和 框架整合 上,至于如何实现就是我们要学习Spring 框架的主要内容,今天我们就来一起学习Spring中的两大核心技术IoC(控制反转)与DI(依赖注入)。 以经典的三层架构MVC作为案例,以前我们都是这么干的,看如下代码: 按照

    2024年02月05日
    浏览(70)
  • React18入门(第二篇)——React18+Ts项目配置husky、eslint、pretttier、commitLint

    我的项目版本如下: React: V18.2.0 Node.js: V16.14.0 TypeScript:最新版 工具: VsCode 本文将采用图文详解的方式,手把手带你快速完成在React项目中配置husky、prettier、commitLint,实现编码规范的统一,git提交规范的统一。 1.1 装包 1.2 ESLint 插件安装 1.3 创建命令并使用 新增命令 执行

    2024年02月08日
    浏览(56)
  • 【旅游景点项目日记 | 第二篇】基于Python中的Selenium爬取携程旅游网景点详细数据

    Gitee仓库地址:travel-server:景点旅游项目服务端 确保安装python3.x环境 以管理员身份打开cmd, 安装selenium、pymysql、datetime ,默认安装最新版即可 确保chrome安装对应版本的驱动 (将该驱动放在chrome安装路径下),用于控制chrome浏览器,并将路径添加到环境变量的Path变量中,如

    2024年04月13日
    浏览(55)
  • 第二篇【传奇开心果系列】Python的文本和语音相互转换库技术点案例示例:深度解读pyttsx3支持多种语音引擎

    pyttsx3是一个Python文本到语音转换库,可以将文本转换为语音并播放出来。它支持多种语音引擎,包括sapi5、nsss、espeak等。pyttsx3可以用于开发语音助手、自动化脚本、语音提示等应用程序。它具有简单易用的接口,可以灵活设置语音输出的音量、语速、声音类型等参数。如果

    2024年02月19日
    浏览(52)
  • Java项目实战笔记--基于SpringBoot3.0开发仿12306高并发售票系统--(二)项目实现-第二篇-前端模块搭建及单点登录的实现

    本文参考自 Springboot3+微服务实战12306高性能售票系统 - 慕课网 (imooc.com) 本文是仿12306项目实战第(二)章——项目实现 的第二篇,详细讲解使用Vue3 + Vue CLI 实现前端模块搭建的过程,同时其中也会涉及一些前后端交互的实现,因此也会开发一些后端接口;搭建好前端页面后,

    2024年03月26日
    浏览(58)
  • Vue基础第二篇

    总结: 1 写在data或method中的属性或方法,从vm中直接可以 . 出来 2 methods的函数中,如果想使用data或methods中的属性,直接this.名字  就可以了 示例: 总结: 1  v-on:事件名=\\\'函数\\\'-----》简写成  @事件名=\\\'函数\\\' 2 触发函数,可以传参数 示例: 标签上   name   id  class  src  href

    2024年02月08日
    浏览(46)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包