[REEF-1421] Transport Client inner thread is not canceled when object is disposed

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.16
• Component/s: REEF.NET, Wake.NET
• Labels: FT
• Assignee: Julia Wang
• Reporter: Julia Wang
• Created: 04/Jun/16 19:23
• Updated: 09/Jun/16 04:42
• Resolved: 06/Jun/16 16:42

Description

Currently, StreamingTransportClient starts a new task ResponseLoop, which reads a message with ReadAsync and sends it to the observer in a while loop with a cancellation token.

When StreamingTransportClient object is disposed, this task should be canceled with the cancellation token. Otherwise, the ResponseLoop will keep running and never end. However, we don't cancel it. After the task is completed, what we see in the logs are endless exception messages thrown from this loop as group communication has been ended.

The same bug is in TransportClient.

Issue Links

• blocks: REEF-1223 IMRU Fault Tolerance - restart failed evaluators