Class org.springframework.data.hadoop.batch.ReadWriteHdfsTest

2

tests

0

failures

46.811s

duration

100%

successful

Tests

Test Duration Result
testWorkflow 25.341s passed
testWorkflowNS 21.470s passed

Standard output

23:40:47,715  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/batch/in-do-out.xml]
23:40:47,845  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/batch-common.xml]
23:40:47,875  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/hadoop-ctx.xml]
23:40:47,944  INFO Test worker support.DefaultListableBeanFactory - Overriding bean definition for bean 'mainJob': replacing [Generic bean: class [org.springframework.batch.core.configuration.xml.SimpleFlowFactoryBean]; scope=; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null] with [Generic bean: class [org.springframework.batch.core.configuration.xml.JobParserJobFactoryBean]; scope=; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null]
23:40:47,946  INFO Test worker support.GenericXmlApplicationContext - Refreshing org.springframework.context.support.GenericXmlApplicationContext@230ef582: startup date [Wed Sep 25 23:40:47 EDT 2013]; root of context hierarchy
23:40:47,961  INFO Test worker config.PropertyPlaceholderConfigurer - Loading properties file from class path resource [test.properties]
23:40:47,997  INFO Test worker support.DefaultListableBeanFactory - Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@285a7e4b: defining beans [jobRepository,transactionManager,jobLauncher,taskExecutor,ppc,hadoopFs,hadoopResourceLoader,hadoopConfiguration,cfg-init,fs-init,rl-init,org.springframework.data.hadoop.scripting.HdfsScriptRunner#0,org.springframework.batch.core.scope.internalStepScope,org.springframework.beans.factory.config.CustomEditorConfigurer,org.springframework.batch.core.configuration.xml.CoreNamespacePostProcessor,import,do,mainJob,file-reader,hadoop-tasklet,mr-job,org.springframework.data.hadoop.scripting.HdfsScriptRunner#1,script-tasklet]; root of factory hierarchy
23:40:48,026  WARN Test worker conf.Configuration - fs.default.name is deprecated. Instead, use fs.defaultFS
23:40:48,101  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
23:40:48,118  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
FS is org.apache.hadoop.hdfs.DistributedFileSystem
23:40:48,158  INFO Test worker support.SimpleJobLauncher - Job: [FlowJob: [name=mainJob]] launched with the following parameters: [{}]
23:40:48,172  INFO Test worker job.SimpleStepHandler - Executing step: [import]
23:40:48,329  INFO Test worker job.SimpleStepHandler - Executing step: [do]
23:40:48,350  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:40:48,352  INFO Test worker mapreduce.JobTasklet - Starting job [mr-job]
23:40:48,369  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:40:48,430  INFO Test worker input.FileInputFormat - Total input paths to process : 1
23:40:48,471  INFO Test worker mapreduce.JobSubmitter - number of splits:1
23:40:48,480  WARN Test worker conf.Configuration - fs.default.name is deprecated. Instead, use fs.defaultFS
23:40:48,625  INFO Test worker mapreduce.JobSubmitter - Submitting tokens for job: job_1380140057116_0026
23:40:48,651  INFO Test worker impl.YarnClientImpl - Submitted application application_1380140057116_0026 to ResourceManager at sandbox/172.16.87.151:8050
23:40:48,659  INFO Test worker mapreduce.Job - The url to track the job: http://sandbox.hortonworks.com:8088/proxy/application_1380140057116_0026/
23:40:48,659  INFO Test worker mapreduce.Job - Running job: job_1380140057116_0026
23:40:59,448  INFO Test worker mapreduce.Job - Job job_1380140057116_0026 running in uber mode : false
23:40:59,448  INFO Test worker mapreduce.Job -  map 0% reduce 0%
23:41:06,364  INFO Test worker mapreduce.Job -  map 100% reduce 0%
23:41:12,556  INFO Test worker mapreduce.Job -  map 100% reduce 100%
23:41:12,563  INFO Test worker mapreduce.Job - Job job_1380140057116_0026 completed successfully
23:41:12,598  INFO Test worker mapreduce.Job - Counters: 43
	File System Counters
		FILE: Number of bytes read=64
		FILE: Number of bytes written=165761
		FILE: Number of read operations=0
		FILE: Number of large read operations=0
		FILE: Number of write operations=0
		HDFS: Number of bytes read=142
		HDFS: Number of bytes written=38
		HDFS: Number of read operations=6
		HDFS: Number of large read operations=0
		HDFS: Number of write operations=2
	Job Counters 
		Launched map tasks=1
		Launched reduce tasks=1
		Data-local map tasks=1
		Total time spent by all maps in occupied slots (ms)=5130
		Total time spent by all reduces in occupied slots (ms)=3740
	Map-Reduce Framework
		Map input records=3
		Map output records=5
		Map output bytes=48
		Map output materialized bytes=64
		Input split bytes=114
		Combine input records=0
		Combine output records=0
		Reduce input groups=5
		Reduce shuffle bytes=64
		Reduce input records=5
		Reduce output records=5
		Spilled Records=10
		Shuffled Maps =1
		Failed Shuffles=0
		Merged Map outputs=1
		GC time elapsed (ms)=36
		CPU time spent (ms)=1700
		Physical memory (bytes) snapshot=393744384
		Virtual memory (bytes) snapshot=2428526592
		Total committed heap usage (bytes)=288686080
	Shuffle Errors
		BAD_ID=0
		CONNECTION=0
		IO_ERROR=0
		WRONG_LENGTH=0
		WRONG_MAP=0
		WRONG_REDUCE=0
	File Input Format Counters 
		Bytes Read=28
	File Output Format Counters 
		Bytes Written=38
23:41:12,607  INFO Test worker mapreduce.JobTasklet - Completed job [mr-job]
23:41:12,647  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:41:12,800  INFO Test worker support.SimpleJobLauncher - Job: [FlowJob: [name=mainJob]] completed with the following parameters: [{}] and the following status: [COMPLETED]
FS is org.apache.hadoop.hdfs.DistributedFileSystem
23:41:12,808  INFO Test worker support.GenericXmlApplicationContext - Closing org.springframework.context.support.GenericXmlApplicationContext@230ef582: startup date [Wed Sep 25 23:40:47 EDT 2013]; root of context hierarchy
23:41:12,809  INFO Test worker support.DefaultListableBeanFactory - Destroying singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@285a7e4b: defining beans [jobRepository,transactionManager,jobLauncher,taskExecutor,ppc,hadoopFs,hadoopResourceLoader,hadoopConfiguration,cfg-init,fs-init,rl-init,org.springframework.data.hadoop.scripting.HdfsScriptRunner#0,org.springframework.batch.core.scope.internalStepScope,org.springframework.beans.factory.config.CustomEditorConfigurer,org.springframework.batch.core.configuration.xml.CoreNamespacePostProcessor,import,do,mainJob,file-reader,hadoop-tasklet,mr-job,org.springframework.data.hadoop.scripting.HdfsScriptRunner#1,script-tasklet]; root of factory hierarchy
23:41:12,884  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:41:13,044  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/batch/in-do-out-ns.xml]
23:41:13,168  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/batch-common.xml]
23:41:13,183  INFO Test worker xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource [org/springframework/data/hadoop/hadoop-ctx.xml]
23:41:13,217  INFO Test worker support.DefaultListableBeanFactory - Overriding bean definition for bean 'mainJob': replacing [Generic bean: class [org.springframework.batch.core.configuration.xml.SimpleFlowFactoryBean]; scope=; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null] with [Generic bean: class [org.springframework.batch.core.configuration.xml.JobParserJobFactoryBean]; scope=; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null]
23:41:13,218  INFO Test worker support.GenericXmlApplicationContext - Refreshing org.springframework.context.support.GenericXmlApplicationContext@36a20763: startup date [Wed Sep 25 23:41:13 EDT 2013]; root of context hierarchy
23:41:13,296  INFO Test worker config.PropertyPlaceholderConfigurer - Loading properties file from class path resource [test.properties]
23:41:13,303  INFO Test worker support.DefaultListableBeanFactory - Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@45c01e6: defining beans [jobRepository,transactionManager,jobLauncher,taskExecutor,ppc,hadoopFs,hadoopResourceLoader,hadoopConfiguration,cfg-init,fs-init,rl-init,org.springframework.data.hadoop.scripting.HdfsScriptRunner#0,org.springframework.batch.core.scope.internalStepScope,org.springframework.beans.factory.config.CustomEditorConfigurer,org.springframework.batch.core.configuration.xml.CoreNamespacePostProcessor,import,do,mainJob,file-reader,hadoop-tasklet,mr-job,org.springframework.data.hadoop.scripting.HdfsScriptRunner#1,script-tasklet]; root of factory hierarchy
23:41:13,329  WARN Test worker conf.Configuration - fs.default.name is deprecated. Instead, use fs.defaultFS
23:41:13,364  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
23:41:13,379  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
23:41:13,399  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
23:41:13,427  INFO Test worker support.SimpleJobLauncher - Job: [FlowJob: [name=mainJob]] launched with the following parameters: [{}]
23:41:13,435  INFO Test worker job.SimpleStepHandler - Executing step: [import]
23:41:13,451  INFO Test worker fs.TrashPolicyDefault - Namenode trash configuration: Deletion interval = 0 minutes, Emptier interval = 0 minutes.
23:41:13,525  INFO Test worker job.SimpleStepHandler - Executing step: [do]
23:41:13,548  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:41:13,550  INFO Test worker mapreduce.JobTasklet - Starting job [mr-job]
23:41:13,570  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:41:13,640  INFO Test worker input.FileInputFormat - Total input paths to process : 1
23:41:13,682  INFO Test worker mapreduce.JobSubmitter - number of splits:1
23:41:13,690  WARN Test worker conf.Configuration - fs.default.name is deprecated. Instead, use fs.defaultFS
23:41:13,723  INFO Test worker mapreduce.JobSubmitter - Submitting tokens for job: job_1380140057116_0027
23:41:13,746  INFO Test worker impl.YarnClientImpl - Submitted application application_1380140057116_0027 to ResourceManager at sandbox/172.16.87.151:8050
23:41:13,750  INFO Test worker mapreduce.Job - The url to track the job: http://sandbox.hortonworks.com:8088/proxy/application_1380140057116_0027/
23:41:13,750  INFO Test worker mapreduce.Job - Running job: job_1380140057116_0027
23:41:23,031  INFO Test worker mapreduce.Job - Job job_1380140057116_0027 running in uber mode : false
23:41:23,031  INFO Test worker mapreduce.Job -  map 0% reduce 0%
23:41:29,184  INFO Test worker mapreduce.Job -  map 100% reduce 0%
23:41:34,323  INFO Test worker mapreduce.Job -  map 100% reduce 100%
23:41:34,326  INFO Test worker mapreduce.Job - Job job_1380140057116_0027 completed successfully
23:41:34,361  INFO Test worker mapreduce.Job - Counters: 43
	File System Counters
		FILE: Number of bytes read=64
		FILE: Number of bytes written=165761
		FILE: Number of read operations=0
		FILE: Number of large read operations=0
		FILE: Number of write operations=0
		HDFS: Number of bytes read=142
		HDFS: Number of bytes written=38
		HDFS: Number of read operations=6
		HDFS: Number of large read operations=0
		HDFS: Number of write operations=2
	Job Counters 
		Launched map tasks=1
		Launched reduce tasks=1
		Data-local map tasks=1
		Total time spent by all maps in occupied slots (ms)=3735
		Total time spent by all reduces in occupied slots (ms)=3597
	Map-Reduce Framework
		Map input records=3
		Map output records=5
		Map output bytes=48
		Map output materialized bytes=64
		Input split bytes=114
		Combine input records=0
		Combine output records=0
		Reduce input groups=5
		Reduce shuffle bytes=64
		Reduce input records=5
		Reduce output records=5
		Spilled Records=10
		Shuffled Maps =1
		Failed Shuffles=0
		Merged Map outputs=1
		GC time elapsed (ms)=57
		CPU time spent (ms)=1290
		Physical memory (bytes) snapshot=382369792
		Virtual memory (bytes) snapshot=2434494464
		Total committed heap usage (bytes)=288686080
	Shuffle Errors
		BAD_ID=0
		CONNECTION=0
		IO_ERROR=0
		WRONG_LENGTH=0
		WRONG_MAP=0
		WRONG_REDUCE=0
	File Input Format Counters 
		Bytes Read=28
	File Output Format Counters 
		Bytes Written=38
23:41:34,370  INFO Test worker mapreduce.JobTasklet - Completed job [mr-job]
23:41:34,393  INFO Test worker client.RMProxy - Connecting to ResourceManager at sandbox/172.16.87.151:8050
23:41:34,512  INFO Test worker support.SimpleJobLauncher - Job: [FlowJob: [name=mainJob]] completed with the following parameters: [{}] and the following status: [COMPLETED]
23:41:34,512  INFO Test worker support.GenericXmlApplicationContext - Closing org.springframework.context.support.GenericXmlApplicationContext@36a20763: startup date [Wed Sep 25 23:41:13 EDT 2013]; root of context hierarchy
23:41:34,513  INFO Test worker support.DefaultListableBeanFactory - Destroying singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@45c01e6: defining beans [jobRepository,transactionManager,jobLauncher,taskExecutor,ppc,hadoopFs,hadoopResourceLoader,hadoopConfiguration,cfg-init,fs-init,rl-init,org.springframework.data.hadoop.scripting.HdfsScriptRunner#0,org.springframework.batch.core.scope.internalStepScope,org.springframework.beans.factory.config.CustomEditorConfigurer,org.springframework.batch.core.configuration.xml.CoreNamespacePostProcessor,import,do,mainJob,file-reader,hadoop-tasklet,mr-job,org.springframework.data.hadoop.scripting.HdfsScriptRunner#1,script-tasklet]; root of factory hierarchy