Jorvi

代码已经找不到了，应该就是一些获取连接、释放连接和查询之类的操作

Flink从数据库读取配置信息

一、使用State 1.1 主入口 1.2 Process 这样子可以实现：每15分钟去查一次数据库，更新配置信息。 1.3 测试 从测试结果可以发现： 在同一个Slot中处...

Jorvi

3132 2 1

Jorvi

1. 创建 Project 2. Upload Zip包 Zip包中保存的是 ***.job 文件，每个job文件代表 Project 内的一个Flow，各Flow间可利用 ...

Jorvi

参考：https://blog.csdn.net/chinabestchina/article/details/78009220[https://blog.csdn.net/...

Jorvi

参考：https://blog.csdn.net/jdzms23/article/details/17550119[https://blog.csdn.net/jdzms23...

Jorvi

1. 同步回调 Callback Server Client 运行结果 2. 异步回调 Callback同上 Server同上 Client 运行结果

Jorvi

1. 异常 IDEA提示错误： 2. 错误原因 StreamExecutionEnvironment导包错误。 用scala写时，应该导入： import org.apach...

Jorvi

1. 异常信息 报错位置是 org.learn.function.WordCountProcessFunction.onTimer(WordCountProcessFunct...

Jorvi

1. 代码 1.1 Source 1.2 Map 1.3 Process 设置TTL时间为历史时间，看看定时器如何触发？ 2. 结果 从结果可见： 给 TimeService...

Jorvi

就是简单的POJO

Flink批量写MySQL Demo

1. 主程序 利用 timeWindowAll 对 DataStream 画窗口 利用 FileToMysqlWindowFunction 将窗口内的数据组成 List 将 ...

Jorvi

2706 2 0

Jorvi

groupByKey 进入org.apache.spark.rdd.PairRDDFunctions.scala 将 RDD 里 key 相同的元素分组到一个序列里，然后基于...

Jorvi

1. 现象 任务运行非常慢，reduce 长时间卡在 99%。 查看日志： 2. 排查 查看 YARN 上运行状况，发现数据倾斜，大量数据集中在一个 key 上。 运用临时表...

Jorvi

1. 主函数 2. Source 3. 处理函数 4. 测试 4.1 正常情况 文本内容： 结果： 4.2 异常情况 文本内容： 结果： 5. 总结 主要是通过 scala ...

Jorvi

参考：https://www.cnblogs.com/damowang/p/6226167.htmlhttps://www.cnblogs.com/java13/p/1092...

Jorvi

如果MySQL连接池内连接失效，继续读写会出现异常： 解决方案：增加配置： 官网配置： testConnectionOnCheckin Default: false If t...

Jorvi

1. 主程序 利用 timeWindowAll 对 DataStream 画窗口 利用 FileToMysqlWindowFunction 将窗口内的数据组成 List 将 ...

Jorvi

1. pom.xml 2. 主函数 3. Source 4. Sink

Jorvi

参考：https://www.cnblogs.com/Leo_wl/p/3145108.html 1. pom.xml 2. 入口程序 3. 压缩 4. 解压 5. 命令行 ...

Jorvi

一、使用State 1.1 主入口 1.2 Process 这样子可以实现：每15分钟去查一次数据库，更新配置信息。 1.3 测试 从测试结果可以发现： 在同一个Slot中处...

Jorvi

一. 托管State 1.1 主程序 构建 StreamExecutionEnvironment； 启动 Checkpoint，并设置间隔时间； 设置 StateBacken...