I'm trying to run a topology on a local cluster as a DRPC call on Storm
Since the processing can be quite intensive en heavy, I'd like to increase
the timeout of the RPC call beyond the default of 10 minutes
The code is as follows:
Config conf = new Config();
LocalDRPC drpc = new LocalDRPC();
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("test1", conf, buildTopology(drpc));
However, this still causes the execute to return after 10 minutes after
Nimbus decided to shut itself down.
Does anyone have an idea what is wrong with the above code?
I noticed that LocalCluster's constructor takes a map, so I tried given it
the conf object, but an internal NullPointerException followed upon
construction of LocalCluster.
Which leads me to question number 2: is there any documentation on
LocalCluster and LocalDRPC?
This project seems interesting, but harvesting info on blogs and articles
is tiresome, especially since most of those are about older versions