flink sql目前开发的方式包括纯sql的开发，可以运行在zeppelin上，也可以采用代码进行开发，打包成jar运行，代码开发的话每次都要新建工程，会有一些重复性的工作...
发简信
IP属地：浙江
-
Flink SQL实战演练之脚手架开发 -
flink - operator - KeyedStream - KeyedProcessFunction
描述 数据在KeyBy后对key按hash结果进入对应的KeyedProcessFunction subtask 同个key的数据的所有数据都会进入同一个KeyedProce...
-
mac安装Redis可视化工具-Redis Desktop ManagerRedis是一个超精简的基于内存的键值对数据库(key-value)，一般对并发有一定要求的应用都用其储存session，乃至整个数据库。不过它公自带一个最小化的命令行式的数...
-
Flink 使用之 CDC 自定义 DeserializationSchema
Flink 使用介绍相关文档目录 Flink 使用介绍相关文档目录[https://www.jianshu.com/p/74f1990d047c] 背景 本篇接Flink 使...
-
Flink系列 - 实时数仓之FlinkCDC实现动态分流实战（十）自从Flink出了FlinkCDC之后，我们对数据库日志的采集就变得方便了许多了，除去了MaxWell、Cannel、OGG等第三方组件的繁琐配置，目前实现CDC有两种方...
-
如何写好项目方案设计文档
事实上，撰写项目规划和设计文档，最重要的不是文档的模版和格式，而是里面的具体内容，它往往需要结合实际客观环境因素来综合考虑，平衡取舍，是一个需要充分脑力活动的工作。尽管如此，...
-
数据湖是谁？那数据仓库又算什么？数据湖初识 近两年，为什么都开始谈论起 Data Lake 这个”新名词”了？ 先说说我的想法，其实还是用户需求驱动数据服务，大家开始关注 Data Lake 的根本原因是用...
-
Storm，Spark，Flink对比一、容错性（Fault Tolerance） spark依赖checkpoint机制来进行容错，只要batch执行到doCheckpoint操作前挂了，那么该batch就会被...
-
JAVA日志框架适配/冲突解决方案你是否遇到过配置了logback，启动时却提示log4j错误的情况？像下面这样： 你是否遇到过SLF4J的这种报错？ 日志框架的冲突 上面的这些问题，基本都是由于多套日志框架...
-
高性能的Java日志框架log4j2Logback 算是 Java 里一个老牌的日志框架，从 2006 年开始第一个版本，迭代至今也十几年了。不过 Logback 最近一个稳定版本还停留在 2017 年，好几年...
-
xx头条开源了(纯H5项目基于HBuilderX 、MUI、H5+)xx头条开源了(纯Swift项目)https://www.jianshu.com/p/3228bfa3be7d 之兄弟篇 【xx头条开源了(纯H5项目)】 商业用途联系lig...
-
Flink 优化及问题问题排查 看反压：背压高的下游oprator就是瓶颈 关注checkpoint时长checkpoint时长一定程度影响系统吞吐 看核心指标延迟指标、吞吐等 资源使用率 常见问...
-
-
😂
技术人员需要“巴结”领导吗？
面试的时候面试官经常会问:(1)你们的用户量是多少，项目的QPS是多少，TPS是多少，接口的数据量大概有多大；(2)生产线上的部署情况是否了解，怎么做的前后分离，如何做的集群...
-
这个需要你去定义你的schema了，然后利用一些其它手段
Logstash解析嵌套Json
由于我们的埋点日志是嵌套json类型，要想最终所有字段展开来统计分析就必须把嵌套json展开。 日志格式如下： 最开始Logstash的配置文件如下： 按照以上配置文件运行L...
-
方案二亲测可行，感谢博主
Mac系统HiDPI问题
我用mac就是因为人家好看，还好用。再不济我会选择Linux，因为人家好用而且也不丑。 ** 重要的事情说3遍，连接Macbook和显示器的线缆一定是DP口的。**** 重要...
-
@沙晓强 虽然ehcache是分布式框架，但是这篇文章介绍时还只是单机模式，所以没有介绍分布式使用。
Java分布式缓存框架Ehcache 使用(一)
在开发中大型Java软件项目时，对于频繁读写数据库的操作，为了减轻数据库的压力，我们常常会用到缓存。因为数据库连接是非常“昂贵”的资源，因此我们需要增加一个抽象层来解决，缓存...
