<?xml version="1.0" encoding="utf-8" ?><rss version="2.0"><channel><title><![CDATA[Chain的博客]]></title><description><![CDATA[你的态度决定你的高度 时刻谨记，我们永远是前进路上的初学者]]></description><link>https://blog.csdn.net/mojir</link><language>zh-cn</language><generator>https://blog.csdn.net/</generator><copyright><![CDATA[Copyright &copy; mojir]]></copyright><item><title><![CDATA[Kafka 相关参数以及可靠性]]></title><link>https://blog.csdn.net/mojir/article/details/131774733</link><guid>https://blog.csdn.net/mojir/article/details/131774733</guid><author>mojir</author><pubDate>Mon, 17 Jul 2023 21:11:41 +0800</pubDate><description><![CDATA[Kafka 通过持久化消息到磁盘来保障消息存储的可靠性，但是消息都是先写到操作系统的页缓存中，如果没有fsync到磁盘，存在消息丢失的可能性Kafka 提供了两个参数来控制 Broker 的刷盘时机：long型，默认值null，单位ms，用于控制日志刷盘的时间间隔，每隔多少时间将消息刷到磁盘上long型，默认值9223372036854775807，用于控制日志刷盘的消息量，即每积累多少条消息将消息刷到磁盘上建议配置：#每当producer写入10000条消息时，刷数据到磁盘。]]></description><category></category></item><item><title><![CDATA[交换机loopback口]]></title><link>https://blog.csdn.net/mojir/article/details/130281172</link><guid>https://blog.csdn.net/mojir/article/details/130281172</guid><author>mojir</author><pubDate>Fri, 21 Apr 2023 09:43:52 +0800</pubDate><description><![CDATA[如果选择的是物理接口的IP地址，当这个物理接口状态变为Down时，系统也不会重新选择Router ID，除非这个被选择的IP地址被删除。为了保障服务器的安全，SNMP trap将Loopback接口的IP地址作为源IP地址，而不是出接口的IP地址。出于对NTP的安全考虑，NTP将Loopback接口的IP地址（而不是出接口的IP地址）作为源地址。通常配置为借用Loopback接口的地址，以保持接口的稳定性。配置RADIUS服务器时，使从该路由器始发的报文使用的源IP地址是Loopback接口的IP地址。]]></description><category></category></item><item><title><![CDATA[Flink-----任务调度slot和subtask配置]]></title><link>https://blog.csdn.net/mojir/article/details/130181106</link><guid>https://blog.csdn.net/mojir/article/details/130181106</guid><author>mojir</author><pubDate>Sun, 16 Apr 2023 15:50:54 +0800</pubDate><description><![CDATA[为了实现并行执行，Flink应用会将算子划分为不同任务，然后将这些任务分配到集群中的不同进程上去执行。和很多其他分布式系统一样，Flink应用的性能很大程度上取决于任务的调度方式。任务被分配到的工作进程、任务间的共存情况以及工作进程中的任务数都会对应用的性能产生显著影响。本节中我们就讨论一下如何通过调整默认行为以及控制作业链与作业分配（处理槽共享组）来提高应用的性能。其实这两个概念我们可以看作：资源共享链与资源共享组。]]></description><category></category></item><item><title><![CDATA[java动态加载jar包，并运行其中的类和方法]]></title><link>https://blog.csdn.net/mojir/article/details/129112859</link><guid>https://blog.csdn.net/mojir/article/details/129112859</guid><author>mojir</author><pubDate>Sun, 19 Feb 2023 18:10:35 +0800</pubDate><description><![CDATA[动态加载jar包，在实际开发中经常会需要用到，尤其涉及平台和业务的关系的时候，业务逻辑部分可以独立出去交给业务方管理，业务方只需要提供jar包，就能在平台上运行。第四：写个main函数测试下 TestMain (这里比较无聊，写了个从文件读的方式获取jar路劲，路径就是上面提到的jar所在的位置)第三：将TestAction所在的包导出成jar包的方式，eclipse中直接export即可，放到指定目录，此处放在。第二：改写下实体类，实现接口 TestAction。//第一种  配置成文件格式。]]></description><category></category></item><item><title><![CDATA[Jackson Infinite recursion solution]]></title><link>https://blog.csdn.net/mojir/article/details/128288259</link><guid>https://blog.csdn.net/mojir/article/details/128288259</guid><author>mojir</author><pubDate>Mon, 12 Dec 2022 15:45:08 +0800</pubDate><description><![CDATA[根据错误提示中的infinite recursion知道是无线递归错误导致了堆栈溢出，查找代码后发现，由于代码中订单实体类Order内包含了订单详情OrderDetail的对象集合List，而OrderDetail内也含有订单Order对象，因此订单和订单详情是一对多双向关联的关系，在Jackson序列化List属性时会无循环下去，导致stackoverflow。在对象的序列化上选择自己需要的属性就可，对于不需要的属性就可以通过加入注解的方式忽略。]]></description><category></category></item><item><title><![CDATA[Sql-拉链法]]></title><link>https://blog.csdn.net/mojir/article/details/126789691</link><guid>https://blog.csdn.net/mojir/article/details/126789691</guid><author>mojir</author><pubDate>Fri, 09 Sep 2022 22:01:40 +0800</pubDate><description><![CDATA[拉链表：维护历史状态，以及最新状态数据的一种表，拉链表根据拉链粒度的不同，实际上相当于快照，只不过做了优化，去除了一部分不变的记录，通过拉链表可以很方便的还原出拉链时点的客户记录。（也可以叫---缓慢变化维）4.表中的记录变化的比例和频率不是很大，比如，总共有1亿的用户，每天新增和发生变化的有200万左右，变化的比例占的很小。2.表中的部分字段会被update更新操作，如用户联系方式，产品的描述信息，订单的状态等等。1.有一些表的数据量很大，比如一张用户表，大约1亿条记录，50个字段，这种表。]]></description><category></category></item><item><title><![CDATA[【Flink】yarn集群模式]]></title><link>https://blog.csdn.net/mojir/article/details/126509444</link><guid>https://blog.csdn.net/mojir/article/details/126509444</guid><author>mojir</author><pubDate>Wed, 24 Aug 2022 18:41:19 +0800</pubDate><description><![CDATA[Linux - export 命令的生命周期 : 断开会话后 export 的环境变量不生效；支持会话级别的新增、删除和修改环境变量，用作之后的程序使用，仅仅用作此次会话期间；flink系列 转载自作者：Z尽际链接：https://www.jianshu.com/p/f63b7e1e6e09来源：简书著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。]]></description><category></category></item><item><title><![CDATA[【Flink】内存分布]]></title><link>https://blog.csdn.net/mojir/article/details/126489387</link><guid>https://blog.csdn.net/mojir/article/details/126489387</guid><author>mojir</author><pubDate>Tue, 23 Aug 2022 17:25:13 +0800</pubDate><description><![CDATA[相关配置详细说明: Flink ConfigFlink JVM 进程的进程总内存（Total Process Memory）包含了由 Flink 应用使用的内存（Flink 总内存）以及由运行 Flink 的 JVM 使用的内存。 Flink 总内存（Total Flink Memory）包括 JVM 堆内存（Heap Memory）和堆外内存（Off-Heap Memory）。 其中堆外内存包括直接内存（Direct Memory）和本地内存（Native Memory）。配置 Flink 进程内存最简单]]></description><category></category></item><item><title><![CDATA[【Flink】Checkpoint 基础（1）]]></title><link>https://blog.csdn.net/mojir/article/details/126466272</link><guid>https://blog.csdn.net/mojir/article/details/126466272</guid><author>mojir</author><pubDate>Mon, 22 Aug 2022 16:39:10 +0800</pubDate><description><![CDATA[Flink Checkpoint机制剖析(源码剖析)
]]></description><category></category></item><item><title><![CDATA[【Flink】Table\Sql API 笔记：Row和RowData]]></title><link>https://blog.csdn.net/mojir/article/details/126455871</link><guid>https://blog.csdn.net/mojir/article/details/126455871</guid><author>mojir</author><pubDate>Sun, 21 Aug 2022 21:56:05 +0800</pubDate><description><![CDATA[【Flink】Table\Sql API 笔记：Row和RowData]]></description><category></category></item><item><title><![CDATA[【Flink】 Table/Sql API ——join 探究 （1）]]></title><link>https://blog.csdn.net/mojir/article/details/126451521</link><guid>https://blog.csdn.net/mojir/article/details/126451521</guid><author>mojir</author><pubDate>Sun, 21 Aug 2022 15:48:05 +0800</pubDate><description><![CDATA[在数据库中的静态表上做 OLAP 分析时，两表 join 是非常常见的操作。同理，在流式处理作业中，有时也需要在两条流上做 join 以获得更丰富的信息。Flink DataStream API 为用户提供了3个算子来实现双流 join，分别是：1、join()；本章重点讲解regular join以及interval join，其中临时表join的话下一章补充在数据库中的静态表上做 OLAP 分析时，两表 join 是非常常见的操作。]]></description><category></category></item><item><title><![CDATA[【Flink】第二节 windows下运行]]></title><link>https://blog.csdn.net/mojir/article/details/126448050</link><guid>https://blog.csdn.net/mojir/article/details/126448050</guid><author>mojir</author><pubDate>Sun, 21 Aug 2022 10:41:28 +0800</pubDate><description><![CDATA[接上一节，flink编译ok了，但是我准备在windows上进行运行，但是好像1.10之后 start_cluster.bat没有了呢，这样我怎么运行呢，本节是准备这个问题。]]></description><category></category></item><item><title><![CDATA[【Flink】第一节 源码编译]]></title><link>https://blog.csdn.net/mojir/article/details/126430300</link><guid>https://blog.csdn.net/mojir/article/details/126430300</guid><author>mojir</author><pubDate>Fri, 19 Aug 2022 18:55:39 +0800</pubDate><description><![CDATA[认识以及改造flink的第一步从下载编译源码开始。]]></description><category></category></item><item><title><![CDATA[java awt实现拖拉式文件路径获取]]></title><link>https://blog.csdn.net/mojir/article/details/126396912</link><guid>https://blog.csdn.net/mojir/article/details/126396912</guid><author>mojir</author><pubDate>Thu, 18 Aug 2022 00:27:33 +0800</pubDate><description><![CDATA[java awt 拖拉式文件路径获取]]></description><category></category></item><item><title><![CDATA[SparkSession]]></title><link>https://blog.csdn.net/mojir/article/details/125751876</link><guid>https://blog.csdn.net/mojir/article/details/125751876</guid><author>mojir</author><pubDate>Tue, 12 Jul 2022 21:00:17 +0800</pubDate><description><![CDATA[123]]></description><category></category></item><item><title><![CDATA[92 反转链表 笔记]]></title><link>https://blog.csdn.net/mojir/article/details/125039272</link><guid>https://blog.csdn.net/mojir/article/details/125039272</guid><author>mojir</author><pubDate>Mon, 30 May 2022 01:09:26 +0800</pubDate><description><![CDATA[题目

