flink个人
个人职业生涯规划
2024-个人职业生涯规划 一、认识自我 1.个人基本情况 我叫刘海涛，今年22岁，大四，就读于石家庄铁道大学软件工程专业。我来自一个普通的农民家庭，父母都是农民，他们对于我所学的专业以及未来的发展方向并不能给予指引，但是他们最大限度的尊重我的选择。在业余时间，我喜欢阅读、运动以及一个人静静的呆着思 ......
[Python学习记]个人感受(持续更新）
24/01/13 大家好，到目前为止我已经学习到if条件语句的使用了，准备学习循环语句，if语句学的薄浅还得多加练习实际应用！关于if的应用我自主设计了几个程序，希望大佬可以多加指点 23/11/13 大家好，我是小县城高中的一名学生 在我初中时期就已经知道主流的编程语言了，只不过那个时候只记住叫啥 ......
个人博客详细设计说明书
  或者 addSource() 来读取本地日志文件。 使用 readTextFile() 方法读取本地日志文件示例如下所示： 点击查看代码 import ......
Flink实时处理入门
Flink实时处理入门 1、Flink框架介绍 Flink 诞生于欧洲的一个大数据研究项目 StratoSphere。它是由 3 所地处柏林的大学和欧洲其他一 些大学在 2010~2014 年共同进行的研究项目，由柏林理工大学的教授沃克尔·马尔科（Volker Markl）领衔开发。2019年1月阿 ......
个人的vscode配置调优
简述 vscode安装的插件 GBKtoUTF8：将 GBK 编码的文本转换为 UTF-8 编码 GitHub Theme：为VS Code设置 GitHub 风格的主题 Material Icon Theme：为VS Code设置Material Design风格的图标主题 Remote - SS ......
PowerDotNet平台化软件架构设计与实现系列（17）：PCRM个人用户管理平台
个人用户管理是业务系统中非常基础且重要的一个公共服务系统，我们写的绝大多数应用都和个人用户或会员有关，用户(会员)数据安全无小事，必须有一个完备的用户管理平台系统。 因为不同公司的主业务不同，个人用户管理的侧重点也会有不同，PowerDotNet这里介绍的个人用户管理平台，只是个人用户管理系统中很基 ......
Java版Flink（十一）时间语义和watermark
Java版Flink（十一）时间语义和watermark 一、时间语义 在Flink 中涉及到三个重要时间概念：EventTime、IngestionTime、ProcessingTime。 1.1、EventTime EventTime 表示日志事件产生的时间戳，每一条数据都会记录自己生产的时间。 ......
Flink中窗口的触发器、移除器、侧输出流
Flink中窗口的触发器、移除器、侧输出流 目录 1. 触发器（Trigger） 2. 移除器（Evictor） 3. 允许延迟（Allowed Lateness） 4. 将迟到的数据放入侧输出流 对于一个窗口算子而言，窗口分配器和窗口函数是必不可少的。除此之外，Flink 还提供 了其他一些可选的 ......
个人是否可以建立自己的网站？
个人完全可以建立自己的网站。事实上，越来越多的个人都选择建立自己的网站，以展示个人作品、分享知识、开展个人品牌推广等。 建立个人网站可以带来以下好处： 自我展示：个人网站是展示自己作品、经验和技能的理想平台。你可以在网站上展示自己的作品集、写作作品、摄影作品等，向世界展示自己的才华和专业能力。 个人 ......
ubuntu frame 个人开发心得
引言 有一次我在树莓派上安装 Ubuntu Core 我给创新创业项目开发一个可视化 gui 看板，用于展示数据。 然后我就找到了我需要的工具 Ubuntu Frame 初次尝试使用 Ubuntu Frame 在 ubuntu22.04 系统上安装了 Ubuntu Frame 的测试环境 sudo ......
Flink的waterMark概念解释 watermark是flink为了处理event time窗口计算提出的一种机制，本质上就是一个时间戳，代表着比这个时间早的事件已经全部进入到相应的窗口，后续不会在有比这个时间小的事件出现，(触发)基于这个前提我们才有可能将event time窗口视为完整并触发窗口的计算。
Flink的waterMark概念解释 watermark是flink为了处理event time窗口计算提出的一种机制，本质上就是一个时间戳，代表着比这个时间早的事件已经全部进入到相应的窗口，后续不会在有比这个时间小的事件出现，(触发)基于这个前提我们才有可能将event time窗口视为完整并触 ......
【转】chrome-调试技巧个人总结
chrome-调试技巧个人总结 https://blog.csdn.net/badbaby52906/article/details/128973527 1、调试hover样式 1、第一种方法就是利用debugger（推荐） 在控制台输入下面一段代码（时间自己决定）并执行，返回页面，鼠标放在需要 ......
作业8 流计算&Flink
一. 多选题（共5题，62.5分） 1. (多选题)典型的事件驱动型应用包括： A. 异常检测 B. 基于规则的报警 C. 反欺诈 D. 业务流程监控 我的答案: ABCD:异常检测; 基于规则的报警; 反欺诈; 业务流程监控;正确答案: ABCD:异常检测; 基于规则的报警; 反欺诈; 业务流程监 ......
Flink Metaspace OOM问题排查
错误日志 org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application. at org.apache.flink.runtime.webmonitor.handlers.JarRun ......
安装HUE并配置连接Hive&Flink&TIDB
安装依赖包 yum install ant asciidoc cyrus-sasl-devel cyrus-sasl-gssapi cyrus-sasl-plain gcc gcc-c++ krb5-devel libffi-devel libxml2-devel libxslt-devel mak ......
Flink Sql线上环境踩坑记录
背景：Flink Sql程序本机测试执行没问题，上到生产环境就报各种诡异得问题，搞得头都大了。。。特此记录下解决过程。 问题原因主要两点： 1.JDK版本问题 2.Flink Sql相关jar包冲突 问题一 2020-09-27 06:06:33,125 INFO org.apache.flink. ......
教育，是点亮一个人，点亮每一个人
我很高兴，在过去几年里，舆论对于学历对于教育的态度，终于发生了一些变化。我对学历崇拜对中国僵化的应试教育尖锐的批评，最开始的时候，绝大多数人都是无法接受的；而今天，我收到的最有益的批评： 问题大家都看见了，但你有什么更好的办法吗？ 其实这个问题我已经思考很多年了。 90%的中国家长，逼着孩子读书，其 ......
Flink SQL建表语句示例
Hive CREATE EXTERNAL TABLE jc.judgmentDocumentods( odsId STRING, caseTitle STRING, plaintiff STRING, caseTypeShow INT, releaseDate STRING, caseSource ......
Flink Sql On Hive
TableEnvironment // ********************** // FLINK STREAMING QUERY // ********************** import org.apache.flink.streaming.api.environment.Stream ......
第一次个人编程作业
软件工程https://edu.cnblogs.com/campus/gdgy/CSGrade21-12 作业要求 https://edu.cnblogs.com/campus/gdgy/CSGrade21-12/homework/13014 作业目标 学习使用Java建立工程项目，学会论文查重的具 ......
Flink写文件
简介 StreamingFileSink 提供了将数据分桶写入文件系统的功能。 如何分桶是可以配置，默认使用基于时间的分桶策略，每个小时创建一个新的桶，也可以自定义分桶策略。 文件滚动策略支持两种方式，基于时间和文件大小的DefaultRollingPolicy策略和基于Flink检查点的OnChe ......
安装HUE并配置连接Hive&Flink&TIDB
创建用户 groupadd hadoop useradd -g hadoop hadoop 解压编译 wget https://cdn.gethue.com/downloads/hue-4.8.0.tgz PREFIX=/usr/share make install 集成Hive Conf 在/op ......
HUE中执行Flink SQL
要解决的问题 解决HUE操作大数据量Hive表时，执行报错的问题。 为开发人员或数据管理人员提供一个便捷的Flink SQL交互式查询工具，简化SQL验证的流程，进而提高工作效率。 功能介绍 Flink SQL 读写Kafka Flink SQL 读写HDFS Flink SQL 关联 Flink ......
windows 启用个人热点笔记
1. 设置--网络--移动热点 启用热点，编辑设置，关闭节能 2. 控制面板--网络和 Internet--网络连接--更改适配器设置 关闭 Microsoft Wi-Fi Direct Virtual Adapter #2 的网卡电源节能设置（防止热点自动关闭） ......
免费上传个人网页项目并且网址访问
引言 同学们在学习完如何做一个网页（html，css，js）之后，一定有一个困惑，那就是如何将自己的网页发布到网上让别人能够通过网址访问该网页。想想能拥有一个个人网站发布自制网页也是不是非常炫酷的事。但是一般运行自己的网站需要域名和服务器，域名需要花钱买，服务器需要去花钱租，对于绝大多数想要尝尝鲜的 ......
CodeForces Hello 2024 个人题解（A~C）
A. Wallet Exchange 时间限制: 1秒 内存限制: 256兆 输入: 标准输入 输出: 标准输出 Alice and Bob are bored, so they decide to play a game with their wallets. Alice has a coins ......
未来，随着Windows操作系统的不断发展和更新，我认为System Image Manager也将随之更新和改进，以适应新的功能和需求。以下是我个人对System Image Manager未来方向的一些想法
System Image Manager（SIM）是Windows Assessment and Deployment Kit（ADK）中的一个组件，用于创建和编辑Windows无人值守安装或升级过程中所使用的答案文件。 未来，随着Windows操作系统的不断发展和更新，我认为System Imag ......
flink小记
Flink核心概念 1、Flink是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架 2、Flink底层是以Java编写的，并为开发人员同时提供了完整的Java和Scala API。 3、Flink运行时包括JobManager（Master）和TaskManager（Work ......
# 公用服务器配置个人工作仓库
公用服务器配置个人工作仓库 有一些服务器需要多个用户进行访问，但是ssh账号和工作空间又只有一个，同时又不希望和这个ssh账号下的所有用户共享git账号，可以通过配置代码库本地ssh密钥以实现工作空间隔离。 生成并配置密钥 首先登录服务器，进入路径~/.ssh 输入以下命令以生成ssh密钥对 ssh ......