【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版本设计 流程 按照需求 ...