Apache Flink выполняет последовательную запись в несколько приемников один за другим

Question

У меня есть CsvTableSource для чтения CSV-файлов и записи данных в S3, и после этого я хочу загрузить файл из S3 в приемник JDBC.Как я могу заставить приемник JDBC выполняться только после того, как приемник S3 успешно завершен.Причина в том, что S3 будет использоваться для некоторой другой обработки, и данные не могут быть непосредственно перемещены в JDBC без перехода S3

Answer 1

Похоже, у вас может быть одно задание, которое читает файлы CSV и записывает в S3, и второе задание, которое использует S3 в качестве источника и записывает в JDBC.