发简信
IP属地：陕西
-
算法系列-动态规划(1)：初识动态规划昨天，罗拉去面试回来，垂头丧气。显然是面试不顺利，我赶忙过去安慰。 经过询问才知道，罗拉面试挂在了动态规划。 说到动态规划，八哥可就来精神了，于...
-
算法系列-动态规划(2)：切割钢材问题
切割钢材问题 接上回说到，斐波那契数列是动态规划最简单应用，但动态规划却不是为了用来算那数列。 当时留了个尾巴，就是切割钢材的问题。 不同长度的...
-
ExceptionInChainedOperatorException：flink写hbase对于null数据导致数据导致出现异常
使用的flink版本：1.9.1 异常描述 需求： 从kafka读取一条数据流 经过filter初次筛选符合要求的数据 然后通过map进行一次条...
-
flink自定义窗口分配器 周、月关于分配器介绍内容来自官网 窗口分配的概念 窗口分配程序（Window Assigners）定义如何将元素分配给窗口。通过window(...)...
-
二叉树的遍历实现递归与非递归本文实现了二叉树的深度遍历算法，分为递归与非递归 递归的实现非常简单，基本上没啥难度 非递归的实现需要根据遍历的顺序，将递归转换成循环 代码中的...
-
flink 自定义触发器 定时或达到数量触发flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触...
-
hbase-spark bulk load(二)概述 之前写过spark批量导入Hbase的案例：Spark、BulkLoad Hbase、单列、多列，实现了多列的操作。整个过程涉及到排序、分...
-
Flink 1.9 FlinkKafkaProducer 使用 EXACTLY_ONCE 错误记录
使用flink FlinkKafkaProducer 往kafka写入数据的时候要求使用EXACTLY_ONCE语义本以为本以为按照官网写一个就...
-
flink idea运行错误记录
最近学习flink的时候写了最简单的一个demo,但是在测试的时候出现问题：org.apache.flink.util.FlinkExcepti...