2015-02-10 17:14:32,777 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 17:14:32,827 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 17:14:32,828 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.operation.assertion.AppliedAssertionsPlatformTest
2015-02-10 17:14:32,867 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 17:14:33,296 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:33,298 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:33,311 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 18B8A33488184651868A976A1B7C7578
2015-02-10 17:14:33,563 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 17:14:33,566 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:33,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:33,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT"]
2015-02-10 17:14:33,568 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:33,568 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:33,568 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:33,570 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...latform/value/NONE/STRICT
2015-02-10 17:14:33,620 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 17:14:33,693 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 17:14:33,697 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:33,933 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1514956426_0001
2015-02-10 17:14:33,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:33,967 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:33,970 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1514956426_0001_m_000000_0
2015-02-10 17:14:34,041 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 17:14:34,050 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2cf5d030
2015-02-10 17:14:34,059 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:34,059 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@44f0853
2015-02-10 17:14:34,067 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:34,076 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:34,230 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:34,230 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:34,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:34,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:34,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:34,328 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:34,346 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:34,359 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:34,362 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1514956426_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:34,368 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:34,368 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1514956426_0001_m_000000_0' done.
2015-02-10 17:14:34,369 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1514956426_0001_m_000000_0
2015-02-10 17:14:34,369 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:34,380 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@212cb585
2015-02-10 17:14:34,381 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,387 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:34,393 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:34,394 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,395 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:34,396 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:34,417 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:34,418 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT"]
2015-02-10 17:14:34,442 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1514956426_0001_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:34,444 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,444 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1514956426_0001_r_000000_0 is allowed to commit now
2015-02-10 17:14:34,449 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1514956426_0001_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT
2015-02-10 17:14:34,451 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:34,452 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1514956426_0001_r_000000_0' done.
2015-02-10 17:14:34,471 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT/_temporary
2015-02-10 17:14:34,496 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:34,526 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:34,527 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:34,566 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:34,566 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:34,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT"]
2015-02-10 17:14:34,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:34,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:34,567 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:34,568 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...atform/value/VALID/STRICT
2015-02-10 17:14:34,585 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:34,694 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local190729125_0002
2015-02-10 17:14:34,694 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:34,699 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:34,699 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local190729125_0002_m_000000_0
2015-02-10 17:14:34,702 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4adf9095
2015-02-10 17:14:34,703 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:34,704 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1faac07d
2015-02-10 17:14:34,706 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:34,706 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:34,847 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:34,847 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:34,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:34,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:34,865 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:34,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:34,872 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:34,876 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:34,879 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local190729125_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:34,882 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:34,882 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local190729125_0002_m_000000_0' done.
2015-02-10 17:14:34,882 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local190729125_0002_m_000000_0
2015-02-10 17:14:34,882 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:34,888 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@26796e1c
2015-02-10 17:14:34,888 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,889 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:34,890 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:34,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:34,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:34,904 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:34,905 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT"]
2015-02-10 17:14:34,914 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local190729125_0002_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:34,916 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:34,916 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local190729125_0002_r_000000_0 is allowed to commit now
2015-02-10 17:14:34,921 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local190729125_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT
2015-02-10 17:14:34,922 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:34,922 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local190729125_0002_r_000000_0' done.
2015-02-10 17:14:34,929 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT/_temporary
2015-02-10 17:14:34,951 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:34,979 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:34,980 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:35,018 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:35,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT"]
2015-02-10 17:14:35,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:35,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:35,020 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:35,020 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...tform/value/STRICT/STRICT
2015-02-10 17:14:35,037 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:35,095 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1284960932_0003
2015-02-10 17:14:35,096 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:35,098 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:35,099 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1284960932_0003_m_000000_0
2015-02-10 17:14:35,101 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2a6c9ec6
2015-02-10 17:14:35,104 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:35,104 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@114562c5
2015-02-10 17:14:35,106 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:35,107 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:35,244 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:35,245 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:35,247 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:35,247 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:35,263 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,263 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:35,270 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:35,273 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:35,275 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1284960932_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:35,278 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:35,279 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1284960932_0003_m_000000_0' done.
2015-02-10 17:14:35,279 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1284960932_0003_m_000000_0
2015-02-10 17:14:35,279 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:35,284 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6af2f0d0
2015-02-10 17:14:35,285 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,286 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:35,286 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:35,287 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:35,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:35,301 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:35,301 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT"]
2015-02-10 17:14:35,310 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:35,313 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:35,316 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1284960932_0003
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:35,318 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local1284960932_0003 state at FAILED
2015-02-10 17:14:35,319 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:35,320 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:35,320 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:35,322 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:35,322 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...tform/value/STRICT/STRICT
2015-02-10 17:14:35,322 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:35,322 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] shutting down job executor
2015-02-10 17:14:35,323 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] shutdown complete
2015-02-10 17:14:35,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT/_temporary
2015-02-10 17:14:35,342 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:35,342 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:35,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:35,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID"]
2015-02-10 17:14:35,375 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:35,375 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:35,375 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:35,376 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...platform/value/NONE/VALID
2015-02-10 17:14:35,393 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:35,446 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local402315887_0004
2015-02-10 17:14:35,447 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:35,449 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:35,450 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local402315887_0004_m_000000_0
2015-02-10 17:14:35,451 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@40b890dc
2015-02-10 17:14:35,454 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:35,454 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2b52b6f5
2015-02-10 17:14:35,456 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:35,457 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:35,595 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:35,595 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:35,597 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:35,597 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:35,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:35,616 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:35,620 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:35,622 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local402315887_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:35,625 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:35,625 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local402315887_0004_m_000000_0' done.
2015-02-10 17:14:35,625 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local402315887_0004_m_000000_0
2015-02-10 17:14:35,626 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:35,630 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@505fa26
2015-02-10 17:14:35,631 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,632 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:35,633 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:35,633 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,634 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:35,634 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:35,645 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:35,645 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID"]
2015-02-10 17:14:35,654 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local402315887_0004_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:35,656 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,656 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local402315887_0004_r_000000_0 is allowed to commit now
2015-02-10 17:14:35,660 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local402315887_0004_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID
2015-02-10 17:14:35,662 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:35,662 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local402315887_0004_r_000000_0' done.
2015-02-10 17:14:35,672 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID/_temporary
2015-02-10 17:14:35,686 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:35,704 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:35,704 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:35,735 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:35,735 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,736 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID"]
2015-02-10 17:14:35,736 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:35,737 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:35,737 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:35,738 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...latform/value/VALID/VALID
2015-02-10 17:14:35,753 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:35,793 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local443785145_0005
2015-02-10 17:14:35,793 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:35,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:35,797 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local443785145_0005_m_000000_0
2015-02-10 17:14:35,799 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6e9b86ea
2015-02-10 17:14:35,802 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:35,803 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@77b9e7fc
2015-02-10 17:14:35,805 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:35,806 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:35,957 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:35,958 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:35,960 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:35,960 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:35,974 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:35,974 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:35,981 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:35,984 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:35,987 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local443785145_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:35,990 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:35,991 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local443785145_0005_m_000000_0' done.
2015-02-10 17:14:35,991 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local443785145_0005_m_000000_0
2015-02-10 17:14:35,992 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:35,997 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7897aaa6
2015-02-10 17:14:35,998 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:35,999 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:35,999 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:36,000 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,000 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:36,000 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:36,012 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:36,012 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID"]
2015-02-10 17:14:36,019 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:36,020 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:36,022 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local443785145_0005
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:36,026 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local443785145_0005 state at FAILED
2015-02-10 17:14:36,026 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:36,026 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:36,026 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:36,033 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:36,033 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...latform/value/VALID/VALID
2015-02-10 17:14:36,033 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:36,034 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID/_temporary
2015-02-10 17:14:36,034 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/NONE/STRICT
2015-02-10 17:14:36,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/VALID/STRICT
2015-02-10 17:14:36,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/VALID/VALID
2015-02-10 17:14:36,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/NONE/VALID
2015-02-10 17:14:36,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/STRICT/STRICT
2015-02-10 17:14:36,078 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:36,079 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:36,106 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:36,107 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:36,108 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT"]
2015-02-10 17:14:36,108 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:36,109 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:36,109 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:36,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...latform/group/NONE/STRICT
2015-02-10 17:14:36,126 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:36,163 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local261885390_0006
2015-02-10 17:14:36,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:36,168 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:36,168 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local261885390_0006_m_000000_0
2015-02-10 17:14:36,170 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@54d1f0ad
2015-02-10 17:14:36,172 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:36,172 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2d97d09f
2015-02-10 17:14:36,174 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:36,174 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:36,521 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:36,522 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:36,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:36,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:36,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:36,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:36,542 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:36,545 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:36,547 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local261885390_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:36,550 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:36,550 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local261885390_0006_m_000000_0' done.
2015-02-10 17:14:36,550 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local261885390_0006_m_000000_0
2015-02-10 17:14:36,550 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:36,555 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@25927275
2015-02-10 17:14:36,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,556 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:36,557 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:36,558 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:36,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:36,569 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:36,569 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT"]
2015-02-10 17:14:36,576 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local261885390_0006_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:36,578 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,578 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local261885390_0006_r_000000_0 is allowed to commit now
2015-02-10 17:14:36,582 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local261885390_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT
2015-02-10 17:14:36,584 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:36,584 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local261885390_0006_r_000000_0' done.
2015-02-10 17:14:36,597 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT/_temporary
2015-02-10 17:14:36,610 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:36,626 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:36,626 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:36,653 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:36,654 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:36,655 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT"]
2015-02-10 17:14:36,655 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:36,655 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:36,655 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:36,657 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...atform/group/VALID/STRICT
2015-02-10 17:14:36,673 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:36,709 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local747079923_0007
2015-02-10 17:14:36,709 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:36,713 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:36,713 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local747079923_0007_m_000000_0
2015-02-10 17:14:36,715 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@60a93995
2015-02-10 17:14:36,717 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:36,718 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@59e61026
2015-02-10 17:14:36,720 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:36,720 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:36,864 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:36,865 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:36,867 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:36,867 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:36,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:36,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:36,883 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:36,885 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:36,888 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local747079923_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:36,890 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:36,890 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local747079923_0007_m_000000_0' done.
2015-02-10 17:14:36,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local747079923_0007_m_000000_0
2015-02-10 17:14:36,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:36,896 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@62ba2e48
2015-02-10 17:14:36,896 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,897 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:36,898 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:36,898 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:36,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:36,910 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:36,910 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT"]
2015-02-10 17:14:36,917 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local747079923_0007_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:36,919 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:36,919 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local747079923_0007_r_000000_0 is allowed to commit now
2015-02-10 17:14:36,923 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local747079923_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT
2015-02-10 17:14:36,925 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:36,925 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local747079923_0007_r_000000_0' done.
2015-02-10 17:14:36,934 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT/_temporary
2015-02-10 17:14:36,946 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:36,962 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:36,962 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:36,992 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:36,992 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:36,993 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT"]
2015-02-10 17:14:36,993 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:36,994 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:36,994 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:36,995 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...tform/group/STRICT/STRICT
2015-02-10 17:14:37,009 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:37,042 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1448562445_0008
2015-02-10 17:14:37,042 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:37,046 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:37,046 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1448562445_0008_m_000000_0
2015-02-10 17:14:37,048 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@47c39412
2015-02-10 17:14:37,050 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:37,050 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1d05a248
2015-02-10 17:14:37,052 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:37,052 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:37,194 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:37,194 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:37,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:37,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,208 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,214 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:37,217 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:37,219 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1448562445_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:37,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:37,222 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1448562445_0008_m_000000_0' done.
2015-02-10 17:14:37,223 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1448562445_0008_m_000000_0
2015-02-10 17:14:37,223 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:37,228 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5e3d5149
2015-02-10 17:14:37,229 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,231 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:37,232 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:37,233 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,233 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:37,234 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,245 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,246 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT"]
2015-02-10 17:14:37,254 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,261 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,267 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1448562445_0008
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,275 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local1448562445_0008 state at FAILED
2015-02-10 17:14:37,275 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:37,275 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:37,275 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:37,279 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:37,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...tform/group/STRICT/STRICT
2015-02-10 17:14:37,280 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:37,281 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT/_temporary
2015-02-10 17:14:37,298 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:37,298 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:37,327 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:37,327 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,327 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID"]
2015-02-10 17:14:37,328 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:37,328 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:37,328 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:37,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...platform/group/NONE/VALID
2015-02-10 17:14:37,343 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:37,379 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local704120740_0009
2015-02-10 17:14:37,380 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:37,383 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:37,383 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local704120740_0009_m_000000_0
2015-02-10 17:14:37,386 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@74d01311
2015-02-10 17:14:37,388 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:37,388 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5ac524dd
2015-02-10 17:14:37,390 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:37,391 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:37,535 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:37,537 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:37,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:37,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,551 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,555 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:37,557 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:37,559 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local704120740_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:37,562 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:37,562 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local704120740_0009_m_000000_0' done.
2015-02-10 17:14:37,562 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local704120740_0009_m_000000_0
2015-02-10 17:14:37,562 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:37,567 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1860045
2015-02-10 17:14:37,567 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,568 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:37,569 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:37,569 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,569 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:37,570 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID"]
2015-02-10 17:14:37,585 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local704120740_0009_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:37,586 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,587 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local704120740_0009_r_000000_0 is allowed to commit now
2015-02-10 17:14:37,590 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local704120740_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID
2015-02-10 17:14:37,592 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:37,592 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local704120740_0009_r_000000_0' done.
2015-02-10 17:14:37,607 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID/_temporary
2015-02-10 17:14:37,618 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:37,634 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:37,634 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:37,657 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:37,657 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,658 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID"]
2015-02-10 17:14:37,658 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:37,658 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:37,658 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:37,659 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...latform/group/VALID/VALID
2015-02-10 17:14:37,705 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:37,732 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1268606457_0010
2015-02-10 17:14:37,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:37,737 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:37,737 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1268606457_0010_m_000000_0
2015-02-10 17:14:37,739 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3ae86a5f
2015-02-10 17:14:37,741 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:37,741 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5f47ff11
2015-02-10 17:14:37,743 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:37,743 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:37,882 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:37,882 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:37,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:37,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,899 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:37,902 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:37,904 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1268606457_0010_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:37,906 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:37,907 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1268606457_0010_m_000000_0' done.
2015-02-10 17:14:37,907 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1268606457_0010_m_000000_0
2015-02-10 17:14:37,907 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:37,911 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@14985016
2015-02-10 17:14:37,912 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,913 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:37,913 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:37,914 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:37,914 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:37,914 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:37,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:37,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID"]
2015-02-10 17:14:37,932 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,933 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,935 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1268606457_0010
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:37,936 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local1268606457_0010 state at FAILED
2015-02-10 17:14:37,936 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:37,936 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:37,936 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:37,946 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:37,947 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...latform/group/VALID/VALID
2015-02-10 17:14:37,947 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:37,948 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID/_temporary
2015-02-10 17:14:37,948 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/group/NONE/VALID
2015-02-10 17:14:37,949 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/group/VALID/VALID
2015-02-10 17:14:37,949 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/group/STRICT/STRICT
2015-02-10 17:14:37,949 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/group/NONE/STRICT
2015-02-10 17:14:37,949 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/group/VALID/STRICT
2015-02-10 17:14:37,962 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:37,963 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:37,986 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:37,986 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:37,987 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/fail"]
2015-02-10 17:14:37,987 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:37,987 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:37,989 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...edassertionsplatform/fail
2015-02-10 17:14:38,001 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:38,028 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1290773940_0011
2015-02-10 17:14:38,029 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:38,032 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:38,032 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1290773940_0011_m_000000_0
2015-02-10 17:14:38,035 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@70a0afab
2015-02-10 17:14:38,036 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:38,037 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@78214f6b
2015-02-10 17:14:38,039 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:38,039 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:38,130 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:38,131 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:38,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:38,134 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,150 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:38,153 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:38,155 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1290773940_0011_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:38,159 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:38,159 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1290773940_0011_m_000000_0' done.
2015-02-10 17:14:38,160 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1290773940_0011_m_000000_0
2015-02-10 17:14:38,160 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:38,165 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1ddd40f3
2015-02-10 17:14:38,166 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,167 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:38,168 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:38,168 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:38,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,180 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,180 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/fail"]
2015-02-10 17:14:38,187 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,193 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,198 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1290773940_0011
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,203 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local1290773940_0011 state at FAILED
2015-02-10 17:14:38,203 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:38,203 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:38,203 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:38,205 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:38,206 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...edassertionsplatform/fail
2015-02-10 17:14:38,206 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:38,207 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/fail/_temporary
2015-02-10 17:14:38,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/fail
2015-02-10 17:14:38,474 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:38,474 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:38,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:38,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/pass"]
2015-02-10 17:14:38,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:38,497 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:38,497 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:38,498 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...edassertionsplatform/pass
2015-02-10 17:14:38,510 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:38,536 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local893018633_0012
2015-02-10 17:14:38,536 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:38,539 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:38,539 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local893018633_0012_m_000000_0
2015-02-10 17:14:38,541 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7de534cb
2015-02-10 17:14:38,543 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:38,544 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2c905b34
2015-02-10 17:14:38,545 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:38,546 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:38,568 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:38,568 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:38,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:38,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,586 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:38,588 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:38,590 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local893018633_0012_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:38,593 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:38,593 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local893018633_0012_m_000000_0' done.
2015-02-10 17:14:38,593 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local893018633_0012_m_000000_0
2015-02-10 17:14:38,593 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:38,597 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7000bcbc
2015-02-10 17:14:38,598 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,599 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:38,599 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:38,600 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,600 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:38,600 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,608 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,608 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/pass"]
2015-02-10 17:14:38,614 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local893018633_0012_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:38,615 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,615 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local893018633_0012_r_000000_0 is allowed to commit now
2015-02-10 17:14:38,618 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local893018633_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/pass
2015-02-10 17:14:38,620 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:38,620 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local893018633_0012_r_000000_0' done.
2015-02-10 17:14:38,630 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/pass/_temporary
2015-02-10 17:14:38,640 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:38,642 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/pass
2015-02-10 17:14:38,654 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:38,654 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:38,729 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:38,729 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,730 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/fail"]
2015-02-10 17:14:38,730 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:38,730 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:38,730 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:38,731 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...rtionsplatform/value/fail
2015-02-10 17:14:38,744 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:38,779 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local14429474_0013
2015-02-10 17:14:38,779 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:38,783 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:38,783 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local14429474_0013_m_000000_0
2015-02-10 17:14:38,785 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@689d6d87
2015-02-10 17:14:38,787 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:38,787 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3654919e
2015-02-10 17:14:38,789 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:38,789 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:38,866 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:38,867 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:38,868 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:38,868 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,883 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:38,886 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:38,888 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local14429474_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:38,890 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:38,891 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local14429474_0013_m_000000_0' done.
2015-02-10 17:14:38,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local14429474_0013_m_000000_0
2015-02-10 17:14:38,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:38,896 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@37eaab
2015-02-10 17:14:38,896 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,897 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:38,898 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:38,898 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:38,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:38,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:38,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:38,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/fail"]
2015-02-10 17:14:38,914 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,915 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,918 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local14429474_0013
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2015-02-10 17:14:38,922 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local14429474_0013 state at FAILED
2015-02-10 17:14:38,922 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2015-02-10 17:14:38,922 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2015-02-10 17:14:38,923 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2015-02-10 17:14:38,924 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopping all jobs
2015-02-10 17:14:38,925 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...rtionsplatform/value/fail
2015-02-10 17:14:38,926 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] stopped all jobs
2015-02-10 17:14:38,926 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/fail/_temporary
2015-02-10 17:14:38,926 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/fail
2015-02-10 17:14:38,942 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:14:38,943 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:14:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 17:14:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/pass"]
2015-02-10 17:14:38,968 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 17:14:38,968 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 17:14:38,968 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 17:14:38,968 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...rtionsplatform/value/pass
2015-02-10 17:14:38,980 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:39,011 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local803157859_0014
2015-02-10 17:14:39,012 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 17:14:39,015 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:14:39,015 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local803157859_0014_m_000000_0
2015-02-10 17:14:39,017 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7192efd
2015-02-10 17:14:39,018 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt
2015-02-10 17:14:39,019 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@78c62333
2015-02-10 17:14:39,020 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2015-02-10 17:14:39,020 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2015-02-10 17:14:39,177 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2015-02-10 17:14:39,177 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2015-02-10 17:14:39,180 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:14:39,180 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:14:39,190 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-02-10 17:14:39,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:39,195 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2015-02-10 17:14:39,198 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2015-02-10 17:14:39,200 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local803157859_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:39,203 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 17:14:39,203 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local803157859_0014_m_000000_0' done.
2015-02-10 17:14:39,203 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local803157859_0014_m_000000_0
2015-02-10 17:14:39,204 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:14:39,208 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@464486de
2015-02-10 17:14:39,209 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:39,210 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2015-02-10 17:14:39,211 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 709 bytes
2015-02-10 17:14:39,211 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:39,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 17:14:39,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 17:14:39,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-02-10 17:14:39,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/pass"]
2015-02-10 17:14:39,227 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local803157859_0014_r_000000_0 is done. And is in the process of commiting
2015-02-10 17:14:39,229 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:14:39,230 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local803157859_0014_r_000000_0 is allowed to commit now
2015-02-10 17:14:39,233 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local803157859_0014_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/pass
2015-02-10 17:14:39,234 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2015-02-10 17:14:39,235 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local803157859_0014_r_000000_0' done.
2015-02-10 17:14:39,246 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/appliedassertionsplatform/value/pass/_temporary
2015-02-10 17:14:39,258 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:14:39,260 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/appliedassertionsplatform/value/pass