Flink 1.10 SQL 写 Hbase 数据无法写入hbase问题
接之前的：Flink 1.10 SQL 写HBase 有朋友看了之前的 sql 写 Hbase 的博客，自己试了写，可能没有得到预期的结果 之前在捣腾的时候，也花了不少时间，这里大概写下遇到的两个问题 1、hbase 表参数问题 我们有多套hbase 集群，之前 ...
原文：Flink 1.10 SQL 写HBase
Hbase 也是我们很常用的数据存储组件，所以提前尝试下用SQL 写Hbase，中间也遇到一些坑，跟大家分享一下。 官网地址：https: ci.apache.org projects flink flink docs release . dev table connect.html hbase connector 新增：Flink . SQL 写 Hbase 数据无法写入hbase问题 HBas ...
2020-03-23 08:45 6 5400 推荐指数：
相关推荐
Flink 1.10 SQL 写ElasticSearch
官网对应页面：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#elasticsearch-connector Flink SQL ElasticSearch connector ...
Flink sql 写 Hbase 忽略空列
数仓场景下，经常有两个表 Join 后往一个宽表写数据。比如：埋点数据中只包含 user_id，但是下游计算的需要使用用户的其他属性，就需要将埋点数据和用户数据做关联。 实时场景，需要做流表 Join，用埋点数据的 user_id 去全量用户表中取用户属性。 如果两部分数据产生的顺序不确定 ...
Flink Batch SQL 1.10 实践
Flink作为流批统一的计算框架，在1.10中完成了大量batch相关的增强与改进。1.10可以说是第一个成熟的生产可用的Flink Batch SQL版本，它一扫之前Dataset的羸弱，从功能和性能上都有大幅改进，以下我从架构、外部系统集成、实践三个方面进行阐述。 架构 Stack ...
Flink 1.10 SQL 读写Kafka
最近因为疫情的原因，偷了好长时间的懒，现在终于开始继续看Flink 的SQL 了 ———————————————— 电脑上的Flink 项目早就升级到了 1.10了，最近还在看官网新的文档，趁着周末，体验一下新版本的SQL API（踩一下坑）。 直接从之前的 云邪大佬的Flink ...
Flink系列之1.10版流式SQL应用
随着Flink 1.10的发布，对SQL的支持也非常强大。Flink 还提供了 MySql, Hive，ES, Kafka等连接器Connector，所以使用起来非常方便。 接下来咱们针对构建流式SQL应用文章的梗概如下： 1. 搭建流式SQL应用所需要的环境准备。 2. ...
Flink 1.10 SQL 自定义KafkaUpsertSink
在 Flink 1.10 中SQL正式生产，在尝试使用的时候，遇到了这样的问题： KafkaTableSink 的 'update-mode' 只支持 ‘append’，如下面这样： 看起来好像没问题，因为kafka 也只能往里面写数据，不能删数据 官网链接：https ...
Flink SQL 写 hudi
# Flink SQL 写 hudi 最近在做一个数据湖项目，基于 Hudi 的湖仓一体项目，计算引擎是 Flink + Spark 之前稍稍研究了一下数据湖的三个主要技术组件 IceBerg，以为可能会用，在网上看资料的时候，同样也发现，IceBerg 对 Flink 比较亲和，Hudi ...