手机网站开发模板,做影视网站怎么挣钱,wordpress wpenqueuescript,wordpress建的网站由于第一次做实时#xff0c;所以踩坑比较多#xff0c;见谅(测试环境用的flink),小公司没有用到hadoop组件
一、踩坑记录
1:本地代码的flink版本是flink1.15.4#xff0c;生产环境是flink1.16.1#xff0c;在使用侧输出流时报错#xff0c;需要使用以下写法,需要使用Si…由于第一次做实时所以踩坑比较多见谅(测试环境用的flink),小公司没有用到hadoop组件
一、踩坑记录
1:本地代码的flink版本是flink1.15.4生产环境是flink1.16.1在使用侧输出流时报错需要使用以下写法,需要使用SideOutputDataStream不能用DataStream同时将pom下的flink版本切换为1.16.1
SideOutputDataStreamString tblHotelGuestSnapStreamDS processedDS.getSideOutput(tblHotelGuestSnaptag);
2: Oceanus环境运行flink时候会默认使用RocksDB State Backend,不需要再手动配置检查点
3:可以利用checkpoint检查点来保证数据的端到端一致
4:打包可以使用maven协助打包
5: bin/start-cluster.sh启动后测试环境的8081无法访问,需要修改flink-conf.yml的属性rest.bind-address: 0.0.0.0和rest.bind-port: 8081和rest.port: 8081,之后重启就可以访问
