Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- bash-3.2$ pig -version
- Warning: $HADOOP_HOME is deprecated.
- Apache Pig version 0.10.0 (r1328203)
- compiled Apr 19 2012, 22:54:12
- bash-3.2$ pig -p docPath=./data/rain.txt -p wcPath=./output/wc -p stopPath=./data/en.stop ./src/scripts/wc.pig
- Warning: $HADOOP_HOME is deprecated.
- 2012-08-28 10:01:47,966 [main] INFO org.apache.pig.Main - Apache Pig version 0.10.0 (r1328203) compiled Apr 19 2012, 22:54:12
- 2012-08-28 10:01:47,967 [main] INFO org.apache.pig.Main - Logging error messages to: /Users/ceteri/src/concur/Impatient/part4/pig_1346173307964.log
- 2012-08-28 10:01:48.060 java[73829:1903] Unable to load realm info from SCDynamicStore
- 2012-08-28 10:01:48,252 [main] INFO org.apache.pig.backend.hadoop.executionengine.HExecutionEngine - Connecting to hadoop file system at: file:///
- 2012-08-28 10:01:48,820 [main] WARN org.apache.pig.PigServer - Encountered Warning USING_OVERLOADED_FUNCTION 1 time(s).
- 2012-08-28 10:01:48,820 [main] WARN org.apache.pig.PigServer - Encountered Warning IMPLICIT_CAST_TO_CHARARRAY 2 time(s).
- 2012-08-28 10:01:48,968 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler - File concatenation threshold: 100 optimistic? false
- 2012-08-28 10:01:48,977 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer - Choosing to move algebraic foreach to combiner
- 2012-08-28 10:01:48,994 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MultiQueryOptimizer - MR plan size before optimization: 2
- 2012-08-28 10:01:48,994 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MultiQueryOptimizer - MR plan size after optimization: 2
- 2012-08-28 10:01:49,030 [main] WARN org.apache.pig.PigServer - Encountered Warning USING_OVERLOADED_FUNCTION 1 time(s).
- 2012-08-28 10:01:49,030 [main] WARN org.apache.pig.PigServer - Encountered Warning IMPLICIT_CAST_TO_CHARARRAY 2 time(s).
- 2012-08-28 10:01:49,032 [main] INFO org.apache.pig.tools.pigstats.ScriptState - Pig features used in the script: HASH_JOIN,GROUP_BY,FILTER
- 2012-08-28 10:01:49,064 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler - File concatenation threshold: 100 optimistic? false
- 2012-08-28 10:01:49,068 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer - Choosing to move algebraic foreach to combiner
- 2012-08-28 10:01:49,070 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MultiQueryOptimizer - MR plan size before optimization: 2
- 2012-08-28 10:01:49,070 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MultiQueryOptimizer - MR plan size after optimization: 2
- 2012-08-28 10:01:49,086 [main] INFO org.apache.pig.tools.pigstats.ScriptState - Pig script settings are added to the job
- 2012-08-28 10:01:49,095 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - mapred.job.reduce.markreset.buffer.percent is not set, set to default 0.3
- 2012-08-28 10:01:49,098 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - creating jar file Job7509048591395546006.jar
- 2012-08-28 10:01:53,505 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - jar file Job7509048591395546006.jar created
- 2012-08-28 10:01:53,516 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - Setting up single store job
- 2012-08-28 10:01:53,524 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - BytesPerReducer=1000000000 maxReducers=999 totalInputFileSize=1054
- 2012-08-28 10:01:53,524 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - Neither PARALLEL nor default parallelism is set for this job. Setting number of reducers to 1
- 2012-08-28 10:01:53,603 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - 1 map-reduce job(s) waiting for submission.
- 2012-08-28 10:01:53,615 [Thread-6] WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
- 2012-08-28 10:01:53,754 [Thread-6] INFO org.apache.hadoop.mapreduce.lib.input.FileInputFormat - Total input paths to process : 1
- 2012-08-28 10:01:53,754 [Thread-6] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths to process : 1
- 2012-08-28 10:01:53,763 [Thread-6] WARN org.apache.hadoop.io.compress.snappy.LoadSnappy - Snappy native library not loaded
- 2012-08-28 10:01:53,766 [Thread-6] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths (combined) to process : 1
- 2012-08-28 10:01:53,775 [Thread-6] INFO org.apache.hadoop.mapreduce.lib.input.FileInputFormat - Total input paths to process : 1
- 2012-08-28 10:01:53,775 [Thread-6] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths to process : 1
- 2012-08-28 10:01:53,776 [Thread-6] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths (combined) to process : 1
- 2012-08-28 10:01:54,021 [Thread-7] INFO org.apache.hadoop.mapred.Task - Using ResourceCalculatorPlugin : null
- 2012-08-28 10:01:54,037 [Thread-7] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader - Current split being processed file:/Users/ceteri/src/concur/Impatient/part4/data/en.stop:0+544
- 2012-08-28 10:01:54,045 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - io.sort.mb = 100
- 2012-08-28 10:01:54,183 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - HadoopJobId: job_local_0001
- 2012-08-28 10:01:54,184 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - data buffer = 79691776/99614720
- 2012-08-28 10:01:54,184 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - 0% complete
- 2012-08-28 10:01:54,185 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - record buffer = 262144/327680
- 2012-08-28 10:01:54,233 [Thread-7] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader - Created input record counter: Input records from _1_en.stop
- 2012-08-28 10:01:54,251 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - Starting flush of map output
- 2012-08-28 10:01:54,262 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - Finished spill 0
- 2012-08-28 10:01:54,265 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
- 2012-08-28 10:01:57,005 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:01:57,005 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task 'attempt_local_0001_m_000000_0' done.
- 2012-08-28 10:01:57,008 [Thread-7] INFO org.apache.hadoop.mapred.Task - Using ResourceCalculatorPlugin : null
- 2012-08-28 10:01:57,012 [Thread-7] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader - Current split being processed file:/Users/ceteri/src/concur/Impatient/part4/data/rain.txt:0+510
- 2012-08-28 10:01:57,013 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - io.sort.mb = 100
- 2012-08-28 10:01:57,073 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - data buffer = 79691776/99614720
- 2012-08-28 10:01:57,073 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - record buffer = 262144/327680
- 2012-08-28 10:01:57,087 [Thread-7] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader - Created input record counter: Input records from _0_rain.txt
- 2012-08-28 10:01:57,096 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - Starting flush of map output
- 2012-08-28 10:01:57,098 [Thread-7] INFO org.apache.hadoop.mapred.MapTask - Finished spill 0
- 2012-08-28 10:01:57,100 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task:attempt_local_0001_m_000001_0 is done. And is in the process of commiting
- 2012-08-28 10:02:00,006 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:00,007 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task 'attempt_local_0001_m_000001_0' done.
- 2012-08-28 10:02:00,018 [Thread-7] INFO org.apache.hadoop.mapred.Task - Using ResourceCalculatorPlugin : null
- 2012-08-28 10:02:00,018 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:00,021 [Thread-7] INFO org.apache.hadoop.mapred.Merger - Merging 2 sorted segments
- 2012-08-28 10:02:00,028 [Thread-7] INFO org.apache.hadoop.mapred.Merger - Down to the last merge-pass, with 2 segments left of total size: 3284 bytes
- 2012-08-28 10:02:00,029 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:00,061 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
- 2012-08-28 10:02:00,062 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:00,062 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task attempt_local_0001_r_000000_0 is allowed to commit now
- 2012-08-28 10:02:00,064 [Thread-7] INFO org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/temp382990916/tmp-2005021410
- 2012-08-28 10:02:03,019 [Thread-7] INFO org.apache.hadoop.mapred.LocalJobRunner - reduce > reduce
- 2012-08-28 10:02:03,020 [Thread-7] INFO org.apache.hadoop.mapred.Task - Task 'attempt_local_0001_r_000000_0' done.
- 2012-08-28 10:02:03,022 [Thread-7] WARN org.apache.hadoop.mapred.FileOutputCommitter - Output path is null in cleanup
- 2012-08-28 10:02:04,203 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - 50% complete
- 2012-08-28 10:02:04,205 [main] WARN org.apache.pig.tools.pigstats.PigStatsUtil - Failed to get RunningJob for job job_local_0001
- 2012-08-28 10:02:04,207 [main] INFO org.apache.pig.tools.pigstats.ScriptState - Pig script settings are added to the job
- 2012-08-28 10:02:04,207 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - mapred.job.reduce.markreset.buffer.percent is not set, set to default 0.3
- 2012-08-28 10:02:04,208 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - creating jar file Job6242959626572154070.jar
- 2012-08-28 10:02:07,871 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - jar file Job6242959626572154070.jar created
- 2012-08-28 10:02:07,875 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - Setting up single store job
- 2012-08-28 10:02:07,879 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - BytesPerReducer=1000000000 maxReducers=999 totalInputFileSize=1037
- 2012-08-28 10:02:07,879 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler - Neither PARALLEL nor default parallelism is set for this job. Setting number of reducers to 1
- 2012-08-28 10:02:07,890 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - 1 map-reduce job(s) waiting for submission.
- 2012-08-28 10:02:07,943 [Thread-11] INFO org.apache.hadoop.mapreduce.lib.input.FileInputFormat - Total input paths to process : 1
- 2012-08-28 10:02:07,943 [Thread-11] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths to process : 1
- 2012-08-28 10:02:07,943 [Thread-11] INFO org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil - Total input paths (combined) to process : 1
- 2012-08-28 10:02:08,008 [Thread-12] INFO org.apache.hadoop.mapred.Task - Using ResourceCalculatorPlugin : null
- 2012-08-28 10:02:08,011 [Thread-12] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader - Current split being processed file:/tmp/temp382990916/tmp-2005021410/part-r-00000:0+1037
- 2012-08-28 10:02:08,012 [Thread-12] INFO org.apache.hadoop.mapred.MapTask - io.sort.mb = 100
- 2012-08-28 10:02:08,023 [Thread-12] INFO org.apache.hadoop.mapred.MapTask - data buffer = 79691776/99614720
- 2012-08-28 10:02:08,023 [Thread-12] INFO org.apache.hadoop.mapred.MapTask - record buffer = 262144/327680
- 2012-08-28 10:02:08,036 [Thread-12] INFO org.apache.hadoop.mapred.MapTask - Starting flush of map output
- 2012-08-28 10:02:08,047 [Thread-12] INFO org.apache.hadoop.mapred.MapTask - Finished spill 0
- 2012-08-28 10:02:08,048 [Thread-12] INFO org.apache.hadoop.mapred.Task - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
- 2012-08-28 10:02:08,391 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - HadoopJobId: job_local_0002
- 2012-08-28 10:02:11,006 [Thread-12] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:11,006 [Thread-12] INFO org.apache.hadoop.mapred.Task - Task 'attempt_local_0002_m_000000_0' done.
- 2012-08-28 10:02:11,013 [Thread-12] INFO org.apache.hadoop.mapred.Task - Using ResourceCalculatorPlugin : null
- 2012-08-28 10:02:11,013 [Thread-12] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:11,014 [Thread-12] INFO org.apache.hadoop.mapred.Merger - Merging 1 sorted segments
- 2012-08-28 10:02:11,015 [Thread-12] INFO org.apache.hadoop.mapred.Merger - Down to the last merge-pass, with 1 segments left of total size: 809 bytes
- 2012-08-28 10:02:11,015 [Thread-12] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:11,028 [Thread-12] INFO org.apache.hadoop.mapred.Task - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
- 2012-08-28 10:02:11,030 [Thread-12] INFO org.apache.hadoop.mapred.LocalJobRunner -
- 2012-08-28 10:02:11,030 [Thread-12] INFO org.apache.hadoop.mapred.Task - Task attempt_local_0002_r_000000_0 is allowed to commit now
- 2012-08-28 10:02:11,032 [Thread-12] INFO org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter - Saved output of task 'attempt_local_0002_r_000000_0' to file:/Users/ceteri/src/concur/Impatient/part4/output/wc
- 2012-08-28 10:02:14,009 [Thread-12] INFO org.apache.hadoop.mapred.LocalJobRunner - reduce > reduce
- 2012-08-28 10:02:14,010 [Thread-12] INFO org.apache.hadoop.mapred.Task - Task 'attempt_local_0002_r_000000_0' done.
- 2012-08-28 10:02:14,011 [Thread-12] WARN org.apache.hadoop.mapred.FileOutputCommitter - Output path is null in cleanup
- 2012-08-28 10:02:18,409 [main] WARN org.apache.pig.tools.pigstats.PigStatsUtil - Failed to get RunningJob for job job_local_0002
- 2012-08-28 10:02:18,411 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - 100% complete
- 2012-08-28 10:02:18,413 [main] INFO org.apache.pig.tools.pigstats.SimplePigStats - Script Statistics:
- HadoopVersion PigVersion UserId StartedAt FinishedAt Features
- 1.0.3 0.10.0 ceteri 2012-08-28 10:01:49 2012-08-28 10:02:18 HASH_JOIN,GROUP_BY,FILTER
- Success!
- Job Stats (time in seconds):
- JobId Maps Reduces MaxMapTime MinMapTIme AvgMapTime MaxReduceTime MinReduceTime AvgReduceTime Alias Feature Outputs
- job_local_0001 1 1 n/a n/a n/a n/a n/a n/a docPipe,stopPipe,tokenPipe HASH_JOIN
- job_local_0002 1 1 n/a n/a n/a n/a n/a n/a tokenGroups,wcPipe GROUP_BY,COMBINER file:///Users/ceteri/src/concur/Impatient/part4/output/wc,
- Input(s):
- Successfully read 0 records from: "file:///Users/ceteri/src/concur/Impatient/part4/data/rain.txt"
- Successfully read 0 records from: "file:///Users/ceteri/src/concur/Impatient/part4/data/en.stop"
- Output(s):
- Successfully stored 0 records in: "file:///Users/ceteri/src/concur/Impatient/part4/output/wc"
- Counters:
- Total records written : 0
- Total bytes written : 0
- Spillable Memory Manager spill count : 0
- Total bags proactively spilled: 0
- Total records proactively spilled: 0
- Job DAG:
- job_local_0001 -> job_local_0002,
- job_local_0002
- 2012-08-28 10:02:18,413 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - Success!
- bash-3.2$ cat output/wc/part-r-00000
- air 1
- dry 3
- dvd 1
- lee 2
- area 4
- land 2
- less 1
- lies 1
- rain 5
- such 1
- cause 1
- death 1
- known 1
- women 1
- broken 1
- effect 1
- ranges 1
- shadow 4
- valley 1
- deserts 1
- leeward 2
- primary 1
- secrets 1
- sinking 1
- downwind 1
- mountain 3
- produces 1
- australia 1
- cloudcover 1
- mountainous 1
- california's 1
- bash-3.2$
Add Comment
Please, Sign In to add comment