памяти или на диске? Или и там и там? Если в стриме без вотермарка делать .dropDuplicates() можно получить OOM на экзекюторе? Или просто диск забьется?
Какие вообще есть best practice по дедупликации стрима в спарке при условии что дубликат может прийти когда угодно?
можете посмотреть на вопрос пожалуйста? может кто-то сталкивался с подобным?
Обсуждают сегодня