第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會有你想問的

spark submit的時(shí)候怎么導(dǎo)入自己寫的依賴模塊?

spark submit的時(shí)候怎么導(dǎo)入自己寫的依賴模塊?

收到一只叮咚 2018-10-13 18:26:30
python代碼中的importfrom spark_learning.utils.default_utils import setDefaultEncoding,initSparkContext,ensureOffsetsubmit命令:bin/spark-submit --jars /home/jabo/software/spark-1.5.2-bin-hadoop2.6/lib/spark-streaming-kafka-assembly_2.10-1.5.2.jar\/home/jabo/spark-by-python/spark_learning/third_day/streaming_kafka_avg.py\ --py-files /home/jabo/spark-by-python/spark_learning/utils/default_utils.py官網(wǎng)解釋:For Python applications, simply pass a .py file in the place of <application-jar> instead of a JAR, andadd Python .zip, .egg or .py files to the search path with --py-files.但是會報(bào)錯(cuò),找不到import模塊:Traceback (most recent call last):  File "/home/jabo/spark-by-python/spark_learning/third_day/streaming_kafka_avg.py", line 10, in <module>    import spark_learning.utils.default_utils ImportError: No module named spark_learning.utils.default_utils如何解決??
查看完整描述

2 回答

?
烙印99

TA貢獻(xiàn)1829條經(jīng)驗(yàn) 獲得超13個(gè)贊

你可以試一下把--py-files 參數(shù) 放在你要運(yùn)行腳本的前面哈!剛才我們也遇到這個(gè)問題 就是這樣解決的!

查看完整回答
反對 回復(fù) 2018-10-27
  • 2 回答
  • 0 關(guān)注
  • 1600 瀏覽

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號