连接器 用户flink http
git 多用户配置
# 第一步 删除全局用户名和邮箱配置 ```shell # 添加全局用户信息 git config --global user.name "用户名" git config --global user.email "邮箱" #删除全局用户信息 git config --global --unset u ......
flink双流join底层如何实现的
Flink是一个分布式流处理框架，它提供了丰富的操作符来处理流数据。双流(join)操作是其中一个常用的操作，用于将两个流的数据按照指定的条件进行关联。Flink的底层实现使用了一种称为“流的连接”(stream co-processing)的技术。 在Flink中，双流(join)操作通过以下步骤 ......
flink双流join时间窗口过大导致的问题
当Flink双流(join)操作的时间窗口过大时，可能会导致以下问题： 1. 内存消耗：时间窗口大小直接影响Flink系统的内存消耗。较大的时间窗口会导致需要维护更多的状态数据，从而占用更多的内存资源。 2. 延迟增加：大时间窗口可能会导致延迟增加。如果窗口的大小超过了数据流的延迟，那么在触发窗口计 ......
flink的双流join的2个流必须都是滑动窗口吗
不，Flink的双流(join)操作并不要求两个流都是滑动窗口。在双流(join)操作中，每个流可以使用不同类型的窗口，包括滑动窗口、滚动窗口或其他类型的窗口。 在Flink中，可以对每个输入流分别定义不同的窗口类型和参数，以满足实际的业务需求。只要两个流在关联键上能够匹配，并且窗口定义能够适配，就 ......
flink中的广播流实例
在Flink中，广播流（Broadcast Stream）是一种特殊的数据流类型，用于将一个数据流广播到所有并行任务中，以供每个任务共享和使用。广播流通常用于将静态数据（如维表数据）发送给所有任务，以便任务可以在本地缓存该数据，避免多次访问外部存储系统。 广播流的特点如下： - 广播流只有一个并行度 ......
flink的状态表需要保存多久
Flink的状态表保存的时间可以根据应用程序的需求进行配置。状态表的保留时间取决于两个因素： 1. **状态后端（State Backend）的配置**：Flink支持不同类型的状态后端，如内存、文件系统、RocksDB等。不同的状态后端可以配置不同的状态保留策略。例如，如果使用基于内存的状态后端， ......
flink从检查点恢复时候做什么
当发生故障时，Flink从最近的一致性检查点中恢复任务的状态。以下是从检查点恢复的主要步骤： 1. **加载检查点元数据和状态数据**：Flink首先加载最近一次成功的检查点的元数据和持久化的状态数据。检查点的元数据包含了关于检查点的信息，如检查点ID、生成时间和相关的任务信息等。持久化的状态数据包 ......
使用Redis作为维表输入的Flink示例代码
下面是一个使用Redis作为维表输入的Flink示例代码： ```java import org.apache.flink.api.common.functions.RichFlatMapFunction; import org.apache.flink.api.common.state.MapSt ......
flink的各个算子在收到barrier的时候会做什么
在Flink中，各个算子（算子链中的每个算子）在收到 barrier（检查点屏障）时会执行以下操作： 1. **算子状态快照**：算子会触发对其状态的快照操作，以捕获当前状态的一致性快照。这包括算子的运行时状态、缓冲区或累加器等数据。 2. **处理挂起输入数据**：算子会将收到的 barrier ......
flink中一个多输入的算子如何决定是否可以往下游算子发送barrier
在Flink中，多输入的算子在决定是否可以往下发 barrier 时需要满足以下条件： 1. **输入流的 barrier 对齐**：多输入的算子必须要求所有输入流都处于 barrier 对齐状态，即收到了相同的 barrier。这意味着所有输入流的上游任务都已经收到了相同的 barrier，并向下 ......
Apache ECharts【用户层】
一、介绍 Apache ECharts 是一款基于 JavaScript 的 开源可视化图表库。 提供直观、生动、可交互、可个性化定制的数据可视化图表。 二、官网地址： https://echarts.apache.org/zh/index.html 三、总结 不管是哪种形式的图形，最本质的东西实际 ......
HTTP headers | Content-Type
### Content-type 所有可能的值 | Type | Values | | | | | Application | application/EDI-X12application/EDIFACTapplication/javascriptapplication/octet-streamap ......
MySQL用户与权限管理
一：用户管理 1：登录MySQL服务器 我们在安装完MySQL以后，就会通过root用户进行登录；那么root该怎么登录呢？所以我们启动MySQL服务后，可以通过mysql命令来登录MySQL服务器 基本语法：mysql <-u username> <-p> [password] [-h hostn ......
Docker安装MS SQL Server并使用Navicat远程连接
思维导航 MS SQL Server简介 基于Ubuntu的Microsoft SQL Server官方镜像 拉取Microsoft SQL Server 2022容器镜像 验证mssql镜像是否成功拉取到本地 创建并运行一个mssql容器 注意大坑使用Docker部署Sql Server容器后过几 ......
VirtualBox安装虚拟机并配置IP地址并实现Xshell连接
安装好virtualBox之后跟着下面图程走，奶奶看了都说会的流程 检查网络配置 已经有默认的网络配置了 创建虚拟机 选择自己要安装的位置 按自己需求分配内存大小 根据需求分配磁盘空间 点击完成 选择创建的虚拟机点击设置 点击网络选择网卡二 按照一下配置 配置完成后添加介质（我这里以OpenEule ......
【网络基础】【HTTP】如何理解是 TCP 面向字节流协议？
1 前言 TCP 是面向字节流的协议，UDP 是面向报文的协议？这里的「面向字节流」和「面向报文」该如何理解。我们这节来看看哈。 2 如何理解字节流？ 之所以会说 TCP 是面向字节流的协议，UDP 是面向报文的协议，是因为操作系统对 TCP 和 UDP 协议的发送方的机制不同，也就是问题原因在发送 ......
【网络基础】【HTTP】既然有 HTTP 协议，为什么还要有 RPC？
1 前言 第一次接触RPC协议，当时就很懵，我HTTP协议用的好好的，为什么还要用RPC协议？于是就到网上去搜。 不少解释显得非常官方，我相信大家在各种平台上也都看到过，解释了又好像没解释，都在用一个我们不认识的概念去解释另外一个我们不认识的概念，懂的人不需要看，不懂的人看了还是不懂。 这种看了，又 ......
用户故事与敏捷方法读后感（一）
在前六章中主要讲的就是编写用户故事，书中提供了一种节省时间和消除重复工作的需求管理方法，通过用户故事与敏捷方法，对开发更优秀的软件，起着积极高效的推动作用。软件开发起始于需求收集和分析。传统的方式客户获得的只会是开发人员根据他们对文档的理解所开发的软件系统，这可能并不是客户真正需要的，这种情况下软件 ......
Locust用户手册
Locust是一个基于Python语言的开源压力测试工具，通过模拟虚拟用户进行并发访问，测试目标站点的性能和稳定性。本手册详细介绍如何使用Locust进行压力测试，包括基础、高阶和拓展内容。 一、基础使用 1. 安装Locust 首先需要安装Python3，在命令行窗口输入以下命令： ```pip ......
http协商缓存VS强缓存
本文主要讲解浏览器端的缓存，缓存的作用是不言而喻的，能够极大的改善网页性能，提高用户体验。 1、浏览器缓存 缓存这东西，第一次必须获取到资源后，然后根据返回的信息来告诉如何缓存资源，可能采用的是强缓存，也可能告诉客户端浏览器是协商缓存，这都需要根据响应的header内容来决定的。下面用两幅图来描述浏 ......
开松工艺单——pb查询子窗口中下拉列表控件赋值；两张表左连接显示其中部分数据；数据窗口单元格布局设置
说明：此查询窗口为继承窗口 开松工艺单来自两张表时其中一张表没有数据也要显示部分数据时，可以使用左连接，如下 1 select a.waste_lot, 2 a.qua_name, 3 a.color_name, 4 a.qty, 5 a.remark, 6 Case a.prod_type whe ......
springboot +nginx 配置http2
# 说明 - nginx端使用http2+https,如果不使用https,浏览器会默认走http1.1 - 后台使用http2,不使用https,因为内部服务之间没必要每次校验证书 # nginx配置 ``` # user root; worker_processes auto; error_lo ......
数据库分库分表操作——假如用户注册人数过亿
如果用户注册人数过亿，数据信息量大。此时就需要考虑分库分表 单库分表 垂直拆分和水平拆分 垂直拆分 拆分列 水平分表——常见 本质把大表拆分小表——Id取模分表 数据迁移问题： 如果一开始将数据预估量很大。建议根据id范围分表。——多用于分表数据不能很好扩展问题 问题：一两张分表进行频繁读写操作。其 ......
【GiraKoo】adb.exe频繁崩溃，与Android设备连接不稳定
在使用Android Studio时，发现adb.exe连接非常不稳定。通过EveryThing工具搜索关键字adb.exe。发现了大量的AppCrash\_adb文件夹，adb.exe.xxx.dmp文件等情况。
初步判断，应当是adb在运行时，程序频繁崩溃。遇到此类问题，尝试了以下几种方案。最终... ......
非root用户安装python3.10
最近舍友找我帮忙解决python版本问题，特此记录中间遇到的各种问题。 ## 查看系统版本 这里使用的服务器系统为ubuntu，具体如下  微型端子排针提供多种标准选项。这些选项包括表面贴装、垂直或水平方向、通孔或混合技术尾部，以及各种接线柱高度。此外，FTSH端子排针还为用户提供各种末端屏蔽板和弹出屏蔽板选择，以便与极化和键控对齐或盲插。这些FTSH系列SMT端子排针与 ......
电脑WIFI无法连接5gwifi设置
1.找到网络连接 对应wifi 右键点选配置 ，然后高级 2.到了这一步可以看到我这里的属性只有3个，点击Wireless Mode 3.选802.11a就行了因为无线规格 工作频段802.11a （5GHz） 802.11b （2.4GHz）802.11g （2.4GHz ） 802.11n （2 ......
BPI-M2-Zero Armbian_22.11.0 连接WiFi的方法，使用wpa_cli，wpa_supplicant，可创建自动连接
 wpa_supplicant 工具包含wpa_supplicant和wpa_cli这2个程序，其中wpa ......
Flink CDC
# **第1章 CDC简介** ## 1.1 什么是CDC CDC是Change Data Capture(变更数据获取)的简称。核心思想是，监测并捕获数据库的变动（包括数据或数据表的插入、更新以及删除等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 ## 1 ......
grpc 与http比较，具有哪些优势
1. 更高的性能：gRPC使用Protocol Buffers作为默认的数据序列化工具，相比于JSON等文本格式，它的编码和解码速度更快，传输的数据量更小，因此可以更快地处理大量的请求和响应。 2. 更小的带宽占用：由于使用二进制数据格式，gRPC的数据传输量比HTTP更小，因此可以降低网络传输的带 ......