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 這次打算都選擇最新的版本 ...