九师兄-CSDN博客

原创【算法】工作难度、工作报酬、最高报酬的工作

为了找到自己满意的工作，牛牛收集了每种工作的难度和报酬。牛牛选工作的标准是在难度不超过自身能力值的情况下，牛牛选择报酬最高的工作。在牛牛选定了自己的工作后，牛牛的小伙伴们来找牛牛帮忙选工作，牛牛依然使用自己的标准来帮助小伙伴们。牛牛的小伙伴太多了，于是他只好把这个任务交给了你。给定一个Job类型的数组jobarr，表示所有的工作。给定一个int类型的数组arr，表示所有小伙伴的能力。返回int类型的数组，表示每一个小伙伴按照牛牛的标准选工作后所能获得的报酬.

2024-04-25 00:30:00 5

原创【Flink】flink启动任务，taskmanager.out 文件增涨非常快

flink启动任务，taskmanager.out 文件增涨非常快，这个文件大小怎么限定？测试了很多办法发现都不起作用。但是后面我发现不是这个导致的是slf4j依赖冲突，jar包删除就可以了。

2024-04-25 00:30:00 5

原创【算法】通用优化、斐波拉契数列套路、递归除了第一项都能优化成logN级别

视频：一周刷爆LeetCode，算法大神左神（左程云）耗时100天打造算法与数据结构基础到高级全家桶教程，直击BTAJ等一线大厂必问算法面试题真题详解

2024-04-25 00:15:00 6

原创【算法】数组切分后、两边最大值、绝对值相减最大

给定一个数组arr长度为N，你可以把任意长度大于0且小于N的前缀作为左部分，剩下的作为右部分。但是每种划分下都有左部分的最大值和右部分的最大值，请返回最大的，左部分最大值减去右部分最大值的绝对值。我们最简单的方法是从头开始遍历，然后每次切分后，遍历两边的最大值，然后计算，但是这样时间复杂度比较高。

2024-04-24 23:30:00 4

原创【算法】调整数组相邻的数字相乘是4的倍数

给定一个数组arr，如果通过调整可以做到arr中任意两个相邻的数字相乘是4的倍数，返回true；如果不能返回false。

2024-04-24 23:30:00 4

原创【算法】数组直方图装水问题

给定一个数组arr，已知其中所有的值都是非负的，将这个数组看作一个容器，，根据值画出的直方图就是容器形状，该容器可以装下5格水。，该容器可以装下2格水。请返回容器能装多少水。

2024-04-18 07:30:00 33

原创【Flink】Flink 消费 kafka流任务界面不显示指标，一直处于loading状态

今天使用docker构建了一个kafka单节点，脚本如下然后使用本地的简单代码的生产者和消费者是能处理数据的。然后准备运行flink程序。flink 1.13.0版本，我们的原先都是正常的，现在升级kafka版本从1.0 升级到3.6版本然后使用三个简单算子，现在输出算子都打印数据了，证明消费是没问题的，但是界面指标 12分钟了，还是在转圈查看接口调用发现接口都正常但是返回值都是无属性但是目前还不清楚是什么原因。升级了一下FLink，然后就好了。

2024-04-18 07:30:00 164 2

原创【Kafka】flink消费kafka报错 rebalanced and assigned the partitions to another member

场景：消费kafka写入hdfs时，要从spark任务迁移为flink任务消费，为保证不丢数据，用同一个groupid消费数据flink消费数据，提交不了offset到kafka，报错如下原因：kafka的消费模式分为此种场景会发生standalone consumer（assign()消费模式）与consumer group冲突。

2024-04-18 06:15:00 504 1

原创【算法】动态规划的空间压缩技巧

给你一个二维数组matrix，其中每个数都是正数，要求从左上角走到右下角。每一步只能向右或者向下，沿途经过的数字要累加起来。最后请返回最小的路径和。这里主要思考位置依赖。我们经常遇到动态规划需要你填写一张二维表，然后最后要最右下角的数据。

2024-04-18 06:00:00 30

原创【算法】顺时钟90度转动方形矩阵

