Cluster Runtime Mode

To operate a processing node in cluster mode, the configuration must modified accordingly: (/path/to/spqr/spqr-node/etc/spqr-node.cfg)

(local/standalone)

resourceManager:
  mode: LOCAL

(remote resource manager)

resourceManager:
  mode: REMOTE
  protocol: "http"
  host: "localhost"
  port: 9090    

The log should state somewhere that the processing node was successfully registered at the remote resource manager:

2015-04-16 15:18:03 INFO  SPQRNodeServer:76 - [resource manager [mode=REMOTE, protocol=http, host=localhost, port=9090]
2015-04-16 15:18:04 INFO  SPQRNodeServer:84 - node successfully registered [id=037f38a6-e43b-11e4-9ca3-fc4dd4350f4b, proto=http, host=localhost, servicePort=7070, adminPort=7071]

Start / Stop

Compared to standalone runtime mode the cluster mode requires to start two different node types: the resource manager and the processing node. As the processing nodes register themselves with an already running resource manager it is obviously required to run the latter first.

Start / Stop Resource Manager

To start the resource manager execute the start/stop script located at /path/to/spqr/spqr-resman/bin/spqr-resman.sh

The script requires you to reference a configuration file as well as the execution mode: start or stop.

mnxfst@mnxfst-desktop:/opt/transport/spqr/spqr-resman/bin$ ./spqr-resman.sh 
usage: spqr-resman.sh {start|stop} <configuration file>

Starting the resource manager:

/opt/transport/streaming/spqr/spqr-resman/bin/spqr-resman.sh start /opt/transport/streaming/spqr/spqr-resman/etc/spqr-resman.cfg

Stopping the resource manager:

/opt/transport/streaming/spqr/spqr-resman/bin/spqr-resman.sh stop

Start / Stop Processing Node

To start the processing node execute the start/stop script located at /path/to/spqr/spqr-node/bin/spqr-node.sh

The script requires you to reference a configuration file as well as the execution mode: start or stop.

mnxfst@mnxfst-desktop:/opt/transport/spqr/spqr-node/bin$ ./spqr-node.sh 
usage: spqr-node.sh {start|stop} <configuration file>

Starting the processing node:

/opt/transport/streaming/spqr/spqr-node/bin/spqr-node.sh start /opt/transport/streaming/spqr/spqr-node/etc/spqr-node.cfg

Stopping the processing node:

/opt/transport/streaming/spqr/spqr-node/bin/spqr-node.sh stop