在前面的文章我们主要介绍了flink多数据源的时间窗口,然后对数据进行计算,但是试想一下,真实的生产环境中我们经常多数据源都是乱序的,所以此时我们多个数据源拿过来进行join的时候,由于数据处理的延迟,会导致如下情况...
作者 Rae 发布的文章
使用Minikube快速的搭建一个本地的Kubernetes环境
在前面我们介绍了使用kuboard来搭建kubernetes环境,这种在生产上实用性非常高,但是在内部的测试环境上,一般我们不会涉及到那么奢侈,因此这里我们习惯性使用minikube来快速搭建一个本地或者测试环境的k...
热文使用MAT分析java内存溢出的原因
上一篇文章《Eclipse安装Memory Analyzer详细教程》我们介绍了MAT的安装,这篇文章我们介绍下使用MAT分析内存泄漏的思路。一、导入内存快照这里我们用前面生成的案例来分析内存泄漏,案例在《实战Jvm...
热文Eclipse安装Memory Analyzer详细教程
在生产环境中我们经常会涉及到OOM的报错,一般我们会dump下整个jvm的内存快照,dump下来之后我们再对快照文件进行内存分析,这里我们建议使用MAT(Memory Analyzer)进行分析,MAT工具的话在ec...
这篇文章我们介绍下jvm另外一种内存溢出,就是StackOverflowError,发生这个的问题主要是栈内存溢出,完整的错误实例如下:Exception in thread "main" java.lang.Sta...
前两篇文章我们主要介绍的是java的堆内存溢出,这篇文章我们介绍下jvm的方法区内存溢出,也就是常见的Metaspace,完整报错示例如下:Exception in thread "main" java.lang.O...
上一篇文章《实战Jvm内存溢出之GC overhead limit exceeded》我们介绍了jvm堆内存溢出的第一种方式GC overhead limit exceeded,这篇文章我们介绍下最常见的JVM内存溢...
在实际的java应用里面我们经常会遇到OOM的场景,所以遇到这种问题我们就需要进行排查,今天这篇文章我们主要介绍的jvm内存溢出异常之GC overhead limit exceeded。这个异常其实并不陌生,遇到这...
热文Rabbitmq使用安装包进行安装的详细教程
在我们的生产环境我们对于rabbitmq的使用我们一般不怎么用docker的方式安装,在服务器条件有限的情况下我们使用原始安装包进行安装即可。这篇文章我们演示下使用安装包的方式进行Rabbitmq的安装。这里我们按照...
Springboot项目开发websocket服务端
最近接触到一个银行的项目对接,原以为使用现在成熟的http进行交互,结果银行提供的文档是socket的,因此需要我们编写socket服务端供银行进行调用。所以没办法,需要来操作一下这个socket的服务端项目。下面直...
To B 新产品玩家的破局之道
To B领域不像To C很多信息都不好获取,尤其是进入特定场景的To B赛道更是不进去,很难获得真实信息。因此偶尔能接到To B产品从业者,如何获取To B竞品信息的咨询。本篇作为从业者探讨下,To B 新产品玩家的...
热文自动化部署工具Jpom系列(四)使用ssh部署VUE项目
在之前的文章《自动化部署工具Jpom系列(三)使用ssh部署JAVA项目》我们介绍了使用jpom实现自动化部署java服务,这篇文章我们介绍下使用利用jpom实现ssh部署前端VUE的项目(React项目也适用)。一...
上一篇文章《Flink流处理系列(四)flink读取多数据源》我们介绍了在flink流处理中实现多数据源的读取。在实际的场景业务中,一般我们多数据源把数据读取进来之后,肯定不是直接转存到其他地方这么简单,一般的应用场...
上一篇文章《Flink流处理系列(三)flink cdc读取mysql binlog》我们介绍了一下使用flink的cdc来读取mysql。这篇文章我们的案例代码还是在上一篇的基础上改动即可。在实际的业务中,我们经常...
这是flink流处理的第三篇文章,咱们介绍下使用flink的cdc功能,读取mysql的binlog实现数据同步。下面直接实战演示下:一、安装mysql安装mysql的话,,这里选择5.7或者8.x的版本都可以,建议...
