Flink开发部署踩坑记录
~~~~踩坑一：springboot+flink项目的日志问题~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ 现象：开发环境IDE里调试运行都ok，部署到flink服务器上运行报如下错误： The main method caused an error ...
原文：Flink Java踩坑记录（Flink1.10.0）
记录一下使用Flink进行编程的采坑经历 最后一次更新： 年 月 日 场景 使用Flink，从阿里云的AMQP中获取数据，然后直接写入到InfluxDB中。即： source：amqp sink：influxdb 环境 Linux：Centos . Hadoop： . . Flink： . . Java： . . InfluxDB： . . RocketMQ： . . 数据流 踩坑 错误日志如下： ...
2020-03-16 19:37 0 14936 推荐指数：
相关推荐
Apache Flink 1.10.0
Apache Flink 社区迎来了激动人心的两位数位版本号，Flink 1.10.0 正式宣告发布！作为 Flink 社区迄今为止规模最大的一次版本升级，Flink 1.10 容纳了超过 200 ...
flink爬坑记录一
问题一 使用命令提交flink任务 flink run -c com.lezhi.business.dxxbs.transmission.ExecuteDML /data/jar/gkt-bigData-flink ...
Flink-1.10.0中的readTextFile解读
Flink-1.10.0中的readTextFile解读 最近在学习Flink，研究了一些东西，在准备自定义一个简单的监听文件的source作为练手的时候，遇到了一个问题。就是应该如何在自己的source中决定哪个分区读取哪个文件？学习过spark的我们知道，source会被切分，然后每个分区 ...
Ubuntu16.04安装flink-1.10.0
://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.10.0/flink ...
Java踩坑记录
1.Collections.copy方法，报错Source does not fit in dest 解决：https://www.cnblogs.com/jingLongJun/p/4491038. ...
Java ArrayList 踩坑记录
做编程的一个常识：不要在循环过程中删除元素本身（至少是我个人的原则）。否则将发生不可预料的问题。 而最近，看到一个以前的同学写的一段代码就是在循环过程中删除元素，我很是纳闷啊。然后后来决定给 ...
Flink On Yarn安装部署笔记（flink-1.10.0，Hadoop2.10.1）
【背景】 好几年没搞Hadoop了，最近需要用Flink，打算搞一搞Flink On Yarn。 下面这篇是几年前安装HBase的笔记，也包含了Hadoop的安装。 https://www.cnblogs.com/quchunhui/p/7411389.html 这次打算都选择最新的版本 ...