I just want to call Connection.commit() for adding data to DB. Now I call commit in the bolt after some threshold. But when the spout stops emitting for some time, the uncomitted data are not yet added to DB. So if calling a function when a topology is killed isn't possible, is it possible to have a Time out in the bolt, so that I can commit data when no Tuple is received for some time?
On 20 March 2014 16:39, Manthosh Kumar T <[email protected]> wrote: > Hi All, > When running a topology in cluster, is it possible to call a > function when in a bolt when a Topology is killed?. Or will > cluster.shutdown() work in the same way as in local mode when running in > Cluster mode?, if it is so, is it possible to call a function in bolt when > the cluster is shutdown? > > -- > Cheers, > Manthosh Kumar. T > > -- Cheers, Manthosh Kumar. T
