- 博客(19)
- 收藏
- 关注
RSS订阅原创 深入理解 Java 的 `synchronized` 关键字及其 JVM 优化
synchronized 关键字是 Java 中实现线程安全的基本手段，它通过对象的锁信息和监视器来实现线程同步。JVM 对 synchronized 进行了多种优化，包括偏向锁、轻量级锁和重量级锁等机制，以提高同步的性能和效率。深入理解 synchronized 的底层实现和优化策略，有助于编写高效、线程安全的 Java 程序。
2024-07-01 13:53:11
688
原创 [1]-揭秘 Apache Flink Client：从脚本执行到 StreamGraph 与 JobGraph 的奥秘
旨在记录源码阅读过程，中间加入了AI美化的语句及自己的想法，如有疑问或错误请尽情留言讨论 在数据流处理领域，Apache Flink 作为一个高性能、低延迟的流处理引擎，以其强大的功能和灵活的架构而备受关注。然而，对于许多刚接触 Flink 的开发者来说，Flink Client 的角色往往不为人知。你是否曾经好奇，当你运行一个 Flink 脚本时，背后究竟发生了什么？Flink Client 又在其中扮演了什么样的重要角色？
2024-06-26 14:12:17
716
原创 Flink window Trigger
结合源码，可以看出 onElement() 每个数据经过，都会执行，在执行过程中对比当前数据时间戳与窗口最大时间戳，从而进行registerEventTimeTimer（注册完后，会注册到internalTimerService中，后续时间到达后会执行onEventTime方法）可以看到Trigger为可选项，当不指定会走默认的，以滑动窗口为例，可从源码中看到默认为EventTimeTrigger。综合上述可以看出，EventTimeTrigger 当数据不发送时，不会自动关闭窗口，会一直等待数据。
2024-01-19 13:58:27
453
原创 Mybatis-plus自定义类型转换器
2、自定义完类型转换器后，插入能够正常插入，查询依旧为空，断点到父类发现 查询时不走类型转换器，百度出的自定义的类型转换器的写法都对，查阅官网后，发现忽略了在实体类上填加 autoResultMap = true。要不就很复杂，要不就是要改ResultMap、要不就是建议selectByExampleWithBLOBs，但3.4.1不存在！数据表中字段类型为longText的字段，实体类中类型也同样设置为JAVA对象，但MyBatis-Plus查询数据时为null，其余数据都可正常查询出来。
2023-07-19 18:10:25
1080
原创 scala 归并排序详解（一步一结果）
先贴源码（欢迎大佬指正）object sortimp { def main(args: Array[String]): Unit = { val list = List[Int](5,2,21,34,11) val xx = msort(list) print(xx) } def msort[T](xs: List[T])(implicit ord: Ordering[T]): List[T] = { def merge(xs: List[T], ys: Lis
2020-07-30 15:34:08
305
原创 mysqld 清除日志 记录
清除mysqld.log 文件必须使用mysql 用户如果忘记密码需要清除mysql 密码//清除mysql用户的密码sudo passwd -d mysql//查看密码状态sudo passwd -S mysql切换到mysql 用户下的log目录下执行echo ‘’> mysqld.log清除文件后，mysql事件被关闭。需要手动开启 • 查看命令1 show variables like ‘%event_sche%’;• 显示的event_scheduler为OFF时
2020-07-22 17:37:43
1283
原创 Limux 下 mysql8.0 安装 说明文档
1、查看linux下自带版本，如果有卸载rpm -qa | grep -i mysql卸载命令：rpm -e --nodeps2、查看相关的文件如果有删除find / -name mysqlrm -rf 删除语句3、解压文件tar -xvf xxxx.tar4、安装rpm -ivh mysql-community-*或务必按顺序 rpm -ivh mysql-community-common-8.0.13-1.el6.x86_64.rpmrpm -ivh mysql-commu
2020-07-22 17:35:42
173
原创 Idea使用hive 创建UDF 异常
直接上图问题分析：hive3.0 相关jar没下载下来。解决思路：1、先查看maven库 是否已经存在hive 3.0的依赖如果没有下载下来，需要将以下参数配置到idea-Dmaven.wagon.http.ssl.insecure=true -Dmaven.wagon.http.ssl.allowall=true -Dmaven.wagon.http.ssl.ignore.validity.dates=true2、如果提示pentaho-aggdesigner-algorithm.j
2020-07-22 17:23:56
325
原创 Flume使用过程中的异常（OOM）
1、发现启动Flume抛出异常ERROR hdfs.HDFSEventSink: process failedjava.lang.OutOfMemoryError: GC overhead limit exceeded解决方案：明显OOM异常，需要调大内存顾在flume中的flume-env.sh 配置：export JAVA_OPTS="-Xms100m -Xmx2000m -Dcom.sun.management.jmxremote"参数解释：-Xms表示JVM Heap(堆内存)最小尺
2020-07-22 17:12:34
927
1
原创 Centos7 JDK安装（详细步骤）
Centos7 JDK8安装1、关闭防火墙systemctl stop firewalld（临时关闭）systemctl disable firewalld （永久关闭）2、查看状态3、创建新用户 并重启（可以不做，为我的后续开发做准备）①useradd student②③reboot欢迎使用Markdown编辑器你好！ 这是你第一次使用 Markdown编辑器 所展示的欢迎页。如果你想学习如何使用Markdown编辑器, 可以仔细阅读这篇文章，了解一下Markdown的基本语法知识。
2020-07-21 17:59:35
285
转载 LInux_环境搭建centos7(转载)
原文地址需要直接点：https://www.cnblogs.com/fangniunanhai/p/10808756.html如有侵权，告知必删，感谢1.CentOS下载CentOS是免费版，推荐在官网上直接下载，网址：https://www.centos.org/download/DVD ISO：普通光盘完整安装版镜像，可离线安装到计算机硬盘上，包含大量的常用软件，一般选择这种镜像类型即可。Everything ISO：包含了完整安装版的内容，并对其进行补充，集成了所 有软件。Min
2020-07-16 13:31:38
155
原创 Hbase2.x java API
记一次 hbase 2.x java api欢迎大佬 指导环境准备resources 文件夹下添加core-site.xml;habse-site.xml代码：import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.Path;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.TableName;
2020-05-27 14:40:36
323
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人