解決了!RuntimeError:看來你是試圖從廣播引用SparkContext變量,行動,或轉換。SparkContext隻能用於驅動程序,而不是在代碼上運行工人。有關更多信息,請參見火花- 5063。 我創建了以下模型:該調用get_identifier_information()如下:這是我日誌模式,這是我遇到的錯誤:RuntimeError:看來你正試圖引用SparkContext broadc……
如何改變壓縮編解碼器的sql倉庫的書麵文件? 嗨,我現在開始使用SQL倉庫,我們有我們的大多數湖在壓縮和時髦的不同。我如何設置SQL倉庫使用像gzip壓縮,zstd,在創建、插入、等等?試:設置spark.sql.parquet.compre……
