你好,
我試圖設置DLT管道,其基本管道測試目的我麵臨的問題而啟動管道,任何幫助都是感激
代碼:
@dlt.table (name = " dlt_bronze_cisco_hardware ")
def dlt_cisco_networking_bronze_hardware ():
回報(
spark.readStream.format \ (“cloudFiles”)
.option (“cloudFiles。”、“json格式”)\
.option (“cloudFiles.schemaLocation”、“abfss: / /(電子郵件保護)/ DLT_Schema”)\
.load (“abfss: / /(電子郵件保護)/著陸/ DLT_Testing /硬件/ * / * / * / * . json”)
)
嗨@Arumugam拉馬錢德蘭似乎你有一個火花集群配置上設置你的DLT工作,隻允許python和SQL代碼。檢查配置火花(集群政策)。
在任何情況下,python代碼應該工作。檢查筆記本的默認語言,它不應該scala。
檢查這個文檔的更多細節。
https://docs.www.eheci.com/notebooks/notebooks-manage.html執行上下文
評論標記為“最佳答案”解決查詢,謝謝。