2013-11-20 13:27:57,697 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 13:27:57,725 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 13:27:57,726 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.FlowStrategiesPlatformTest
2013-11-20 13:27:57,752 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 13:27:58,125 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:27:58,127 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:27:58,141 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 54C54851CFA1402D8DC5F603C0AEF5B5
2013-11-20 13:27:58,291 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink is marked for delete
2013-11-20 13:27:58,297 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2013-11-20 13:27:58,299 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink is marked for delete
2013-11-20 13:27:58,301 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2013-11-20 13:27:58,345 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 13:27:58,348 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:27:58,349 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:58,349 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/replace"]
2013-11-20 13:27:58,350 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-11-20 13:27:58,351 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-11-20 13:27:58,351 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-11-20 13:27:58,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...trategiesplatform/replace
2013-11-20 13:27:58,397 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 13:27:58,463 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-11-20 13:27:58,469 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:58,691 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0001
2013-11-20 13:27:58,753 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 13:27:58,762 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5d185844
2013-11-20 13:27:58,770 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt
2013-11-20 13:27:58,778 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 13:27:58,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:27:58,792 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:27:58,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:58,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/replace"]
2013-11-20 13:27:58,869 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:27:58,881 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2013-11-20 13:27:58,882 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-11-20 13:27:58,886 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/replace
2013-11-20 13:27:58,887 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:27:58,888 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0001_m_000000_0' done.
2013-11-20 13:27:58,903 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/replace/_temporary
2013-11-20 13:27:58,904 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink is marked for delete
2013-11-20 13:27:58,905 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2013-11-20 13:27:58,906 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink is marked for delete
2013-11-20 13:27:58,906 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2013-11-20 13:27:58,929 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:58,952 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:58,955 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/replace
2013-11-20 13:27:58,979 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:27:58,980 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:27:59,001 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink does not exist
2013-11-20 13:27:59,003 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] at least one sink does not exist
2013-11-20 13:27:59,005 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:27:59,005 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:59,006 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/keep"]
2013-11-20 13:27:59,006 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-11-20 13:27:59,006 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-11-20 13:27:59,006 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-11-20 13:27:59,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...owstrategiesplatform/keep
2013-11-20 13:27:59,023 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:59,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0002
2013-11-20 13:27:59,115 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@f8600d6
2013-11-20 13:27:59,119 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt
2013-11-20 13:27:59,121 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 13:27:59,127 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:27:59,127 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:27:59,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:59,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/keep"]
2013-11-20 13:27:59,143 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:27:59,144 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2013-11-20 13:27:59,145 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-11-20 13:27:59,149 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/keep
2013-11-20 13:27:59,150 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:27:59,151 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0002_m_000000_0' done.
2013-11-20 13:27:59,162 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/keep/_temporary
2013-11-20 13:27:59,166 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Nov 20 13:27:59 UTC 2013
2013-11-20 13:27:59,170 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source modification date at: Wed Nov 20 12:38:24 UTC 2013
2013-11-20 13:27:59,174 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink oldest modified date: Wed Nov 20 13:27:59 UTC 2013
2013-11-20 13:27:59,192 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:59,214 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:59,216 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/keep
2013-11-20 13:27:59,238 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:27:59,239 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:27:59,274 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:27:59,275 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:59,275 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/simple"]
2013-11-20 13:27:59,276 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-11-20 13:27:59,276 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-11-20 13:27:59,276 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-11-20 13:27:59,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...strategiesplatform/simple
2013-11-20 13:27:59,292 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:59,340 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0003
2013-11-20 13:27:59,345 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@29b22d99
2013-11-20 13:27:59,347 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt
2013-11-20 13:27:59,349 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 13:27:59,361 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 13:27:59,497 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 13:27:59,498 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 13:27:59,516 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:27:59,516 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:27:59,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:27:59,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:'ip']]
2013-11-20 13:27:59,541 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 13:27:59,552 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 13:27:59,555 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:27:59,557 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:27:59,558 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_m_000000_0' done.
2013-11-20 13:27:59,567 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5c76458f
2013-11-20 13:27:59,568 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2013-11-20 13:27:59,575 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 13:27:59,581 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 13:27:59,581 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2013-11-20 13:27:59,583 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:27:59,584 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:27:59,598 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:'ip']]
2013-11-20 13:27:59,599 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/simple"]
2013-11-20 13:27:59,613 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:27:59,614 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2013-11-20 13:27:59,615 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2013-11-20 13:27:59,619 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/simple
2013-11-20 13:27:59,620 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2013-11-20 13:27:59,621 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_r_000000_0' done.
2013-11-20 13:27:59,628 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/simple/_temporary
2013-11-20 13:27:59,642 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:27:59,644 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/simple