У меня есть приложение flink с источниками kafka, которое вычисляет некоторые характеристики на основе этого и отправляет его в JDB C. Теперь я хочу знать, до какой отметки времени данные полностью помещаются в JDB C (т. Е. Больше данных не будет помещаться в отметку времени, меньшую или равную этой). Кажется, не существует прямого способа программирования c.
Я наткнулся на следующую тему, которая показалась мне наиболее актуальной: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/End-of-Window-Marker-td29345.html#a29461
Тем не менее, я не могу понять, как связать функцию процесса перед задачей стока, чтобы поставить водяные знаки на боковой вывод. (Я подозреваю, что это может иметь какое-то отношение к datastream.addSink в обычных приемниках потока данных по сравнению с sink.consumeDataStream (stream) в JDBCAppendTableSink).
Далее, что происходит, если нет windows, как решить проблему тогда?
Пожалуйста, поделитесь указателями или соответствующими решениями для решения этой проблемы.