小记flink

针对为什么传一级空指针进函数不会改变指针的指向而引发的思考 首先先看下面的错误代码 1 #include <iostream> 2 using namespace std; 3 #include <stdlib.h> 4 #include <string.h> 5 void func(int *p) ......

1 问题描述 1.1 基本信息 所属环境：CN-PT 问题时间：2023-11-21 所属程序: Flink Job(XXXPT_dimDeviceLogEventRi) 作业类型： Flink SQL Job 数据流 : 业务MySQL ==> Flink Job( Flink Cdc Conne ......

发topic代码，创建交换器，数据直接按routingKey发送到交换器中： using (var connection = factory.CreateConnection()) { using (var channel = connection.CreateModel()) { // 创建交换器 ......

kafka这些准备好 flink下载 1.16.2 https://www.apache.org/dyn/closer.lua/flink/flink-1.16.2/flink-1.16.2-bin-scala_2.12.tgz 1.9.1 https://archive.apache.org/di ......

聊聊Flink的必知必会(三) 聊聊Flink必知必会(四) 从源码中，根据关键的代码，梳理一下Flink中的时间与窗口实现逻辑。 WindowedStream 对数据流执行keyBy()操作后，再调用window()方法，就会返回WindowedStream，表示分区后又加窗的数据流。如果数据流没 ......

NOIP Day -3 序幕 \(\text{6:40}\)：到校，需要冬眠。 杯子没盖水紧撒了一地，赶紧收拾完去整理博客，模拟赛之前先找点数据结构做吧。 \(\text{7:30}\)：开题，T1 感觉很没有水平，T2 不知道什么情况，T3 讲过，T4 神秘。 感觉这次题可做，我直接倒序开题。 思 ......

LCT 小记 前言 在 OI 中，对于常规的树论问题，其树的形态一般是静态的。 但往往会存在一批毒瘤出题人，他们把树的形态变成了动态的，出现了 加边/删边 等操作。 而对于这类 「动态树问题」，我们有三种常见的数据结构可以维护，而本文将简单地引入其中的一种。 LCT。 以下简称这类处理动态树问题的数 ......

#include<bits/stdc++.h> #define db double using namespace std; const int N=1e5+10; db H; int n; struct node{int t,h;}a[N]; bool cmp(node x,node y){ret ......

MySQL 数据库是结构化信息或数据的有序集合，一般以电子形式存储在计算机系统中。本总结笔记是以MySQL为例来进行记录的。 数据库使用时操作对象一般包括数据库、数据表及表中数据等，操作类型一般为创建、选择、删除，以及对表中数据的插入、删除、更新、查询。如下图： 除此之外，还有较为少用的对于用户的操 ......

30+0+10+0 全真模拟。今天的模拟赛有一种格外的说不上来的绝望的感觉。很不好描述的。一直在想如果这是真实的 noip 赛场那我不就大寄特寄了。 下午因为不舒服所以玩了一下午（？）一直在机惨别人（？）玩的很开心。 但还是想看大家在机房跳钢管舞喵（？ A.game 赛时看到这个题之后就变得很愚蠢。 ......

NOIP Day -4 序幕 \(6:50\)：准时到校，整理博客，先改题。 一直在 T，写个拍瞅一眼，发现判断边界的时候有问题，逻辑一塌糊涂，不知道当时咋写的。 八点半的时候终于过掉了第二分块。 \(\color{black}{P4117}\) 第二分块。 间幕 \(1\) 吃了个早饭就九点半了， ......

有些东西不专门记一下就要忘。。。 kmp 核心是 \(next\) 数组, 即当前缀的除去自身的最大 \(border\) 。在字符串匹配时考虑双指针，一旦失配就跳 \(next\)，找到可能再次匹配的开始位置 \(p\) 。基于 \(border\) 的性质，只要 \(s[i - j + 1, i ......

特附今日闲话。 100+95+0+20. A.数字操作(num) 赛时其实是看了一下样例和数据范围的一档说均为质数，无端的想到 gcd 于是就秒掉了。 其实因为这个减数、统计不重复的过程就类似于辗转相除吧。然后就没了。没什么说的，存一下码好了。 #include<bits/stdc++.h> usi ......

序幕 \(\text{7:00}\)：起晚了到校（不是为啥这个点还没人），整整博客。 接着做点 CF 题，等会模拟赛。 \(\text{7:30}\)：准时开题。 看来是 JOI 专场，题面还是有点意思的。（实际上是 JOISC 2015，赛后知道的。） T1 感觉有点神秘先跳过。 T2 貌似除了最 ......

今天的题目很难评啊，你说他难吧那倒也不是，反正就是，又偏又怪，我感觉价值非常有限，所以一题也没补。记录一下喔。 今天足足 5pts 呢！历史新低。 晚自习看同学做一个黄色的小小模拟题，然后说要“同台竞技”，于是我也去做，结果写了四十多分钟。虽然一发过了但是还是感觉被降智了。这是题目链接：作业调度方案 ......

抽象场。打完人自闭的那种。 得分情况：\(80-0-30-30\)。 A：从 \(0\) 走到 \(n\)。在 \(i\) 位置时，等概率走的走到 \([i+1,n]\)（视为一步）。求期望步数。 哥们赛时，爆搜打表找规律。。。最后写的 O(n)，没看到第九个数据点没有特判。对于最后一个点 1e18 ......

僕を連れてって,浸み込んでしまう前に 菜哭了。不会打，看了半个小时史铁生散文集。 100+0+80+0 喵。 A.俨俨与道路（constructure） 正解是最小生成树。我的思路差不多。 为了全部联通，需要 n-1 条边。随意先计算给定的确定起始点的边，根据边权排序，从中挑至少 \(n-1-k\) ......

一、简介 算子map()和flatMap()是用于实现无状态转换的基本操作。 二、map() map()算子接收一个MapFunction接口参数，对元素进行一对一转换，即每个元素对应恰好一个结果。由于MapFunction是函数式接口，因此可以使用Lambda表达式。代码如下： StreamExe ......

运行 docker-compose.yml 搭建数据库源，官方 mysql 样例数据源无法启动，改用其他 mysql 镜像 version: '2.1' services: postgres: image: debezium/example-postgres:1.1 ports: - "5432:5 ......

一、获取源码 1、从 Git 克隆代码 git clone https://github.com/apache/flink.git 2、maven运行编译 mvn clean install -DskipTests 注：为了加速构建，可以执行如下命令，以跳过测试，QA 的插件和 JavaDocs 的 ......

单节点flink推荐作用于测试环境，最好不要使用到线上环境 一、环境配置： 1、安装Java 至少1.8版本 https://www.cnblogs.com/xiaoyou2018/p/9945272.html 2、系统环境变量 vi -b /etc/profile export FLINK_HOM ......

序幕 早上好冷好冷好冷。 \(\text{6:40}\)：冰冻到校。 补昨天的博客，一直补到七点多。 \(\text{7:30}\)：模拟赛开题。 题面都很简洁，简单浏览一遍，感觉没什么不可做题。 先开 T1，缩点是显著的，缩完点直接套了个贪心上去。 大样例过不了，开始思考正确性。 用一条链就简单地 ......

摘要：三道原，比较之前的难，发挥不好，八点半从机房外面过去的帅哥真的真的真的好帅我一下子无心大模拟赛了一整个惊艳到。 A.油田(oil) P3888 GDOI2014 拯救莫莉斯 状压 dp，据说爆搜也能过。本蒟蒻不会写剪枝，喜提 20pts。 状压 dp 思路： 首先 \(n*m<=50\)，\( ......

分治，分而治之，是通过减少数据规模，然后合并的结果，从而减少复杂度的思想。 其实感觉本文应该放在分治里面讲……算法学习笔记(31): 分治 在经典的序列分治中，我们是对于每一个点，求出经过这个点的那些区间的贡献。 在点分治中，同样我们是对于每一个点，求出经过这个点的那些路径的贡献。 放在边分治中，则 ......

1、生成jupyter notebook的配置文件 打开Anaconda Prompt，输入jupyter notebook --generate-config生成当前jupyter notebook的配置文文件，返回一个jupyter_notebook_config.py的文件的地址 2、修改配置 ......

序幕 \(\text{6:40}\)：冰冻到校，今天好冷，学校雪休但我们不休。 先补一补博客然后去写一些东西。 \(\color{blueviolet}{CF1499F}\) 设 \(f_{u, x}\) 表示在 \(u\) 子树内，\(u\) 向下延伸最多 \(x\) 步的方案数。转移是简单的，考 ......

前言 之前用过一段时间Mirror，它是一个服务器客户端一体的框架，通过给方法打上特定注解，来控制该方法运行在客户端还是服务器上（Unity官方已弃用的UNet设计思路一致）。这是它的优点，也是它的缺点，见仁见智吧。抛开这一点不谈，如果是客户端做主机那还好，但如果要打包为Deplicate Serv ......

设置进程内存(Process Memory) Apache Flink通过严格控制其各种组件的内存使用，在JVM之上提供高效的工作负载。 配置总内存(Total Memory) Flink JVM进程的总进程内存(total process memory)由Flink应用程序消耗的内存(总Flink ......

flink消费kafka 本机java代码测试 flink消费kafka机制 flink 消费 kafka 数据，提交消费组 offset 有三种类型 1、开启 checkpoint ： 在 checkpoint 完成后提交 2、开启 checkpoint，禁用 checkpoint 提交： 不提交 ......

TL;DR 迫于 PatchAsJsonAsync 方法缺失，我给 dotnet/runtime 项目贡献了相关的 API，可惜要到 .NET7 才能用上。 https://github.com/dotnet/runtime/pull/60672 正文 同事小陈 的 issue 收到了回复，希望他可 ......