5 舞舞舞吾

尚未进行身份认证

我要认证

看红尘冉冉,须臾之间,参遍昙华演变。问法珠玄玄,方寸有变,听尽默剑说禅

等级
TA的排名 3w+

FlinkSql 读取kafka sink到mysql 案例

public static void main(String[] args) { StreamExecutionEnvironment bsEnv = StreamExecutionEnvironment.getExecutionEnvironment(); bsEnv.setStreamTimeCharacteristic(TimeCharacterist...

2019-11-27 15:36:18

数据结构重习之1-数据逻辑结构和数据的存储结构

数据的逻辑结构:简单的来说就是指数据对象中各数据之间的相互关系。这个概念不是很难理解。比如把数据对象比作一个家庭,把逻辑关系就是家庭成员的之间的关系,如夫妻、父子等逻辑关系。在数据结构中,数据的逻辑关系比较稍微复杂一点,其关系有四个:1:集合结构2:线性结构 元素之间一对一3:树形结构 元素一对多4:图形结构 元素多对多关系数据的存储结构 ,也叫物理结构,就是数据逻...

2019-11-27 09:56:37

Cannot instantiate user function.

Caused by: org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function. at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfi...

2019-09-26 16:53:30

Flink时间窗口代码分析

本代码分析以TumblingEventTimeWindows 为例,若有疏忽,请包涵。第一步 在TumblingEventTimeWindows 类中调用assignWindows()方法。public Collection<TimeWindow> assignWindows(Object element, long timestamp, WindowAssignerConte...

2019-08-16 15:23:18

ERROR: java.io.IOException: Table Namespace Manager not fully initialized, try again later

ERROR: java.io.IOException: Table Namespace Manager not fully initialized, try again later    at org.apache.hadoop.hbase.master.HMaster.checkNamespaceManagerReady(HMaster.java:2693)    at org.apache...

2018-08-10 17:15:02

网站性能测试基本概念

注:引用李智慧教授的架构核心原理书籍;若有不足地方欢迎指出一 系统性能测试的指标 1:响应时间  及一个操作到返回的时间;包括从发出请求开始到收到最后响应数据所需要的时间;这个指标直接放映了系统的反应的快慢。 2:并发数 指的是系统同时处理请求的数目,这个数字放映了系统的负载特性。 3:吞吐量  指的是单位时间内系统处理的请求数;体现系统的整体处理能力,常用的指标有请求数/秒或者页

2018-01-29 10:52:20

Elasticsearch索引内部原理最简洁的归纳

Elasticsearch 内部索引写入原理 :   1: 索引首先会写入到索引的 buffer缓存和translog日志文件中,这个期间不能被客户端索引;   2:每隔一秒钟,buffer 缓存中的数据会被写入到新的segment缓存文件 file中,同时写入系统的缓存中os caching 中,并打开索引,外部客户端可以进行索引查询;这一点说明Elasticsearch 并不是所谓的实

2018-01-11 15:53:54

yarn提交总结

注:此记录仅做自己学习记录yarn的提交过程简单的总结如下:第一步:client 通过RPC 的applicationClientProcotol协议提交客户自己编码的应用程序到 resourceManager第二步:applicationMaster 启动后,首先向resourceManager 进行注册,注册通过RPC 的  applicationMasterProcotol协议

2017-09-07 15:13:51

分布式基本副本控制协议

分布式协议

2017-08-30 14:39:55

分布式系统一致性

分布式一致性

2017-08-24 18:56:15

分布式系统的网络异常

分布式系统

2017-08-24 18:19:07

Http协议与TCP协议简单理解(转)

tcp和http协议区别

2017-08-04 10:59:08

spark整合kafka案例

spark 整合kafka

2017-08-03 11:30:26

过拟合和欠拟合---西瓜笔记一

申明:仅学习过程笔记记录,多处引用周志华老师书本内容错误率:把分类错误的样本占总体样本总数的比率精度(accuracy)= 1 -错误率误差:把学习器的实际预测输出与样本的真实输出的差异叫做误差;

2017-08-01 16:55:28

线程join和sleep的区别

线程sleep 和 wait 的区别

2017-08-01 10:37:58

多线程wait 和 notify的判断条件(if 和 while)和假死

多线程通信;notify和wait

2017-07-31 17:21:27

springboot+quartz分布式

quartz分布式

2017-07-26 10:32:23

JVM 优化浅解分析

先上个图;了解一下gc各个内存分配:优化问题点:     1:内存回收导致的长时间停顿 ;由于堆设置太大,一次Full GC的停顿时间高达14秒。并且由于程序设计的关系,访问文档时要把文档从磁盘提取到内存中,导致内存中出现很多由文档序列化产生的大对象,这些大对象很多都进入了老年代,没有在Minor GC中清理掉。这种情况下即使有很大的堆,内存也很快被消耗殆尽,由此导致每隔十几分钟出

2017-07-24 17:58:02

jvm 垃圾回收机制 安全点

上一节,我们说到  jvm 保洁阿姐一边打扫的,别人一边扔垃圾怎么处理呢?其实很简单,jvm保洁阿姐再打扫前,告诉公司所有说:我要打扫了,你们不准扔垃圾了;OK解决了!哈哈。那在jvm垃圾回收中,上面的情景怎么处理呢?在可达性分析中要分析哪个对象没有引用的时候,必须在一中快照的状态点进行,就是这个点所有的线程都被冻结了;不可以出现分析过程中对象引用关系还在不停的变化;如果该点不能满足的话,

2017-07-24 14:15:32

jvm的垃圾回收机制——jvm超简洁直白理解

jvm的保洁啊姐一早就来了,但让保洁阿姐犯愁的事情是:   一:哪些东西需要回收呢?   二:什么时候回收呢?   三:用什么方式回收呢?那我们先弄清上面疑问前,先了解一下jvm的内存分配jvm 内存可以分栈,本地方法栈,程序计数器、堆和方法区;栈 :  线程私有,生命周期和线程同步;存放局部变量(基本数据类型,对象的引用),其所需内存大小编译器时候    已经确认,故内存分配有确定性;程序计数器

2017-07-21 11:33:50

查看更多

勋章 我的勋章
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 勤写标兵Lv1
    勤写标兵Lv1
    授予每个自然周发布1篇到3篇原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。