為什麼SFTP攝取不工作嗎?

[eyalo]

你好,我做了下麵的代碼但似乎集群運行很長一段時間然後停止沒有任何結果。

附加我的代碼:(我用的com.springml.spark。sftp庫和安裝Maven)

我也白名單我SFTP服務器上的本地機器的IP。也許有另一種whitlisting以防磚引擎運行在不同的IP ?

感激這裏的任何幫助,甚至一個替代解決方案。

謝謝。

[Debayan]

嗨,你能更新錯誤嗎?

請標記@Debayan與你的下一個評論,這樣我將得到通知。謝謝你！

[eyalo]

嗨@Debayan穆克吉,謝謝你的回複。

後重新啟動集群我得到了以下錯誤:. lang。NoClassDefFoundError的:scala美元/產品類的

據我所知,它seeme像不認識我的課雖然我安裝我的集群的圖書館:

com.springml: spark-sftp_2.10:1.0.2

com.springml: spark-sftp_2.11:1.1.3

你知道是什麼原因嗎?

僅供參考,根據這個文檔:我做到了https://github.com/springml/spark-sftp

[eyalo]

@Debayan慕克吉你好,我不知道你有我給你的回複所以我彈我的信息了。

謝謝。

[Debayan]

嗨,抱歉延遲!我認為這個問題可以表麵由於各種原因。我們可以研究整個集群和分流。你能提出一個supportcase與我們,這樣我們可以繼續調查嗎?

再次感謝!