Flink相關異常解決

2021-10-03 06:14:54 字數 630 閱讀 5546

本文開頭附:flink 學習路線系列 ^ _ ^

錯誤資訊:

exception in thread 「main」 org.apache.flink.table.api.tableexception: arity [2] of result [[lorg.apache.flink.api.common.typeinfo.typeinformation;@52354202] does not match the number[1] of requested type [generictype].

原因:

因為 table api 在 執行tableenv.toretractstream(table, wordcount.class);操作時,無法讀取到 wordcount 類中的屬性。

解決方法:

類中屬性為 private 修飾,沒有寫get() / set() 方法

將屬性修飾符由 private 變為 public 修飾

類中字段型別改為基本型別(提供來自:ls bryant )

Flink日誌相關

flink日誌的使用 直接在類內定義,即可使用。當然了,pom匯入,看你喜歡怎麼用了 org.slf4jgroupid slf4j log4j12artifactid 1.7.7version runtimescope dependency log4jgroupid log4jartifactid ...

MySQL 匯入匯出 以及 相關常見異常解決

命令列下具體用法如下 mysqldump u使用者名稱 p密碼 d 資料庫名 表名 指令碼名 需要在cmd命令列下執行,不能登入mysql的cmd client 1 匯出資料庫為dbname的表結構 其中使用者名為root,密碼為dbpasswd,生成的指令碼名為db.sql mysqldump u...

NConf異常相關

在nconf嚮導的時候報如下錯誤 copy config file file accounts.php failed copy config file authentication.php failed copy config file main.php failed copy config fil...