title: Flink: Cluster Execution error of loss of Taskmanager
body: <p>I am running the real time streaming program on the Flink with 1 master and 2 workers. One worker is running on the separate machine while another one is running on the master machine itself. I am using the JAR of my program in which the <code>Parallelism</code> is set to 2. Also I am read the data from Kafka with 2 brokers and 2 partitions.</p>
  
  <p>With this scenario when I submit the job to the Flink cluster, it will run for a while and get failed with error <code>java.lang.Exception: The slot in which the task was executed has been released. Probably loss of TaskManager 82f8941ff339603995e37c453f8ff401</code>. What is the probable reason of the loss of taskmanager? (Only one Task-manager which is on the master machine is lost, another one is still there and being shown at Flink Web Interface.)</p>