in src/main/java/com/netflix/bdp/s3mper/alert/impl/CloudWatchAlertDispatcher.java [88:106]
private void lazyInit() {
String keyId = conf.get("fs."+uri.getScheme()+".awsAccessKeyId");
String keySecret = conf.get("fs."+uri.getScheme()+".awsSecretAccessKey");
//An override option for accessing across accounts
keyId = conf.get("fs."+uri.getScheme()+".override.awsAccessKeyId", keyId);
keySecret = conf.get("fs."+uri.getScheme()+".override.awsSecretAccessKey", keySecret);
synchronized(this) {
if(cloudWatch == null) {
initCloudWatch(keyId, keySecret);
}
if(sqs == null) {
initSqs(keyId, keySecret);
}
}
}