天天看點

storm mysql 結合_storm 與mysql整合問題

首先說明下問題的情況,

1、我storm 環境已經搭建完成,在本地測試wordcount是沒問題的,

2、我在wordcount中加入一個MysqlBolt,此Bolt隻是簡單的把 wordcount的結果存入mysql資料庫中,在本地模式測試測試時,完全可以把結果插入指定表。

3、我的每個storm 節點都已經把mysql-connector-java-5.1.23.jar 放到storm的lib目錄下。

4、每個節點均可以通路指定資料庫,都已經開通相應權限

5、并且在遠端模式下執行原始wordcount是沒問題的

OK !!!

問題是,在遠端模式下運作整合mysql的wordcount時 就出錯誤了,異常為空指針,通過查找代碼,發現在獲得mysql 連接配接 時異常。

代碼如下:标紅處報異常

String host_port = "slaver1:3306";

String database = "test";

String username = "root";

String password = "hello";

String url = "jdbc:mysql://" + host_port + "/" + database;

Connection conn = null;

try {

Class.forName("com.mysql.jdbc.Driver");

conn = DriverManager.getConnection(url, username, password);

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (SQLException e) {

e.printStackTrace();

}

問題原因:是使用maven打包時,沒有包括第三方jar包

解決辦法:這裡就不贅述了,大家可以參考http://www.voidcn.com/article/p-fthdfaff-bv.html