2 issues we are seeing on 1.5.1 on a streaming pipe line

org.apache.flink.util.FlinkException: The assigned slot
208af709ef7be2d2dfc028ba3bbf4600_10 was removed.


and

java.util.concurrent.TimeoutException: Heartbeat of TaskManager with
id 208af709ef7be2d2dfc028ba3bbf4600 timed out.


Not sure about the first but how do we increase the heartbeat interval of a
TM

Thanks much

Vishal

Reply via email to