Hi all,
Taking Storm distributed processing framework as a reference: Following two problems we are facing. (1) Find the optimal time out of batch processing based on traffic load and provision to set timeout at runtime in storm cluster. (2) Computes the optimal degree of parallelism for each bolt based on execute latency of bolt. (Hint: find the bolt stats through nimbus service and increase the bolt’s executor by firing rebalancing command after fixed interval if load increases) Can any one help us in this? If you have any link on this please share us. regards tarkesh
