李小李的路

基于flink-1.8.1 概述 parallelism指的是并行度的意思。在 Flink 里面代表每个任务的并行度，适当的提高并行度可以大大提高 job 的执行效率，比如你...

本来无一物_f1f2

用 Chrome 发请求 打开 Network 地址栏输入网址 在 Network 点击，查看 request，点击「view source」终于点了？可以看到请求的前三部分...

骑着乌龟去看海

概述   首先，Priority翻译之后是优先级的意思，而PriorityQueue，也就是优先级队列的意思。优先级队列，和普通的先进先出（FIFO）的队列不同，优先队列每次...

仰望夜空一万次

本文介绍如何在mac电脑端安装flink、运行flink自带exmaple。 唯一的前置条件为电脑端安装Java 8.x 。mac电脑端安装flink命令： 查看flink安...

仰望夜空一万次

导读：本文介绍如何使用hbase自带的HexStringSplit算法，根据传入参数（最小值、最大值、分区数量）生成startKey,endKey为16进制表示的region...

仰望夜空一万次

创建预分区表的代码： 执行代码后，table的region分布如下： 当我们使用十六进制的字符作为rowkey前缀的时候，就会发生热点分区的问题。记录都会集中在如下四个reg...

哪天改改

yarn默认只管理内存资源,虽然也可以申请cpu资源,但是在没有cpu资源隔离的情况下效果并不是太好.在集群规模大,任务多时资源竞争的问题尤为严重.还好yarn提供的Linu...