给你单链表的头指针head和两个整数left和right，其中left &lt;= right。请你反转从位置left到位置right的链表节点，返回反转后的链表。

示例 1：




输入：head = [1,2,3,4,5], left = 2, right = 4
输出：[1,4,3,2,5]


示例 2：

输入：head = [5], left = 1, right = 1 输出：[5]

提示：

链表中节点数目为n
	1 &lt;= n &lt;= 5...]]></description><category></category></item><item><title><![CDATA[prometheus安装以及错误汇总]]></title><link>https://blog.csdn.net/mojir/article/details/123434390</link><guid>https://blog.csdn.net/mojir/article/details/123434390</guid><author>mojir</author><pubDate>Fri, 11 Mar 2022 21:26:05 +0800</pubDate><description><![CDATA[1、msg="Failed to create directory for logging active queries"

解决：对运行目录 chmod 777 XXX 增加权限，然后重新运行即可



其余异常参考：我在B站学运维之Prometheus监控所遇问题解决总结(11) - 哔哩哔哩
]]></description><category></category></item><item><title><![CDATA[npm运行命令时抛错]]></title><link>https://blog.csdn.net/mojir/article/details/123364935</link><guid>https://blog.csdn.net/mojir/article/details/123364935</guid><author>mojir</author><pubDate>Tue, 08 Mar 2022 22:26:25 +0800</pubDate><description><![CDATA[sudo npm uninstall npm -g

