【Flink系列二】構建實時計算平台——特別篇，用InfluxDb收集Flink Metrics
Influxdb 快速入門 原文地址：https://www.cnblogs.com/slankka/p/13865338.html 從Docker啟動 Influxdb 進入Influxdb的Client 配置Flink Flink ifluxdb reporter ...
原文：【Flink系列三】構建實時計算平台——特別篇，Influxdb Java客戶端訪問指標數據
Influxdb Java客戶端 Influxdb 的Docker版本目前最高是 . . . 官方最高版本是 . . Note: We recommend using the new client libraries on this page to leverage the new read via Flux and write APIs and prepare for conversion to ...
2020-10-29 17:24 1 585 推薦指數：
相關推薦
【Flink系列八】構建實時計算平台——動態加載UDF
前言 本文首發自https://www.cnblogs.com/slankka/ 轉載請注明出處。 本文的主要內容是介紹如何動態加載Flink作業的UDF。 Classloader 加載UDF一定是classLoader做的，而作業啟動的過程中，App ClassLoader的具體實現類 ...
【Flink系列七】構建實時計算平台——校驗FlinkSQL
前言 FlinkSQL 和常見的SQL一樣，也分為 DDL,DML,DQL,DCL。 本文的主要內容是探討如何利用FlinkAPI 對多行SQL語句進行校驗。 SQL語言共分為四大類：數據查詢語言DQL，數據操縱語言DML，數據定義語言DDL，數據控制語言DCL。 以下是幾個 ...
【Flink系列一】構建實時計算平台——Flink開啟Checkpoint，以及從Checkpoint恢復
前言 Flink提供了Checkpoint/Savepoint來保存狀態，以便在出錯時進行恢復，在上一個狀態的基礎上恢復計算流程。 問題 1. 如何開啟Checkpoint？ Flink-Checkpointing 2. 如何從Checkpoint恢復？ Checkpoint恢復 ...
【Flink系列六】構建實時計算平台——Flink 1.10+通過Kerberos連接HiveCatalog
背景 因為要開發Flinksql，決定要使用HiveCatalog的支持，Flink當前最新版本是1.12.2，集群Hive的版本是1.1.0，而且需要用某個Linux用戶進行代理。 在實際開發中，遇到兩個問題： Hive 1.1.0 使用的不是jdbc ...
【Flink系列四】構建實時計算平台——Flink SQLClient啟動失敗的問題筆記
問題 報錯 org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory ...
【Flink系列零】構建實時計算平台——FlinkSQL 作業菜鳥筆記
前言 因為最近的需求是做FlinkSQL平台，需要在實時計算平台上集成FlinkSQL功能，但目前剛剛有了研究成果，所以有了這篇筆記。 第一步：編寫一個流 這里使用python編寫的一個流，比Java簡潔。 需要注意的是 pip install kakfa-python，不能是 pip ...
客戶端埋點實時OLAP指標計算方案
背景 產品經理想要實時查詢一些指標數據，在新版本的APP上線之后，我們APP的一些質量指標，比如課堂連接掉線率，課堂內崩潰率，APP崩潰率等指標，以此來看APP升級之后上課的體驗是否有所提升，上課質量是否有所提高，為下一步的APP升級做准備。 客戶端埋點 1.0版本設計 流程 按照需求 ...