源码 过程flink rpc
RPC学习
RPC RPC入门 RPC是远程过程调用的简称，是分布式系统中不同节点间流行的通信方式。在互联网时代，RPC和IPC一样成为一个不可或缺的基础构件。 RPC传输协议 消息序列化与反序列化 ......
记录一次K8s pod被杀的排查过程
问题描述 今天下午运维反馈说我们这一个pod一天重启了8次，需要排查下原因。一看Kiban日志，jvm没有抛出过任何错误，服务就直接重启了。显然是进程被直接杀了，初步判断是pod达到内存上限被K8s oomkill了。 因为我们xmx和xsx设置的都是3G，而pod的内存上限设置的是6G，所以出现这 ......
Flink 简介
Apache Flink是一个分布式流处理器，具有直观和富有表现力的API，可实现有状态的流处理应用程序。它以容错的方式有效地大规模运行这些应用程序。 Flink于2014年4月加入Apache软件基金会作为孵化项目，并于2015年1月成为顶级项目。从一开始，Flink就拥有一个非常活跃且不断增长的 ......
俄罗斯方块诞生30周年：作者回顾创作过程
俄罗斯方块诞生30周年：作者回顾创作过程 投递人 itwriter 发布于 2014-06-06 18:20 评论(0) 有445人阅读 原文链接 [收藏] « » 导语：今天，是俄罗斯方块诞生 30 周年，“俄罗斯方块之父”阿列克谢·帕基特诺夫(Alexey Pajitnov)撰文，对这款经典游戏 ......
开发过程中管理多个项目不同的Node版本，使用.sh脚本实现
本地会开发多个不同的 NodeJS 项目，每个项目可能需要的 Node 版本不同，有的老项目还在用 10.xx ，有的要求 12.xx/14.xx/16.xx/18.xx 。 总之，每个项目都需要不同的 Node 版本。很多时候我都是在启动项目遇到报错了才会意识到要切换 Node 版本。 1、在项目 ......
修改Zabbix源码实现监控数据同时写入数据库和ES集群
写在开篇 玩过 Zabbix 的朋友都了解，Zabbix 提供了与 Elasticsearch（ES）的集成，允许用户将历史数据存储在 Elasticsearch 中，而无需使用传统数据库。在高监控负载的生产环境中，这种架构带来了多重好处。首先，它有效减轻了数据库的负担，从而提高了整体性能。其次，通 ......
JCF相关基础类接口/抽象类源码阅读
目录简介代码分析IteratorIterableCollectionAbstractCollectionListAbstractListItr（Iterator的实现）ListItr（ListIterator的实现）SubListRandomAccessSubList参考链接 本人的源码阅读主要聚焦 ......
flink小记
Flink核心概念 1、Flink是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架 2、Flink底层是以Java编写的，并为开发人员同时提供了完整的Java和Scala API。 3、Flink运行时包括JobManager（Master）和TaskManager（Work ......
【火爆】抖音同款音乐圣诞树源码
1. 音乐圣诞树 可以选择默认背景音乐，也可以上传喜欢的音乐，稍等片刻，灯光会跟随音乐变化 2. 绿色圣诞树 比较简单，圣诞树会旋转，有雪花飘落 3. 圣诞快乐圣诞树 “圣诞节快乐字体会逐一闪亮”，下面圣诞树会旋转，但是会有交替 3. 纸圣诞树 圣诞树会旋转，有雪花飘落，圣诞树上面文字可修改 5. ......
MySQL运维实战（1.3）安装部署：源码编译安装
作者：俊达 引言 在大多数情况下，我们不需要自己编译MySQL源码，因为编译的MySQL和二进制包的内容基本一致。然而，有些特殊情况可能需要我们采用源码编译的方式安装MySQL： 安装非标准版本的MySQL：有些特殊的应用场景会使用到MySQL的非标准版本，这时候我们就需要编译源码来安装。 安装社区 ......
一款神仙级SpringCloud微服务开源项目，接私活吊到不行！(附源码)
一个由商业级项目升级优化而来的微服务架构，采用SpringBoot 2.7 、SpringCloud 等核心技术构建，提供基于React和Vue的两个前端框架用于快速搭建企业级的SaaS多租户微服务平台。 ......
【源码系列#05】Vue3响应式原理（Ref）
proxy 只接受对象入参，所以我们需要 ref 来解决值类型的数据相应。如果传入 ref 的是一个对象，内部也会调用 reactive 方法进行深层响应式转换 ......
如何解决企业在绩效管理过程中目标设定不清晰的问题？
目标清晰对于企业至关重要，它能够为企业和员工提供明确的方向，提高工作效率，增强团队合作，为绩效评估提供客观依据，并促进持续改进。确保目标的清晰和具体是实现有效绩效管理的基础，有助于推动企业的整体发展和成功。 如果企业的目标不清晰，会导致迷失发展方向、资源浪费、团队合作受阻、员工士气低落、错失市场机会 ......
匿名过程与函数的使用
1、在{$mode objfpc}{$H+} 后加{$ModeSwitch ANONYMOUSFUNCTIONS} 2、例子 如 Application.QueueAsyncCall(procedure (Data:PtrInt) var i:Integer; begin i:=1;i:=2 end ......
MySQL面试题：一条SQL语句在MySQL中执行过程全解析
一 .MySQL 基础架构分析 介绍一下下图涉及的一些组件的基本作用帮助大家理解这幅图。 连接/线程处理（连接器）： 身份认证和权限相关(如连接处理、授权认证、安全等等)。 查询缓存: 执行查询语句的时候，会先查询缓存（MySQL 8.0 版本后移除）。 解析器: 没有命中缓存的话，SQL 语句就会 ......
【OpenCV】在MacOS上源码编译OpenCV
【OpenCV】在MacOS上源码编译OpenCV 合集 - opencv(1) 1.【OpenCV】在MacOS上源码编译OpenCV01-03 收起 前言 在做视觉任务时，我们经常会用到开源视觉库OpenCV，OpenCV是一个基于Apache2.0许可（开源）发行的跨平台计算机视觉和机器学习软 ......
ASR项目实战-交付过程中遇到的内核崩溃问题
当前参与交付的语音识别产品服务，算法模块基于经典的Kaldi，算法中的一部分运行在GPU之上。 算法团队采用的是声学模型+语言模型的1-pass方案。这个方案的特点在于，语言模型数据文件（HCLG文件）的大小，和训练语料的丰富程度正相关，即语言文本的语料越多，经过训练、转换后得到的语言模型文件越大。 ......
PLSQL存储过程中异常的传递
1.PLSQL异常处理的几个原则 异常是指程序在编译时不能被发现，而在运行时出现的错误，异常处理可以使程序正常结束 ，并且可以灵活指定异常处理动作。 异常的作用域是本异常所覆盖的语句块或部分语句块，对于嵌套的语句块，外部定义的异常适用于处理所有内部块中所匹配出现的异常； 异常出现后，在块中直接跳到异 ......
NS-3源码学习（九）OFDMA
OFDMA是802.11ax为了适配室内多用户场景而运用的物理层技术，其原理是将原本的OFDM信道划分为更小的单位（即RU），这样就能让一个信道同时为多个站点提供数据传输的服务。不过在这种传输方式中，这些RU并不能被自由的使用，他们必须同步传输，即在同一个channel的RU在同一时刻必须是同一个数 ......
Flink的常用算子以及实例（详解）(赞)
Flink的常用算子以及实例（详解）(赞) 友情提示：本次博文所有源码均在下方，点击关注就能下载，免费的 点这里获取配套源码 1. map 特性：接收一个数据，经过处理之后，就返回一个数据 1.1. 源码分析 我们来看看map的源码 map需要接收一个MapFunction<T,R>的对象，其中泛型 ......
11-flink如何正确分流
11-flink如何正确分流 11-flink如何正确分流 分流方式 filter分流 split分流 (只能一次分流，分流后的流不能继续分流) side output分流 (推荐使用) 场景 flink-分流场景.png 输入数据： {"key":"001","type":"1","data":" ......
Flink SideOutput 和 Filter 分流对比
Flink SideOutput 和 Filter 分流对比 Flink 分流有Filter、Split（已经废弃移除）、Side Output进行分流，到底时有什么区别，哪个种更好呢？ 对比 代码对比 直接上代码对比： import org.apache.flink.streaming.api.d ......
flink入门1-Flink使用socketTextStream对接netcat完成入门demo
flink入门1-Flink使用socketTextStream对接netcat完成入门demo 一、flink介绍 1、flink是什么 flink是一个面向流处理和批处理的分布式计算框架，即支持流处理，也支持批处理。flink基于流处理引擎实现，正真做到了流处理，将批处理看作一种特殊的有界流fl ......
Volcano 原理、源码分析（二）
0. 总结前置 1. 概述 2. 寻找调度器中的 PodGroup 2.1 从 PodGroup 到 JobInfo 的封装 2.2 从 Pod 到 TaskInfo 的封装 3. 控制器中 PodGroup 和 Pod 的创建逻辑 3.1 从 main 开始寻找 SyncJob 的踪迹 3.2 S ......
Flink CDC写入数据到kafka几种格式
Flink cdc写入kafka数据格式 主要记录flink cdc写入kafka几种常见的数据格式，其中包括upsert-kafka写入后正常的json格式，debezium-json格式以及changelog-json格式。 upsert-kafka 正常json数据格式 -- insert 操 ......
JUC源码学习系列03
Synchronized 什么是 Synchronized：这是 Java 控制多线程访问共享资源的一种方式，是线程之间通信的一种方式。 什么同步代码块：同步代码块用于阻止多个线程同时对同一方法中的部分代码进行访问。 理解起来，可以看成同步代码块相当于一个保护共享资源的一块区域，这个区域需要有特定身 ......
在windows上安装 docker容器的过程
本文为第一次记录,有遗漏问题,欢迎交流,主要用于记录,方便以后操作 先找到了微软官网教程 https://learn.microsoft.com/zh-cn/virtualization/windowscontainers/quick-start/set-up-environment?tabs=do ......
【OpenCV】在MacOS上源码编译OpenCV
在做视觉任务时，我们经常会用到开源视觉库OpenCV，OpenCV是一个基于Apache2.0许可（开源）发行的跨平台计算机视觉和机器学习软件库，它具有C++，Python，Java和MATLAB接口，并支持Windows，Linux，Android和Mac OS。最近在项目中，我遇到了在MacOS... ......
配置中心Apollo源码分析
一、环境搭建 1、下载源码：https://gitee.com/apolloconfig/apollo.git 2、以1.8.2版本为例，切到1.8.2分支，scripts文件夹下有两个sql文件apolloconfigdb.sql，apolloportaldb.sql，放入数据库执行 3、配置启动 ......