生产FullGC问题排查

在 2020 年 6 月 28 日2021 年 8 月 10 日上张贴由龙安_任天兵发表回复

FullGC时间过长问题突然来了一波gc时间过长的告警，类似下面这个，接着接二连三的来了很多…

flink读取kafka数据未能触发watermark

在 2020 年 2 月 5 日上张贴由龙安_任天兵发表回复

过年被病毒闹的出不了门，就顺带着把flink秒级统计的逻辑写了一下，逻辑很简单，就是从kafka消费数据，然后…

flink使用时间戳作为起始offset消费kafka的问题

在 2019 年 10 月 21 日2019 年 10 月 26 日上张贴由龙安_任天兵发表回复

代码如下 private static voidtest2()throwsException { En…

flink通过jdbc读取postgresql数据库里的数据

在 2019 年 10 月 17 日2024 年 5 月 16 日上张贴由龙安_任天兵发表回复

问题1：从postgresql里使用flink-jdbc读取数据的问题, 数据类型不匹配，不支持jsonb等…

flink相关 – 通过Table API写入ElasticSearch的部分源码分析

在 2019 年 10 月 17 日上张贴由龙安_任天兵发表回复

New ElasticSearch()…xxx…registerTableSink(); ElasticS…

flink的动态表格

在 2019 年 10 月 17 日2021 年 8 月 10 日上张贴由龙安_任天兵发表回复

目的：订阅kafka的消息(kafka的消息是从postgresql来的)，将kafka的消息作为Table…

flink相关 – 读入kafka数据源

在 2019 年 10 月 17 日上张贴由龙安_任天兵发表回复

业务代码如下 : fsTableEnv.connect( newKafka() …

flink学习笔记(一)

在 2019 年 10 月 17 日上张贴由龙安_任天兵发表回复

架构什么是flink flink是一个框架或者叫流式计算引擎，他可以用来处理有界(批处理，mapReduc…

Java字节码增强应用

在 2019 年 7 月 9 日2019 年 7 月 9 日上张贴由龙安_任天兵发表回复

Java字节码增强技术认识Instrumentation 基本用法: 方法作用 addTra…

JVM Sandbox 源码分析（一）基础篇: Instrumentation和ClassFileTransformer作用

在 2019 年 6 月 3 日上张贴由龙安_任天兵发表回复

背景 jvm sandbox是一个开源项目https://github.com/alibaba/jvm-san…