嗨!。
這是我的第一篇文章在這裏!
我有一個問題,當我啟動一個“運行”在我的筆記本上:在一個時刻(總是在同一細胞),下麵的細胞被跳過。
正如你所看到的38個正確執行的命令和命令40我有一個好狀態(當我檢查臨時視圖”post_reco_transactions“我有數據,當我檢查用表”……rod_sui.post_reco_transactions_ ${國家}一個……”(抱歉我寧願部分隱藏路徑),我也有數據。沒有明確的錯誤消息。
當然所有的細胞與“命令跳過”空對象和我沒有輸出。
當我手動執行細胞# 41,我沒有任何錯誤消息。
問題是,這個問題我不能創建一個工作,它將為每個執行失敗。
你有一個主意嗎?
嗨Valskyyy,
我試著做同樣的步驟。但是它對我來說很不錯,即使我嚐試運行。我的猜測是,有一些其他問題發生在重置集群的集群和因此,臨時視圖定義越來越隨著臨時視圖綁定到一個sparksession下降。
你可以試著把你提到的四個步驟在一個單獨的筆記本,看看這個問題reoproduces呢?
此外,你可以嚐試使用“df創建視圖。createOrReplaceTempView”方法和sql實現隻檢查這個問題嗎?
嗨Lakshay,
謝謝你的回答。所有細胞後滑倒了。
我做更多的測試,這是信息的步驟(通用名稱的視圖/道路/表)。
我創建所有這些步驟,運行:
1 /我宣布sql參數,例如“國家”或“ab_test_id”
2 /我創建一個表my_database.my_table_ ${國家}_ab_test_id_ $ {ab_test_id}
這個表是好的,我可以顯示的時候做一個簡單的:
SELECT * FROM my_database.my_table_ ${國家}_ab_test_id_ $ {ab_test_id}
3 /我必須從這個表創建一個臨時視圖
我可以肯定的是:
如果存在my_temp_view下降的觀點
然後我創建臨時視圖:
創建或替換臨時視圖my_temp_view
SELECT * FROM my_database.my_table_ ${國家}_ab_test_id_ $ {ab_test_id}
> >狀態好,沒有錯誤消息
4 /然後我想顯示臨時視圖:
SELECT * FROM my_temp_view
跳過> >命令(如所有以下細胞)
如果我手動重啟這個細胞(SELECT * FROM my_temp_view),視圖顯示的內容,如果我手動執行所有下麵的細胞。
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
我已經嚐試安排工作。我也有同樣的行為,但是在工作中我有一個明確的錯誤信息屏幕:
(TABLE_OR_VIEW_NOT_FOUND)表或視圖my_database.my_table__ab_test_id_不能被發現。的拚寫和正確性驗證模式和目錄。
如果你沒有資格名稱模式,驗證current_schema()輸出,或與正確的模式限定名稱和目錄。
但我不明白,在步驟2 /我正確地看到我的表的內容創建和它存在的參數名稱。