给定一个正方形矩阵，只用有限几个变量，实现矩阵中每个位置的数顺时针转动。因为知道这个是一个正方形，假设以中心点X为中心旋转90度，那么。90度，比如如下的矩阵。

2024-04-17 06:30:00 128 1

原创【算法】使用zigzag方式打印矩阵、螺旋打印

用zigzag的方式打印矩阵，比如如下的矩阵。根据结果可以知道打印方式如下。

2024-04-17 04:15:00 34

原创【kafka】写入 kafka 有些数据能写入、有些数据不能写入

其实是对方kafka是个集群，但是他们只提供了一个ip给我们，然后只开了这个ip的网络策略。所以有些数据发送失败，有些成功[捂脸哭]这个问题我曾经遇到过类似的，但是这个博客找不到了，哪个博客里面描述的是，一个kafka集群，然后对方不让我们直接访问，而是给我们一个代理机器，然后我们访问代理机器，由代理机器转发，但是有问题，下次找到补个链接。

2024-04-16 09:08:29 32

原创【算法】二叉树权重和最大值

二叉树每个结点都有一个int型权值，给定一棵二叉树，要求计算出从根结点到叶结点的所有路径中，权值和最大的值为多少。

2024-04-15 21:30:00 21

原创【Flink】Flink 1.13版本升级到Flink 1.17版本

我是从Flink 1.13版本升级到Flink 1.17版本，因为flink 1.13版本是好的，各种任务都能运行，本次升级主要是包的问题，最主要的是Flink去掉了很多scala的依赖。这些包一定要引入，同时注意版本信息，建议打开flink源码，然后找到这个类，然后看看类的版本是什么。本章主要介绍Flink 1.13版本升级到Flink 1.16版本中间遇到的问题。可以看到从1.15版本开始去掉scala依赖的，本次升级大问题没有多少的。然后是引入的kafka相关的包。后面记录一下，要引入的包信息。

2024-04-13 07:00:00 172

原创【算法】给定数字转成字符串

将给定的数转换为字符串，原则如下：1对应日，2对应b，26对应z。例如12258可以转换为个数为5，编写一个函数，给出可以转换的不同字符串的个数。比如小结。

2024-04-13 06:00:00 46

原创【kubernetes】kubernetes 资源管理

本章节主要介绍yaml语法和kubernetes的资源管理方式资源管理介绍在kubernetes中，所有的内容都抽象为资源，用户需要通过操作资源来管理kubernetes。kubernetes的本质上就是一个集群系统，用户可以在集群中部署各种服务，所谓的部署服务，其实就是在kubernetes集群中运行一个个的容器，并将指定的程序跑在容器中。

2024-04-12 07:15:00 67 6

原创【kafka】Rolled new log segment at offset xxxx

但是上面那个图也说明数据量确实大了，后来发现他们此时有人正在备份数据库。然后他就以为 2ms一下子新增了 241405433条数据。关键是此时消费者的服务器就来了巨量的流量。

2024-04-12 07:00:00 226 2

原创【算法】双栈排序

然后我们把3弹出，然后判断能不能入栈，因为3大于2，所以3不能入栈，那么我们把2弹出放到原始栈，然后判断3能不能入栈，发现可以，那么入栈。然后我们把6弹出，然后判断能不能入栈，因为5小于6，所以6不能入栈，那么我们把5出栈，然后放到原始栈中，然后把6入栈。然后我们把5弹出，然后判断能不能入栈，因为5小于6，所以5能入栈，那么我们把5入栈。然后我们把2弹出，然后判断能不能入栈，因为2小于5，所以2能入栈，那么我们把2入栈。然后我们把2弹出，然后判断能不能入栈，因为2小于3，所以2能入栈，那么我们把2入栈。

2024-04-11 07:00:00 31 1

原创【Flink】Flink 1.17 报错 Failed to load web based job submission extension

