1回答
- 新しい順
- 投票が多い順
- コメントが多い順
0
So i found the answer and putting this up for anyone who comes seeking it out.
When using a Grouped Map Pandas UDF, it must be defined within the same spark session as the main function. This is especially tricky in Python, whereby spark will not react in an expected manner if you import the UDF into your main console. If you start a separate spark session define your UDF there, then import into your main session it will fail and will not error out and just run endlessly.
回答済み 4年前
関連するコンテンツ
- AWS公式更新しました 3年前
- AWS公式更新しました 1年前