Flink Java Cannot resolve method assignTimestampsAndWatermarks

問題 寫了個demo測試flink水印的方法,明明參數傳遞均無問題,但是一直提示cannot resolve method xxxx 問題的核心不是方法參數傳遞,而是泛型問題 因爲習慣通過IDEA的.var方式自動生成方法的返回參數 如果傳入參數是Tuple3<String, Integer, Long>,返回結果使用泛型Tuple3去接收,那麼後續的窗口操作涉及到元組的數據類型均會同步報錯。
相關文章
相關標籤/搜索