240 发简信
IP属地:江苏
  • 120
    Flink 清理过期 Checkpoint 目录的正确姿势

    本博客是笔者在生产环境使用 Flink 遇到的 Checkpoint 相关故障后,整理输出,价值较高的 实战采坑记,本文会带你更深入的了解 Flink 实现增量 Checkp...

  • 并行与并发 的区别

    参考:http://c.biancheng.net/view/95.html 关键点 通过关键词汇,实现快速理解,记忆的目的: 1、并发,在同一个时间点,任务不会同时运行2、...

  • 120
    Flink 异步IO实战

    基本概念 首先通过官网的一个图片了解一下Asynchronous I/O Operation Flink source收到一条数据就会进行处理,如果需要通过这条数据关联外部数...

  • 120
    基于flink sql构建实时数据仓库

    1、需求背景 根据目前大数据这一块的发展,已经不局限于离线的分析,挖掘数据潜在的价值,数据的时效性最近几年变得刚需,实时处理的框架有storm,spark-streaming...

  • 二十多岁的年纪,有的人脱了单,有的人脱了贫,而我却脱了缰,像只哈士奇一样在二逼的道路上狂奔。

  • 120
    ElasticSearch 亿级数据检索深度优化!

    一、前言 数据平台已迭代三个版本,从头开始遇到很多常见的难题,终于有片段时间整理一些已完善的文档,在此分享以供所需朋友的实现参考,少走些弯路,在此篇幅中偏重于ES的优化,关于...

  • 120
    记一次Flink写入Kafka坑点

    最近做了一个将结果数据写入到Kafka的需求,sink部分代码如下: val kafkaProducer: FlinkKafkaProducer011[String] = n...

  • 怎么评价程序员35岁了还在撸代码?

    ### 正文 > 今天不说废话,不不卖焦虑,就想阐述一下事实,身边很多35岁的人和我一样,仍在处身于技术代码当中,30+的年龄撸码,我就撸码了 还有一个兄弟三十五六了还在画图...

  • 偷情其实并不刺激

    上一篇的文章《偷情真的那么刺激吗?》我倒没想到有那么多的阅读量,虽然写得都是自我臆想,捕风捉影的事情,但也可以作为饭后谈资不是。你要是问我偷情刺不刺激,那我这还跟...

  • FlinkCEP with EventTime

    在之前的Hello FlinkCEP文章中已经简单介绍了FlinkCEP的使用,只是为了简化逻辑并没有加入时间概念。那么在实际业务场景中,都是会要求在特定的时间内发生某种事件...

  • FlinkCEP SQL快速入门

    在之前的文章Hello FlinkCEP和FlinkCEP with EventTime介绍了FlinkCEP的基本使用方法,本文将介绍flink提供的sql方式实现模式匹配...

  • 120
    Hello FlinkCEP

    关于FlinkCEP的相关概念和说明网上已经有很多介绍的文章,这里就不再赘述,本文主要通过一个简单的场景作为FlinkCEP的入门快速上手,并通过样例初步了解一下Combin...

  • 我估计是老板遇到啥事然后心情不好,你撞枪口上了,就拿你撒气了

    又失业了

    昨天,人事跟我说,老板对你很不满意!我一听,一脸懵逼,连老板面都没有见过几次突然就说不满意?什么情况?经过我仔细的回想,大概有以下几个事件:1、上班的第二周突然企业微信的一个...

  • 这种事也是老板直接call你吗,没得其他同事解决或者直接电话吗

    又失业了

    昨天,人事跟我说,老板对你很不满意!我一听,一脸懵逼,连老板面都没有见过几次突然就说不满意?什么情况?经过我仔细的回想,大概有以下几个事件:1、上班的第二周突然企业微信的一个...