flink定时读取mysql
生产上有时候需要定期新增或修改某些筛选值.为了避免频繁重启任务,修改代码,可以将这些配置信息放在mysql表中定期更新,然后通过发送广播流给下游.这样可以减少更改频率,降低重启风险.public class MysqlSource extends RichSourceFunction<Map<String, ValueConf>&
MySQL 分组后取最新记录
业务场景:取一张表里面最新的一条数据,以最新的一条数据为基准进行相关业务操作。CREATE TABLE `t_biz` ( `id` int NOT NULL AUTO_INCREMENT, `name` varchar(100) COLLATE
Tomcat异常讲解
1 Tomcat异常1.1 起步内存溢出问题Exception in thread http-bio-80801.1.1异常现象现象如下:Tomcat7启动后,后台抛出如下异常,前台一直无法登陆Exception in thread ""http-bio-8080"-exec-6" java.lang.OutOfMemoryError: Per
关于jdk8中的四大核心函数式接口
一、Consumer 接口1、接口说明Consumer 接口是消费性接口,无返回值。Java8 中对 Consumer 的定义如下所示。@FunctionalInterfacepublic interface Consumer { void accept(T t); &nbs
Shell脚本应用两个例子
平时很少写Shell脚本,主要是它的语法相比Python要难掌握,但做为非专业运维工程师,拼拼凑凑还是要能写一点Shell代码,在处理文件相关任务时还是要方便些。一、数据库冷备#!/bin/sh bakFile="/bak/"$(date "+%Y%m%d")"150001.gz" mysqldump -h&nbs