обработка пустых партий из входящего потока кинезиса в искровой структурированный поток - PullRequest
0 голосов
/ 27 февраля 2019

мы читаем данные из кинезиса и выводим их в файл, используя поток структуры искры.Реализация kinesis генерирует пустые пакеты, когда в потоке нет данных. Эти пустые пакеты создают пустые файлы в качестве вывода?Любая идея, как мы можем остановить искру, чтобы записать пустые файлы

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