問題現(xiàn)象：

FlinkSQL任務(wù)任務(wù)沒有報錯，但是目標(biāo)端Starrocks數(shù)據(jù)庫中一致沒有數(shù)據(jù)生成。在Web UI頁面的Watermark頁簽中可以看到：No Watermark (Watermarks are only available if EventTime is used)。

查看Jobmanager和taskmanager日志，看不到有報錯信息。

問題原因：

由于之前測試生成的一批數(shù)據(jù)不是持續(xù)的，數(shù)據(jù)生成的時間小于數(shù)據(jù)的窗口大小，watermark 生成器將不會向前推進。所以沒有生成watermark 。

解決辦法：

通過持續(xù)不斷地向Kafka寫入數(shù)據(jù)，即可解決這個問題。