我是从Flink 1.13版本升级到Flink 1.17版本，因为flink 1.13版本是好的，各种任务都能运行，本次升级主要是包的问题，最主要的是Flink去掉了很多scala的依赖。然后因为已经能运行起来了，我就想再次复现这个问题，然后将web.submit.enable改成true，然后也是能运行的，后面把最后加入的依赖也重新搞一下，结果发现无法复现了。关闭后我继续做后面的验证，然后主要是缺少包信息，后面把下图中的所有的包都引入之后，然后就不报错了。然后我找到这个控制参数，然后是否可以关闭呢？

2024-04-10 07:15:00 451 2

原创【Flink】Flink 使用 RocksDb 状态后端报错 File name too long

Flink 使用 RocksDb 状态后端，实现mongo数据整库写hudi，采用RocksDBStateBackend状态后端，checkpoint产生的文件名太长报错报错 File name too long，然后再往下我们发现报错的不是flink的包了，是RocksDb的包，而我们的路径是没有问题的，虽然长，但是也应该支持，因此可能是RocksDb的问题。注意截图中的RocksDb版本只是案例，不是本次报错的版本。后面升级了RocksDb就好了。

2024-04-10 07:00:00 154 1

原创【算法】给定节点数求能组合的二叉树个数

给定一个非负整数n，代表二叉树的节点个数。返回能形成多少种不同的二叉树结构我们先想象一下我们穷举一下，假设我们有N个节点此时树的个数是F(N-1)此时树的个数是F(N-2)因为左树只有一个节点，什么也做不了此时树的个数是因为左树有2个节点，可以做一些树的变换了。。。。。。。。。。。。。。。。。。。。。。。。。此时树的个数是因为左树有i个节点，可以做一些树的变换了。右边为啥是N-i-1呢？因为顶点还占用一个。最终全局变换图如下。

2024-04-08 08:45:00 45 2

原创【Flink】Flink 1.17 报错 RpcLoaderException: could not load RpcSystem

我是从Flink 1.13版本升级到Flink 1.17版本，因为flink 1.13版本是好的，各种任务都能运行，本次升级主要是包的问题，最主要的是Flink去掉了很多scala的依赖。我是从Flink 1.13版本升级到Flink 1.17版本，因为flink 1.13版本是好的，各种任务都能运行，本次升级主要是包的问题，最主要的是Flink去掉了很多scala的依赖。可以看到从1.15版本开始去掉scala依赖的，本次升级大问题没有多少的。然后到源码中看看，然后看到源码中是有实现类的。

2024-04-08 08:30:00 208 4

原创【kafka】kafka 2.8 版本的kafka topic 分区扩容、创建topic

今天要升级kafka客户端版本，我们的服务端版本是1.1.0，然后客户端版本要升级到kafka 2.8.2，有点不明白公司为啥死都不升级服务端版本，使劲升级客户端版本。今天升级后发现这里面的代码不能使用了，然后需要升级。

2024-04-07 23:00:00 63 1

原创【算法】两个集合取值平均数上升

给一个包含n个整数元素的集合a，一个包含m个整数元素的集合b。定义magic操作为，从一个集合中取出一个元素，放到另一个集合里，且操作过后每个集合的平均值都大大于于操作前。

2024-04-07 21:30:00 45

原创【算法】等概率加工问题

给定一个函数千，可以1～5的数字等概率返回一个。请加工出1～7的数字等概率返回一个的函数g。给定一个函数十，可以ad的数字等概率返回一个的函数g。给定一个函数f，以p概率返回0，a以1-p概率返回1。请加工出等概率返回0和1的函数g。

2024-04-03 07:15:00 62 1

原创【算法】二维矩阵中找最大的正方形、预处理

的矩阵matrix，只有0和1两种值，返回边框全是1的最大正方形的边长长度。其中边框全是1的最大正方形的大小为。

2024-04-03 05:00:00 58

原创【Kafka】Kafka 删除topic、然后重建会接着上次消费位置消费吗？

今天在群里遇到这样一个问题：flink 消费2个kafka topic a,b，状态成功保存在savepoint，途中删掉一个topic a，运行一会再把这个topic a加回来，这时候这个topic a 的状态就无法读取了，会重新消费, 但是偏移量是还保存在kafka _consumer_offsets 里面，有没有办法能让他继续从之前的offset 消费呢？这个问题，我们先拆分一下。

