检查点 时候flink
Java版Flink（一）概述和入门案例
一、概述 1、Flink 是什么 Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Apac ......
2023-12-25 无法正常关闭你的电脑 错误代码：0xc0000001 ==》试一下用windows命令【sfc /scannow】来修复可能被破坏的系统文件，不行就检查硬件，再不行就重装c盘吧
最近我的电脑每次早上开机的时候就开始蓝屏，哪怕我晚上把它设置为睡眠模式，第二天打开还是不断蓝屏，对，不是一次，而是起码七八次！ 我的解决方案就是用命令去修复了一下，其实我在写这个随笔的时候我也不知道明天是否能够正常开机。 先说导致蓝屏的代码：0xc0000001 这个代码不一定能正确代表报错的原因， ......
Linux下，安装单机版Flink
安装前准备 jdk环境 开始安装 下载安装包 地址1：https://archive.apache.org/dist/flink/flink-1.18.0/flink-1.18.0-bin-scala_2.12.tgz 官方：https://dlcdn.apache.org/flink/flink- ......
Flink on Yarn安装部署
引言 Apache Flink 是一款用于大规模数据处理和分析的分布式流处理框架，它提供了高性能、容错性和灵活性，广泛应用于实时数据处理和批处理场景。Flink 的核心特性包括事件驱动、状态管理、窗口操作等，使其成为处理实时和离线数据的理想选择。 本文档将引导您在 YARN（Yet Another ......
检查Windows更新问题解决
在任务栏搜索框输入cmd，点击右侧的“以管理员身份运行”，打开后输入： （建议复制粘贴，防止输入有误 出现错误提示等请忽略*） SC config wuauserv start= auto 回车（Enter按键） SC config bits start= auto 回车（Enter按键） SC c ......
MySQL 啥时候用表锁，啥时候用行锁？
https://www.51cto.com/article/714377.html MySQL Innodb 的锁可以说是执行引擎的并发基础了，有了锁才能保证数据的一致性。众所周知，我们都知道 Innodb 有全局锁、表级锁、行级锁三种，但你知道什么时候会用表锁，什么时候会用行锁吗？ 虽然对 MyS ......
HBase Shell操作&Flink写入HBase
一、HBase Shell操作 1、基本操作 1）进入HBase客户端命令行 [root@bigdata1 hbase]$ bin/hbase shell 2）查看帮助命令 hbase(main):001:0> help 3）查看当前数据库中有哪些表 hbase(main):002:0> list ......
涉及到金额的时候是，使用Decimal而不是float和double 浮点数
decimal库包是用来解决float类型对象之间运算不准确的问题的。所以，如果你想使用decimal库包，你必须先把float类型对象通过decimal.NewFromFloat()函数转成decimal.Decimal类型，然后再计算，最后还得再转成你所需要的类型。 范例: package ma ......
聊聊Flink必知必会(七)
What is State 虽然数据流中的许多操作一次只查看一个单独的事件（例如事件解析器），但某些操作会记住多个事件的信息（例如窗口算子）。 这些操作称为有状态的(stateful)。 有状态操作的一些示例： 当应用程序搜索某些事件模式(event patterns)时，状态(state)将存储迄 ......
element-plus的type类型为daterange的时候限制时间选择
对于 Element Plus 的日期时间范围选择组件（el-date-picker 的 type 设置为 "daterange"），你可以使用 :picker-options 属性来设置选项，通过 disabledDate 函数来禁止选择当前时间之前的日期。 下面是一个 el-date-picke ......
聊聊Flink必知必会(六)
Flink是一个分布式系统，需要有效地分配和管理计算资源才能执行流应用程序。它集成了所有常见的集群资源管理器，如Hadoop YARN和Kubernetes，但也可以设置为作为一个独立的集群运行，甚至作为一个库。 Flink集群的剖析 Flink运行时由两种类型的进程组成:一个JobManager和 ......
Nacos配置：发布失败，请检查参数是否正确
一、表象： 页面1： 报错1： caused: PreparedStatementCallback; bad SQL grammar [SELECT id,data_id,group_id,tenant_id,app_name,content,md5,gmt_create,gmt_modified, ......
spring eureka服务注册配置,排查服务注册上来了，但是请求没有过来。检查是否服务注册配置错误
spring eureka服务注册配置,排查服务注册上来了，但是请求没有过来。检查是否服务注册配置错误 解决方法： 去掉该配置eureka.instance.hostname = client微服务的提供IP地址 //微服务的提供IP地址,点开服务注册的http://xxx:1246,找到服务，点开 ......
Flink处理函数解析（ProcessFunction和KeyedProcessFunction）
Flink中的处理函数（ProcessFunction和KeyedProcessFunction）在对于数据进行颗粒化的精确计算时使用较多，处理函数提供了一个定时服务（TimerService），可以向未来注册一个定时服务， ......
Flink 在风控场景实时特征落地实战
背景介绍 风控简介 二十一世纪，信息化时代到来，互联网行业的发展速度远快于其他行业。一旦商业模式跑通，有利可图，资本立刻蜂拥而至，助推更多企业不断的入场进行快速的复制迭代，企图成为下一个“行业领头羊”。 带着资本入场的玩家因为不会有资金的压力，只会更多的关注业务发展，却忽略了业务上的风险点。强大如拼 ......
QT 加载构建控件的时候 是灰色的
先上图 我安装完程序之后，返现上面红框中是灰色的，并且前面还带一个黄色感叹号 并且下面C++的地方还是空的，应该是系统没有c++编译器 为系统安装g++编译器 sudo apt-get install g++ ......
Nacos配置：发布失败，请检查参数是否正确
一、表象： 页面1： 报错1： caused: PreparedStatementCallback; bad SQL grammar [SELECT id,data_id,group_id,tenant_id,app_name,content,md5,gmt_create,gmt_modified, ......
Nacos配置：发布失败，请检查参数是否正确
一、表象： 页面1： 报错1： caused: PreparedStatementCallback; bad SQL grammar [SELECT id,data_id,group_id,tenant_id,app_name,content,md5,gmt_create,gmt_modified, ......
flink在linux上运行成功但是无法访问webUI界面
本文参考博主：Flink Web UI不能访问_flink启动后web页面打不开-CSDN博客 首先我在finallshell上运行成功flink之后长这样： 然后再web界面上输入：localhost：8081显示无法进入： 然后我把防火墙关闭了： hdfs dfsadmin -safemode ......
肝硬化怎么检查出来的？
肝硬化是一种常见的慢性肝病，它是由肝脏长期受到损害引起的。肝硬化会影响肝脏的功能，导致一系列的症状和并发症。 那么，肝硬化怎么检查出来的呢？ 1.医生会询问你的病史和症状。他们会询问你是否有长期的肝病病史，如病毒性肝炎、脂肪肝等。他们还会询问你是否有其他的症状，如腹痛、腹胀、黄疸等。 2.医生会进行 ......
1346. 检查整数及其两倍数是否存在
1346. 检查整数及其两倍数是否存在 给你一个整数数组 arr，请你检查是否存在两个整数 N 和 M，满足 N 是 M 的两倍（即，N = 2 * M）。 更正式地，检查是否存在两个下标 i 和 j 满足： i != j 0 <= i, j < arr.length arr[i] == 2 * a ......
配置内核的时候提示Your display is too small to run Menuconfig! It must be at least 19 lines by 80 columns.
按照按照 （https://rocketboards.org/foswiki/Documentation/EmbeddedLinuxBeginnerSGuide）制作了一个image当想打开内核kernel的配置界面make ARCH=arm menuconfig的时候提示： scripts/kco ......
Nacos配置：发布失败，请检查参数是否正确
一、表象： 页面1： 报错1： caused: PreparedStatementCallback; bad SQL grammar [SELECT id,data_id,group_id,tenant_id,app_name,content,md5,gmt_create,gmt_modified, ......
[popover, select] el-popover内有select的时候在选择后会自动关闭
Steps to reproduce选择某个选项后会自动关闭 What is Expected?选择后不自动关闭，等点击按钮后再去触发组件内的关闭方法。 What is actually happening?自动关闭 Additional comments这个问题当初在elementui的时候还没有 ......
用DE10_NANO_SOC_FB生成dts的时候 提示Component alt_vip_itc_0 of class alt_vip_itc is unknown
当使用DE10_NANO_SOC_FB工程产生dts时提示 Component alt_vip_itc_0 of class alt_vip_itc is unknown： 如果此时生成了dtb， 可以忽略这个提示。 如果没有生成，您可以先在Qsys 中把这两个器件disable 掉, 然后top文 ......
用ubuntu18.04.6 在编译uboot的时候提示
参考 https://www.rocketboards.org/foswiki/Documentation/EmbeddedLinuxBeginnerSGuide 制作image 的时候， 我将uboot 换成最新版本： git checkout rel_socfpga_v2023.04_23.11 ......
SpringSession中的sessionId什么时候会过期
使用SpringSession后，每次请求后，都会把期间变更的attribute保存到redis中。 每次访问都会修改lastAccessTimeorg.springframework.session.web.http.SessionRepositoryFilter#doFilterInternal ......
当需要很多有序的回文数的时候的预处理(<=1e9)
第一个循环处理奇数长度的回文数，第二个处理偶数长度的回文数，小于等于1000，原因是1000000000不是回文数，偶数位回文数只能是8位，也就是最大是99999999 8个9，比字符串处理快。 第一个循环细节是先去掉了后面的一位所以是奇数位最大也就是99999的时候关于最后一个9对称后得到9个9。 ......
streamlit 网络批量ping和snmp检查
import timeimport netaddrfrom netaddr import *import pandas as pdimport streamlit as stfrom concurrent.futures import ThreadPoolExecutorimport subproc ......
阿里云AnalyticDB基于Flink CDC+Hudi实现多表全增量入湖实践
湖仓一体（LakeHouse）是大数据领域的重要发展方向，提供了流批一体和湖仓结合的新场景。阿里云AnalyticDB for MySQL基于 Apache Hudi 构建了新一代的湖仓平台，提供日志、CDC等多种数据源一键入湖，在离线计算引擎融合分析等能力。本文将主要介绍AnalyticDB fo ......