我使用一個框架和一個查詢我在哪裏做,
df = seg_df.select .write (*)。選項(“壓縮”、“gzip),我得到以下錯誤,
當我不寫。選擇我沒有得到以下錯誤。為什麼給我重新分區錯誤。那是什麼。
/ tmp / tmpy1752o0x。py跑步者(params、橋梁、道路、date_graph、日期)
97日期=日期,
98 * *千瓦)
推薦- - - - - - > 99 load.write (df,
100 table_name =表,
101層= current_layer,
/ local_disk0 /火花c24724ad - 99 c7 - 4934 - 8 aad c9082a731e34 / userfiles - e9f6ed1f - 8660 - 40 - d0 be02 e4ab3d83f5e4 pipeline.zip /負載。在寫py (df、table_name層、日期、火花date_graph)
757 date_graph = date_graph)
758年:
- - > 759 single_write (df,
760項,
761層=層,
/ local_disk0 /火花c24724ad - 99 c7 - 4934 - 8 aad c9082a731e34 / userfiles - e9f6ed1f - 8660 - 40 - d0 be02 e4ab3d83f5e4 pipeline.zip /負載。py single_write (df、入口層,日期、火花,date_graph)
615 data_name = final_entry_cp(“數據表”)
616如果final_entry_cp“重新分配”:
- - > 617 df = df.repartition (final_entry_cp[“重新分配”])
618如果“partitionBy”條目:
619年df = df.repartition (final_entry_cp [' partitionBy '])
AttributeError:“NoneType”對象沒有屬性“重新分配”
