flink wordcount demo job
Using JobDSL and Jenkinsfiles to fully automate Jenkins job management
Using JobDSL and Jenkinsfiles to fully automate Jenkins job management 非常贴切的一个比喻 JobDSL 做Job管理的框架， 负责Job基本参数配置 Pipeline 做Job逻辑内容的容器，决定Job执行逻辑。 By usin ......
18.任务调度之Elastic-Job
``` 课程目标 1、了解 Elastic-Job 的基本特性 2、掌握 Elastic-Job 开发与配置方式（包括 Java 开发和SpringBoot 开发），掌握任务类型和任务分片策略 3、了解 Elastic-Job 运维平台的使用 4、掌握 Elastic-Job 运行原理 内容定位 适 ......
[任务调度] XXL-Job入门指南
# 1 概述 本文只是对项目上的技术验证的小结。XXL-Job的详细特性、详细功能说明，参见官方文档。 ## 定义 + 定义 XXL-JOB是一个轻量级分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线，开箱即用。 + 所属分类: 程序开发 ......
Flink源码解析(零)——源码解析系列随笔说明
00、博主仅是数据开发及数仓开发工程师，出于提升自身对Flink系统原理掌握考虑，自愿花费精力整理源码解析系列随笔，并非专业Flink系统开发人员，在源码解析过程中出现非专业行为望见谅。希望Flink系统开发专业人员多提意见，不胜感激。 01、Flink源码解析系列随笔主要基于Flink 1.17. ......
kafka_demo
参考： 概念：https://zhuanlan.zhihu.com/p/74063251 代码运用：https://zhuanlan.zhihu.com/p/114209326 参考 kafka 在windows 平台的搭建和简单实用_一代键客的博客-CSDN博客，先验证本地是否能使用kafka成功 ......
05服务拆分-案例Demo
下载对应学习资料 准备数据库 ``` docker ps docker exec -it 6d542566d077 /bin/bash psql 'host=localhost port=5432 user=postgres dbname=postgres' create database clou ......
k8s 学习笔记之 Pod 控制器——Job & CronJob
## Job Job，主要用于负责**批量处理(一次要处理指定数量任务)**短暂的**一次性(每个任务仅运行一次就结束)**任务。Job特点如下： - 当Job创建的pod执行成功结束时，Job将记录成功结束的pod数量 - 当成功结束的pod达到指定的数量时，Job将完成执行  Hangfire: Hangfire – Background jobs an ......
SSLSocket_demo
参考：https://www.jianshu.com/p/7145bd9c8e95 ssl通信过程图解：https://blog.csdn.net/HD243608836/article/details/118708843 keytool各参数含义：java存取密码于keystore文件中_keys ......
c语言链表demo
```c #include #include // 定义节点结构体 struct node { int data; struct node *next; /* 注意：这行使用了 node, node 必须在这行之前定义 */ }; int main(int argc, const char *arg ......
Jenkins：重置 job build number
在调试jenkins job时会产生很多fail的build，很多**红色的X**还是很碍眼的，job调试成功后就可以重置build number了。 ### 步骤： 1. 点击jenkins小老头图标 -> 管理Jenkins  url : 指的是所连接的Jenkins的网络地 username/pas ......
flink-sql-connector-mongodb-cdc和flink-connector-mongodb-cdc的区别是什么
flink-sql-connector-mongodb-cdc 和 flink-connector-mongodb-cdc 都是 Flink 的 MongoDB CDC（Change Data Capture）连接器，用于从 MongoDB 数据库中捕获变化数据并将其传递给 Flink 进行实时处理 ......
chatgpt evhtp demo
要使用libevhtp实现大文件上传功能，你可以使用libevhtp的POST请求处理器，并通过分块上传的方式来处理大文件上传。以下是一个示例代码： cpp | #include <iostream> #include <fstream> #include <evhtp/evhtp.h> const ......
CoaXPress 2.0 FPGA HOST IP Core Linux Demo
目录 Hello-FPGA CoaXPress 2.0 Host FPGA IP Core Linux Demo 4 1 说明 4 2 设备连接 7 3 VIVADO FPGA工程 7 4 调试说明 10 图 1‑1 资料目录 4 图 1‑2 VIVADO工程目录结构 5 图 1‑3 SDK工程目录 ......
rpc_demo
参考：RPC是什么，看完你就知道了 - 知乎 (zhihu.com) Teror Fox-博客园 (cnblogs.com) IService.java package com.hmb; public interface IService { void sayHello(); void sayGoo ......
xxl-job 定时任务的调研及学习
xxl-job 定时任务官网 xxl-job springboot 整合资料参考 一、xxl-job简介 xxl-job是一个开源的分布式定时任务框架，它可以与其他微服务组件一起构成微服务集群。它的调度中心（xxl-job）和执行器（自己的springboot项目中有@XxlJob("定时任务名称" ......
Flink 容错机制 保存点和检查点
Flink检查点常用配置： //配置检查点 env.enableCheckpointing(180000); // 开启checkpoint 每180000ms 一次 env.getCheckpointConfig().setMinPauseBetweenCheckpoints(50000);// ......
xxl-job docker 搭建&接入
> 项目地址： https://github.com/xuxueli/xxl-job ## 1 初始化数据库 新建表 sql 语句在项目里 /xxl-job/doc/db/tables_xxl_job.sql 在目标数据库执行语句建库、建表 ```sql # # XXL-JOB v2.4.1-SNA ......
StateAFL demo复现
1.概述 论文地址：https://arxiv.org/abs/2110.06253 源码地址：https://github.com/stateafl/stateafl 配置：VMware Pro 16.0 Ubuntu Linux 18.04 StateAFL在AFLNET的基础上，采用更细粒度的 ......
Qt+GDAL开发笔记（一）：在windows系统mingw32编译GDAL库、搭建开发环境和基础Demo
前言 麒麟系统上做全球北斗定位终端开发，调试工具要做一个windows版本方便校对，北斗GPS发过来的是大地坐标，应用需要的是经纬度坐标，所以需要转换，可以使用公式转换，但是之前涉及到了另一个shang市公司项目使用WG，最终选择了GDAL库进行转换。 注意 如果读者不强制要求mingw32，建议不 ......
jobs
jobs 显示作业的状态。 ## 概要 ```shell jobs [-lnprs] [jobspec ...] jobs -x command [args] ``` ## 主要用途 - 显示作业的状态。 - 列出活动的作业。 - 列出停止的作业。 ## 选项 ```shell -l 在作业信息中额 ......
加载wkt到地图 Demo (可直接运行）
直接另存为网页浏览器打开即可： 1 <!DOCTYPE html> 2 <html> 3 <head> 4 <title>WKT</title> 5 <link rel="stylesheet" href="https://openlayers.org/en/v5.3.0/css/ol.css" t ......
React函数式组件渲染顺序探究（Demo）
> 参考资料： > [React渲染顺序及useEffect执行顺序探究（含并发模式）](https://blog.csdn.net/web2022050901/article/details/125238225) # code ```jsx import { useEffect, useState ......
阿里云flink操作示例
前期简单查询：（不同版本语法或有不同，当前版本：专有云flink1.11） 1、可以先简单定义自己的源表字段（下图test），进行简单查询，确定结果是否输出（结果输出是一直存在的，源表实时新增一条数据，查询结果就会新增一条数据） 备注：以下示例特殊信息写成自己的信息；可定义多个源表 2、定义结果表（ ......