используется для определения разделов задач фреймворка. обычно применяется для операций RDD.

разница междуspark.sql.shuffle.partitions а такжеspark.default.parallelism?

Я пытался установить их обоих вSparkSQL, но номер задачи второго этапа всегда 200.

Ответы на вопрос(0)

Ваш ответ на вопрос