Flink 版本: 1.14.2 HA集群环境规划 使用三台节点实现两主两从集群 Jobmanager:node1,node2 一个active,一个standby Taskmanager:node1,node2 Zookeeper: node1,node2,node3 ...
Continue readingFlink版本:1.14 Hudi版本:0.8.0 背景 测试发现当使用MOR(Merge On Read)表的时候写入速度很慢 问题原因 对环境和代码进行分析,发现有2个问题 测试环境使用的是虚拟机,IO速度很慢 Hudi代码有问题 下面对代码问题进行分析 问题分析 ...
Continue readingFlink版本:1.14 SSL连接问题 javax.net.ssl.SSLHandshakeException: No appropriate protocol (protocol is disabled or cipher suites are inappropriat...
Continue readingHudi版本:0.8.0 Source参数 参数名 必填 默认值 类型 说明 path 是 无 string hudi表路径 partition.default.name _DEFAULT_PARTITION_ string 如果动态分区列的值为空或nu...
Continue reading1. Hudi简介 Hudi表示Hadoop Upserts Deletes and Incrementals,用于管理HDFS上的大型分析数据集存储。 Hudi的主要目的是高效的减少入库延时。 Hudi是Uber开发的一个开源项目。 2. 存储类型 Hudi支持以下存储类...
Continue reading使用Offset Explorer 2.0新增Kafka topic,每个topic 32个partition,增加到第三个的时候显示创建成功,但是在topic列表中没有该topic,CDH上Kafka状态出现There are 3 offline partitions 在...
Continue reading流处理应用程序通常是有状态的,“记住”已处理事件中的信息,并使用它来影响进一步的事件处理。在Flink中,记住的信息,即状态,被本地存储在配置的状态后端中。为了防止发生故障时丢失数据,状态后端会定期将其内容的快照持久化到预先配置的持久存储中。RocksDB状态后端(即Roc...
Continue reading一、背景 国家信息安全漏洞库(CNNVD)收到关于Apache Flink安全漏洞(CNNVD-202101-271、CVE-2020-17519)(CNNVD-202101-273、CVE-2020-17518)情况的报送。成功利用漏洞的攻击者,可在未授权的情况下,构造恶...
Continue reading