This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* | |
*/ | |
package com.mycompany.context; | |
import org.springframework.beans.BeansException; | |
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.context.ApplicationContext; | |
import org.springframework.context.ApplicationContextAware; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"_shards": { | |
"total": 48, | |
"successful": 48, | |
"failed": 0 | |
}, | |
"indices": { | |
"products_t0_v9": { | |
"shards": { | |
"0": [ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"_shards": { | |
"total": 24, | |
"successful": 24, | |
"failed": 0 | |
}, | |
"indices": { | |
"products_t0_v9": { | |
"shards": { | |
"0": [ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Assumption | |
- You have 2 machines, one for zk and nimbus and another for a supervisor | |
- One Node Zookeeper in the same machine where Nimbus will be | |
- Supervisor machine setup | |
- Workers are created(in supervisor machines) when you deploy the topology in nimbus machine | |
and thats not covered here | |
- You can also put the below param every machine in storm cluster where storm will create some data | |
for itself in storm.yaml where you have all the permissions for it to write the data to. | |
storm.local.dir: "/a/b/storm" |