Контрольные точки в Spark структурированной потоковой передачи - PullRequest
0 голосов
/ 14 января 2019

Я использовал контрольные точки в потоковой передаче искры, и она создает отдельные папки для каждой контрольной точки, даже если мы указываем один и тот же путь для нескольких потоков. Мы пытаемся использовать потоковое структурирование с использованием технологии spark, и я заметил, что контрольная точка создает только один набор папок (коммиты, смещения, источники), в то время как она использовалась для создания отдельной автоматической папки при потоковой передаче с иском, когда указан один и тот же путь контрольной точки для нескольких потоков.

Я делаю что-то не так или это ожидаемое поведение (один набор папок (коммиты, смещения, источники) для структурированного потока). Нужно ли указывать отдельный путь для каждого потока в случае нескольких потоков?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...