|
@@ -96,36 +96,25 @@ class TestHookBeforeStart(RMFTestCase):
|
|
|
content = Template('health_check.j2'),
|
|
|
owner = 'hdfs',
|
|
|
)
|
|
|
- self.assertResourceCalled('PropertiesFile',
|
|
|
+ rca_properties = format('''
|
|
|
+
|
|
|
+log4j.appender.JHA=org.apache.ambari.log4j.hadoop.mapreduce.jobhistory.JobHistoryAppender
|
|
|
+log4j.appender.JHA.database=jdbc:postgresql://c6401.ambari.apache.org/ambarirca
|
|
|
+log4j.appender.JHA.driver=org.postgresql.Driver
|
|
|
+log4j.appender.JHA.user=mapred
|
|
|
+log4j.appender.JHA.password=mapred
|
|
|
+
|
|
|
+log4j.logger.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=DEBUG,JHA
|
|
|
+log4j.additivity.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=true
|
|
|
+
|
|
|
+''')
|
|
|
+ self.maxDiff = None
|
|
|
+ self.assertResourceCalled('File',
|
|
|
'/etc/hadoop/conf/log4j.properties',
|
|
|
- properties={'property1': 'value1'},
|
|
|
- mode=0664,
|
|
|
+ mode=0644,
|
|
|
+ group='hadoop',
|
|
|
owner='hdfs',
|
|
|
- group='hadoop'
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.driver=.*~ambari.jobhistory.driver=org.postgresql.Driver~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA=.*~log4j.appender.JHA=org.apache.ambari.log4j.hadoop.mapreduce.jobhistory.JobHistoryAppender~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.driver=.*~log4j.appender.JHA.driver=${ambari.jobhistory.driver}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.database=.*~log4j.appender.JHA.database=${ambari.jobhistory.database}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.logger=.*~ambari.jobhistory.logger=DEBUG,JHA~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.password=.*~log4j.appender.JHA.password=${ambari.jobhistory.password}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.database=.*~ambari.jobhistory.database=jdbc:postgresql://c6401.ambari.apache.org/ambarirca~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.additivity.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=.*~log4j.additivity.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=true~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.logger.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=.*~log4j.logger.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=${ambari.jobhistory.logger}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.user=.*~log4j.appender.JHA.user=${ambari.jobhistory.user}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.user=.*~ambari.jobhistory.user=mapred~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.password=.*~ambari.jobhistory.password=mapred~' /etc/hadoop/conf/log4j.properties",
|
|
|
+ content='log4jproperties\nline2log4jproperties\nline2'+rca_properties
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/etc/hadoop/conf/hadoop-metrics2.properties',
|
|
|
content = Template('hadoop-metrics2.properties.j2'),
|
|
@@ -267,35 +256,11 @@ class TestHookBeforeStart(RMFTestCase):
|
|
|
content = Template('health_check.j2'),
|
|
|
owner = 'root',
|
|
|
)
|
|
|
- self.assertResourceCalled('PropertiesFile', '/etc/hadoop/conf/log4j.properties',
|
|
|
+ self.assertResourceCalled('File', '/etc/hadoop/conf/log4j.properties',
|
|
|
owner = 'hdfs',
|
|
|
group = 'hadoop',
|
|
|
- mode = 0664,
|
|
|
- properties = self.getConfig()['configurations']['hdfs-log4j'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.driver=.*~ambari.jobhistory.driver=org.postgresql.Driver~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA=.*~log4j.appender.JHA=org.apache.ambari.log4j.hadoop.mapreduce.jobhistory.JobHistoryAppender~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.driver=.*~log4j.appender.JHA.driver=${ambari.jobhistory.driver}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.database=.*~log4j.appender.JHA.database=${ambari.jobhistory.database}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.logger=.*~ambari.jobhistory.logger=DEBUG,JHA~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.password=.*~log4j.appender.JHA.password=${ambari.jobhistory.password}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.database=.*~ambari.jobhistory.database=jdbc:postgresql://c6401.ambari.apache.org/ambarirca~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.additivity.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=.*~log4j.additivity.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=true~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.logger.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=.*~log4j.logger.org.apache.hadoop.mapred.JobHistory$JobHistoryLogger=${ambari.jobhistory.logger}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?log4j.appender.JHA.user=.*~log4j.appender.JHA.user=${ambari.jobhistory.user}~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.user=.*~ambari.jobhistory.user=mapred~' /etc/hadoop/conf/log4j.properties",
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "sed -i 's~\\(###\\)\\?ambari.jobhistory.password=.*~ambari.jobhistory.password=mapred~' /etc/hadoop/conf/log4j.properties",
|
|
|
+ mode = 0644,
|
|
|
+ content = 'log4jproperties\nline2'
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/etc/hadoop/conf/hadoop-metrics2.properties',
|
|
|
content = Template('hadoop-metrics2.properties.j2'),
|