溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這期內容當中小編將會給大家帶來有關如何理解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包
上述就是小編為大家分享的如何理解storm與mysql整合問題了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
