前言 今天在使用自己搭建的虚拟机测试时，发现3台zookeeper中有一台起不来，具体情况如下： 故障节点 但是jps查看进程的时候没有，其他2...

题目 给定 n 个非负整数表示每个宽度为 1 的柱子的高度图，计算按此排列的柱子，下雨之后能接多少雨水。 输入：height = [0,1,0,...

前言 与DataStream同样，官方在Flink SQL上也提供了很多连接器，今天来学习总结一下JDBC连接器 环境准备 如果使用编码，需要引...

前言 能翻到这篇博文的，想必大家对窗口函数的基本使用已经有了一定的了解，这里就不废话再去多说了。 这篇博文主要讲的是，如果在窗口函数中加入whe...

前言 Flink使用Web UI可以方便本地调试，基本使用如下： pom添加 代码中使用createLocalEnvironmentWithWe...

前言 如果只是为了开发测试，本地搭建一个单机ES是一个不错的选择，本文总结了如何搭建单机版的ES并测试。 环境： mac os 10.15.7 ...

问题 在安装完Hadoop Lzo后。进入spark-sql shell 正常，但是执行查询语句时候，抛出： Caused by: java.l...

前言 今天在群里看到了一个小伙伴提的一个SQL需求： 把一列分为10个区间，按最大值和最小值去分区间，然后统计区间数据量。 emmm，感觉和之前...