Flink TaskManager не работает с OOM - PullRequest
Новая
       6

Flink TaskManager не работает с OOM

0 голосов
/ 10 марта 2020

мгновенно прослушивает kafka topi c, все, что нужно сделать, это прослушать kafka и вставить сообщение в поиск elasti c. Работа продолжает сбой с одним из диспетчеров задач OOM.

Я использую flink docker в kubernetes с 3 ГБ памяти. Но я вижу сбои в логах TaskManager. Я не использую никаких специальных функций, просто слушайте и пишите в elasti c. 

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "I/O dispatcher 2945"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "pool-1170-thread-1"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "I/O dispatcher 5441"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "I/O dispatcher 2467"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "pool-3944-thread-1"

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "pool-2651-thread-1"
...