cylondata / twister2

A composable framework for fast and scalable data analytics
https://twister2.org
Apache License 2.0
57 stars 32 forks source link

fixed re-trying connecting and a few other things #891

Closed ahmet-uyar closed 4 years ago

ahmet-uyar commented 4 years ago

When JMWorkerAgent is waiting the connection to be established, it does not try to initiate a new connection. It waits the result of the previous attempt. If that fails, it makes repeated attempts.

Interfaces ChannelHandler and ConnectHandler changed. Problems are transferred to onError method instead of onConnect.

If JMWorkerAgent fails to register the worker because of connection problems, it retries two more times. This was useful when testing with 1024 workers.