搞了一个Flink实时同步Hive,搞了好久天,后来才发现没有开启checkpoint,我一番骂娘,因为查了好久,都是告诉你如何通过SQL实现Flink、Hive流批一体,却没有告诉你要把checkpoint打开。为什么要把checkpoint打开?因为Flink实现下的Hive Streaming是基于BulkFormat实现的,即Flink-Hive的实时是伪实时,它只支持批量导入,导入的时间点就是checkpoint发生之时,所以没有checkpoint,就没有hive的实时数据写入。