*************************Revise****************************
In order to check the Master socket is alive, every action from Slave will launch a temporary socket link beforesending heartbeat periodically.However,Protobuf-socket-rpc consider this probe unsafe, and add WARNING in logs like below.
Dec 9, 2010 10:32:03 AM com.googlecode.protobuf.socketrpc.RpcServer$ConnectionHandler handleError
WARNING: BAD_REQUEST_DATA: Invalid request from client
There is a conflict between a safe check and a warning, So ignoring prior decision is only choice currently.
########RpcServer.java###############
216: if (!builder.isInitialized()) {
217: //sendResponse(handleError("Invalid request from client",
218: // ErrorReason.BAD_REQUEST_DATA, null));
219: return;
Just annotate the 217 and 218 comparing to prior version.
*************************Revise****************************
In order to check the reason why RpcServer stops the server, when the slaveExecutor report an ERROR or WARNING state to Master.Add printing the content of the trace of exception.
########RpcServer.java##############
172: } catch (IOException ex) {
173: stopServer();
174: ex.printStackTrace();
175: } finally {
Just add the 174 comparing to prior version.
./transformerxml/ is directory containning a xml priciples about jobs and tasks.
######################quick start help ####################
1) ant
compiler the project. This requires jdk1.6 or higher,ant-1.8.0 or higher.
2)configure the location of master and slave.
using machine IP address to set master
using machine IP address: port to set slave.
3) bin/start-master.sh;bin/start-slaves.sh;
#######################combined with yarn ###################################
If you meet troubles with our project, please email jiangbinglover@gmail.com
klose/binos-server
Distrubuted realtime computation : flexible programming models, multiple data transfer channel, distributed RPC, and more.
Java