2024-04-02 14:54:47 311 4

原创【算法】滑动窗口绳子覆盖几个点

L往右边动一步，此时比较巧合，LR相等了，然后R往右边动一步，到达8的位置，然后判断8-4=4小于5，那么证明这个位置是可以走的，然后再次尝试往后面动一步，来到9的位置，9-4=5等于5，但是不是大于，也是可以走的，然后再次尝试到下一个节点12-4=8，大于5，所以不能走，停在位置9，然后计算这个窗口内有节点3个。因为如果你使用左侧，假设绳子长1万米，数组长1000万米，中间有100万个节点，然后其实最后的1万米内，往后，绳子压的点数只会越来越少，所以不必计算。把所有的都走一遍，那么结果肯定就在其中。

2024-04-02 06:15:00 52 1

原创【Flink】Flink 1.17 报错 No ExecutorFactory found to execute the application

我是从Flink 1.13版本升级到Flink 1.17版本，因为flink 1.13版本是好的，各种任务都能运行，本次升级主要是包的问题，最主要的是Flink去掉了很多scala的依赖。可以看到compatibleFactories为空的时候就会报错，然后这个集合是遍历loader加入的，因此看loader就好了。这就是类加载，加载PipelineExecutorFactory这个的实现类，在项目中我的是没有实现类的。然后我们看看yarn运行是哪个包，可以看到是在flink-yarn包中。

2024-04-02 06:00:00 289

原创【算法】双栈实现综合计算器

本次打算从算法的角度使用栈实现计算器。。这里我们可以使用双栈来实现这个功能。我们现在有2个栈一个用来存放数据的，一个用来存放操作符的。

2024-04-01 08:54:30 39 1

原创【Flink】restored state is lower than the configured parallelism

有个环境我想从savepoints恢复，但是修改了并行度，然后报错：首先这个是从savepoint恢复会调用restoreLatestCheckpointedStateInternal,在里面会调用assignStates然后在里面调用 assignAttemptState 重新分配状态checkParallelismPreconditions这里是主要的然后这里就是报错的地方了

2024-03-29 06:45:00 454 2

原创【java】Trie树及Java实现 Trie树(字典树)的介绍及Java实现

我是在我们项目中发现有人使用这个字典树的，因为没有见过，所以来学习一下。Trie树，又称为前缀树或字典树，是一种有序树，用于保存关联数组，其中的键通常是字符串。【这点很重要：位置决定】。一个节点的所有子孙都有相同的前缀，也就是这个节点对应的字符串，而根节点对应空字符串。典型应用是用于统计和排序大量的字符串（但不仅限于字符串），所以经常被搜索引擎系统用于文本词频统计。如下是一棵典型的Trie树:Trie的来源是Retrieval,它常用于前缀匹配和词频统计。

2024-03-29 05:45:00 206 2

转载【算法】第一届排序算法性能大赛

转载：第一届排序算法性能大赛仅供自己学习，转载为了防止丢失，不整理格式。写在前面最近学到了一些重要的排序，并且简单地测了一下各种排序算法在不同的算法实现、优化以及递归和非递归下的运行速度。本文一共提及了以下几种常用到的排序，其他排序使用场景较少，便没有提及。并且本文的全部代码实现均为通俗易懂的c语言，如果觉得本文不错的话，欢迎三连哦。必备排序常识稳定性：在原序列中，r[i]=r[j]，且r[i]在r[j]之前，而在排序后的序列中，r[i]仍在r[j]之前，则称这种排序算法是稳定的；否则称为不稳定的

2024-03-29 01:00:00 58

空空如也

TA创建的收藏夹 TA关注的收藏夹

TA关注的人

Eclipse Formatter 模板 Formatter.xml

Drools-复杂事件处理

excel操作包

eclipse的hadoop插件

hadoop学习文档

hadoop单结点

hadoop单结点配置

native_32位

s2sh整合配置，非常适合初学者，明白配置流程

打飞机代码

空空如也