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