發(fā)簡信
IP屬地：浙江
-
flinksql從kafka中消費(fèi)mysql的binlog日志
*使用canal采集mysql的binlog禁谦，輸出到kafka，然后使用flinksql消費(fèi)kafka，并輸出到屏幕 mysql需要開始binl...
-
FlinkSql cdc 從mysql表join之后寫入elasticsearchgithub地址：https://github.com/ververica/flink-cdc-connectors Flink CDC Con...
-
flinksql 1.11 消費(fèi)kafka到hive中環(huán)境問題flink1.11發(fā)布以來晚岭，很多人就很關(guān)心hive倉庫實(shí)時化。所以自己也試著嘗試一下卫键，然而遇到很多環(huán)境問題领曼。 環(huán)境準(zhǔn)備好之后，先在本地測試一下,...
-
flink 狀態(tài)后端的簡單理解
MemoryStateBackend 狀態(tài)數(shù)據(jù)保存在taskmanager的內(nèi)存中搀玖，所以程序能夠使用狀態(tài)的大小受限于taskmanager的內(nèi)存...
-
flink watermark生成余境，向前推進(jìn)時鐘eventTime eventTime根據(jù)事件中的某個字段指定(assignTimestampsAndWatermarks) watermark...
-
flink 使用RichCoFlatMapFunction算子，用一個流控制另一個流輸出
感覺這種場景還是挺有用的，經(jīng)過在本地和yarn上測芳来，沒問題