Flink运行时架构

Flink On yarn

Kafka Rebalance解决方案

Kafka分区策略

Flink Slot

Maven 镜像指向本地仓库

普通的Java项目 不使用Maven添加依赖步骤1.创建Java项目;2.在Java项目中创建一个文件夹，名字:lib3.把需要引入的依赖放到这个lib文件夹中;4.点击...

Flink SavePoint 和Checkpoint的区别

Flink调优

Maven打包出错

数仓概念

Lambda架构

Starrocks24小时不简单服务

实时计算与离线计算介绍

SQL优化

Mysql索引选型

Flink Checkpoint问题排查

线程的生命周期

Kafka相关的问题解答

Mysql相关函数

Flink重启策略

Flink Checkpoint失败

ConcurrentMap详解ConcurrentMapConcurrentMap是一个线程安全的Map,可以防止多线程并发安全问题.HashTable也是线程安全的,但...

为什么 HashMap 是线程不安全的？三方面原因：多线程下扩容会死循环、多线程下 put 会导致元素丢失、put 和 get 并发时会导致 get 到 null，我们来...

Java集合–HashMap解惑今天，笔者要介绍的是Java集合框架中的Map集合，在日常工作中Map的运用也十分广泛。与List集合、Set集合隶属于Collectio...

Java 深度遍历与 广度遍历

Java 手写线程池

1. uple拉链操作指的就是zip操作2. zip操作，是Array类的方法，用于将两个Array，合并为一个Array比如Array(v1)和Array(v2)，使用...

import java.util.HashMap;import java.util.Hashtable;import java.util.Map;import org.j...

Flink读取HDFS通过Kerberos

Java代码通过Kerberos连接hdfs

Kerberos常用命令

CDH出现时间不同步问题

密集索引和稀疏索引的区分在与是否为每个索引键的值都建立索引，简单来说就是比如有一列的值如下:1、2、3、4、5、6、7密集索引的做法是为这7个值建立索引记录，那么就有7条...

第一步:Flink任务提交后，Client向HDFS上传Flink的Jar包和配置第二步:之后向Yarn ResourceManager提交任务，ResourceMana...