Do you have the JobManager and TaskManager logs of the corresponding TM, by
any chance?
On Mon, Jun 29, 2015 at 8:12 PM, Andra Lungu lungu.an...@gmail.com wrote:
Something similar in flink-0.10-SNAPSHOT:
06/29/2015 10:33:46 CHAIN Join(Join at main(TriangleCount.java:79)) -
Combine
Something similar in flink-0.10-SNAPSHOT:
06/29/2015 10:33:46 CHAIN Join(Join at main(TriangleCount.java:79)) -
Combine (Reduce at main(TriangleCount.java:79))(222/224) switched to FAILED
java.lang.Exception: The slot in which the task was executed has been
released. Probably loss of
Hi to all,
I have this strange error in my job and I don't know what's going on.
What can I do?
The full exception is:
The slot in which the task was scheduled has been killed (probably loss of
TaskManager).
at org.apache.flink.runtime.instance.SimpleSlot.cancel(SimpleSlot.java:98)
at
