oozie在Python中導入我自己的模塊

Question

我是Oozie的新手。在main.py，我需要導入我自己的模塊MY_CLASS.py它被上傳到main.py相同的HDFS路徑。

from MY_CLASS import my_class_1 

def main(): 
    x = my_class_1() 
    ... 

有在Oozie的說法導入錯誤的錯誤：沒有模塊名爲MY_CLASS。而它在當地完美運作。

我也嘗試在HDFS中創建一個文件夾，將MY_CLASS.py與__init__.py一起放入它中，以便該文件夾可以被識別爲一個包。然而from folder.MY_CLASS import *不適合我oozie。

有誰知道如何做到這一點？非常感謝。

Answer 1

我發現了anwser。只需要添加export PYTHONPATH=$(pwd)。