internal/modules/cjs/loader.js:1032
  throw err;
  ^

Error: Cannot find module 'semver'
Require stack:
- /Users/XXXX/tenv/node/v14.4.0/lib/node_modules/npm/lib/utils/unsupported.js
- /Users/XXXX/tenv/node/v14.4.0/lib/node_modul.]]></description><category></category></item><item><title><![CDATA[Flink的双亲委派机制]]></title><link>https://blog.csdn.net/mojir/article/details/123343481</link><guid>https://blog.csdn.net/mojir/article/details/123343481</guid><author>mojir</author><pubDate>Tue, 08 Mar 2022 00:46:31 +0800</pubDate><description><![CDATA[我们知道，在 JVM 中，一个类加载的过程大致分为加载、链接(验证、准备、解析)、初始化5个阶段。而我们通常提到类的加载，就是指利用类加载器(ClassLoader)通过类的全限定名来获取定义此类的二进制字节码流，进而构造出类的定义。

Flink 作为基于 JVM 的框架，在 flink-conf.yaml 中提供了控制类加载策略的参数 classloader.resolve-order，可选项有 child-first(默认)和 parent-first。本文来简单分析一下这个参数背后的含义。


pa]]></description><category></category></item><item><title><![CDATA[Protobuf 语言指南]]></title><link>https://blog.csdn.net/mojir/article/details/119517752</link><guid>https://blog.csdn.net/mojir/article/details/119517752</guid><author>mojir</author><pubDate>Sun, 13 Feb 2022 19:45:04 +0800</pubDate><description><![CDATA[以一个简单例子对pb进行展开讲解


syntax = "proto3"; 

package   rpc.rpcclient.rpccall;

option  java_package="com.ppp.mpj";
option  java_multiple_files = false; 
option  java_outer_classname  = "MpjBean"; 

// 建议使用谷歌protobuf规范 遵循PB语法检查 
// 谷歌protobuf规范地址：https://develop]]></description><category></category></item></channel></rss>