Существуют ли реальные глобальные параметры, которые могут записывать и читать все параллельные задачи (независимо от того, на какой TM они работают)? Я тестировал класс GlobalJobParameter, но кажется, что каждый поток поддерживает свой собственный экземпляр. Я ищу место, где могут делиться все UDF. Кто-нибудь знает? Большое спасибо!
Существуют ли реальные глобальные параметры в потоковой передаче Flink?
Ответы (1)
GlobalJobParameter - это дистрибутив только для чтения, предназначенный для настройки задания. Как вы упомянули «напишите и прочтите», я предполагаю, что вы ищете глобальное общее состояние. Flink не поддерживает нечто подобное, потому что глобальное разделяемое состояние не масштабируется и противоречит идее параллелизма данных.
person
Matthias J. Sax
schedule
23.08.2015
Спасибо за Ваш ответ!
- person zhangshengxiong; 24.08.2015
