У меня есть задание потоковой передачи, которое выполняет следующие действия.
- 10 секунд - это время обработки триггера.
- Он выполнит операцию SQL и загрузит данные в ELK.
Итак, работа на спарке занимает больше времени, чем я упомянул (т. Е. 10 секунд при использовании триггера).что произойдет, если работа с искрой займет больше времени .?
- Будет ли работа с искрой потерять пакет данных?Если да, то как этого избежать.ИЛИ
- Is Spark будет автоматически обрабатывать пакеты .?
ПРИМЕЧАНИЕ. Я не должен терять какие-либо данные, если работа занимает больше времени, чем указано.Так что любые предложения .?