HMaster和HRegionServer很可能是因为OOM挂掉的，因此我们需要更改Master和Regionserver的Java堆栈大小

Flink-CDC监控mysql的好处在于，在项目中无需向canal和maxwell那样要先将数据先存入kafka，而是直接将数据拉取到实时流当中。API方式监控import com.alibaba.ververica.cdc.connectors.mysql.MySQLSource;import com.alibaba.ververica.cdc.connectors.mysql.table.S

1、需求：动态监控mysql中gmall2数据库的order_info数据表，将变化的信息转成json字符串存储到kafka中，具体实现如下：CanalClientpackage com.zyj.gmall.canalimport java.net.{InetSocketAddress, SocketAddress}import java.utilimport com.alibaba.fastjs

一、hbase和phoenix的对应关系hbasephoenixnamespacedatabase(库)tabletable（表）column familycf:cqcolumn quliafierrowkey主键在sql中如家...