Я использую GenerateTableFetch с файлами входящего потока, содержащими table_name, для импорта данных. И я поставил Additional WHERE clause для обработки инкрементных обновлений, используя updated_at столбец таблицы вручную.
Проблема в том, что когда для созданного запроса нет данных для импорта, он просто удаляет потоковый файл. У него должны быть отдельные отношения, отличные от успеха и неудачи для этого случая, чтобы я мог справиться самостоятельно, если что-то нужно сделать для таких случаев.
В настоящее время, в начале рабочего процесса, я использую Wait для количества таблиц, которые я ввел в поток, и отслеживаю, когда они готовы, чтобы увеличить счетчик выполненных операций с помощью Notify. Но для таблиц, которые были отброшены в GenerateTableFetch, он просто продолжает ждать.
Как с этим справиться?
