Class cascading.BasicPipesPlatformTest

16

tests

0

failures

6.706s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 0.458s passed
testCoGroupRelativeUnknown 0.554s passed
testCount 0.396s passed
testCount2 0.495s passed
testCount3 0.173s passed
testCount4 0.238s passed
testFilter 0.112s passed
testFilterAll 0.137s passed
testReplace 0.111s passed
testSimple 0.302s passed
testSimpleChain 1.901s passed
testSimpleRelative 0.532s passed
testSimpleRelativeUnknown 0.316s passed
testSimpleResult 0.637s passed
testSwap 0.175s passed
testUnGroup 0.169s passed

Standard output

2015-08-13 22:36:41,995 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 22:36:42,042 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 22:36:42,043 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-08-13 22:36:42,078 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 22:36:42,371 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-13 22:36:42,488 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:42,490 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:42,504 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 01A789EF424A40B8A73E7AF812C30E62
2015-08-13 22:36:42,760 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 22:36:42,763 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:42,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:42,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-08-13 22:36:42,765 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:42,765 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-08-13 22:36:42,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:42,768 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-13 22:36:42,819 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 22:36:42,886 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 22:36:43,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0001
2015-08-13 22:36:43,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:43,232 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:43,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:43,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:43,480 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:43,481 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:43,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:43,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:43,563 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:43,563 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][6783297355/test/]
2015-08-13 22:36:43,604 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-08-13 22:36:43,724 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0002
2015-08-13 22:36:43,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:43,732 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/6783297355_test_D2734EBDCF454CBCA2C59FCA331BF4CA/part-00000
2015-08-13 22:36:43,877 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:43,878 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:43,892 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][6783297355/test/]
2015-08-13 22:36:43,893 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:43,912 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:43,913 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:43,924 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:43,925 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-08-13 22:36:43,950 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2015-08-13 22:36:43,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplechain
2015-08-13 22:36:44,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:44,008 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:44,034 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-13 22:36:44,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:44,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-08-13 22:36:44,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-08-13 22:36:44,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-08-13 22:36:44,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-08-13 22:36:44,037 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-08-13 22:36:44,117 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local_0003
2015-08-13 22:36:44,117 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-13 22:36:44,122 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-08-13 22:36:44,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:44,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:44,270 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:44,270 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:44,292 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:44,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:44,302 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:44,303 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-08-13 22:36:44,330 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2015-08-13 22:36:44,374 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count
2015-08-13 22:36:44,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:44,396 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:44,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:44,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:44,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-08-13 22:36:44,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:44,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:44,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:44,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2015-08-13 22:36:44,491 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0004
2015-08-13 22:36:44,491 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:44,497 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:44,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:44,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:44,515 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:44,515 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-08-13 22:36:44,534 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2015-08-13 22:36:44,550 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/swap
2015-08-13 22:36:44,568 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:44,569 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:44,600 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:44,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-08-13 22:36:44,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-08-13 22:36:44,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:44,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:44,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:44,603 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-08-13 22:36:44,663 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0005
2015-08-13 22:36:44,663 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:44,669 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower+upper.txt
2015-08-13 22:36:44,676 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:44,677 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:44,686 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-08-13 22:36:44,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-08-13 22:36:44,706 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2015-08-13 22:36:44,721 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2015-08-13 22:36:44,743 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:44,744 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:44,786 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-13 22:36:44,786 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-08-13 22:36:44,787 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:44,787 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogrouprelativeunknown"]
2015-08-13 22:36:44,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: false
2015-08-13 22:36:44,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-13 22:36:44,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-13 22:36:44,789 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2015-08-13 22:36:44,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local_0006
2015-08-13 22:36:44,852 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-13 22:36:44,857 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt
2015-08-13 22:36:44,996 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:44,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:45,009 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:45,010 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-13 22:36:45,023 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt
2015-08-13 22:36:45,172 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:45,173 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:45,182 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-08-13 22:36:45,183 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-13 22:36:45,203 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:45,204 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:45,213 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-13 22:36:45,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogrouprelativeunknown"]
2015-08-13 22:36:45,227 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 22:36:45,228 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 22:36:45,250 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogrouprelativeunknown/_temporary
2015-08-13 22:36:45,275 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/complexcogrouprelativeunknown
2015-08-13 22:36:45,289 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:45,290 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:45,313 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:45,314 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:45,314 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-08-13 22:36:45,315 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:45,315 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:45,315 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:45,317 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-08-13 22:36:45,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0007
2015-08-13 22:36:45,365 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:45,371 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:45,728 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:45,729 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:45,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:45,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:45,757 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:45,758 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:45,768 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:45,769 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-08-13 22:36:45,795 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2015-08-13 22:36:45,807 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2015-08-13 22:36:46,040 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:46,041 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:46,077 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:46,078 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:46,078 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-08-13 22:36:46,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:46,080 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:46,080 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:46,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-08-13 22:36:46,129 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0008
2015-08-13 22:36:46,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:46,134 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt
2015-08-13 22:36:46,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:46,273 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:46,285 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:46,285 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:46,399 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:46,399 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:46,409 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:46,410 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-08-13 22:36:46,434 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2015-08-13 22:36:46,446 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2015-08-13 22:36:46,458 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:46,458 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:46,477 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:46,477 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:46,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-08-13 22:36:46,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:46,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:46,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:46,479 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-08-13 22:36:46,526 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0009
2015-08-13 22:36:46,528 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:46,533 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:46,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:46,540 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:46,548 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:46,548 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-08-13 22:36:46,569 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2015-08-13 22:36:46,583 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filterall
2015-08-13 22:36:46,598 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:46,599 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:46,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:46,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:46,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelativeunknown"]
2015-08-13 22:36:46,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:46,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:46,624 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:46,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...orm/simplerelativeunknown
2015-08-13 22:36:46,674 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0010
2015-08-13 22:36:46,674 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:46,680 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt
2015-08-13 22:36:46,831 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:46,834 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:46,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:46,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2015-08-13 22:36:46,859 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:46,859 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:46,867 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2015-08-13 22:36:46,868 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelativeunknown"]
2015-08-13 22:36:46,888 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelativeunknown/_temporary
2015-08-13 22:36:46,899 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplerelativeunknown
2015-08-13 22:36:46,912 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:46,913 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:46,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-13 22:36:46,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-08-13 22:36:46,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:46,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-08-13 22:36:46,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: false
2015-08-13 22:36:46,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-13 22:36:46,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-13 22:36:46,941 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-08-13 22:36:46,982 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local_0011
2015-08-13 22:36:46,982 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-13 22:36:46,988 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt
2015-08-13 22:36:47,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:47,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,136 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-08-13 22:36:47,136 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-13 22:36:47,147 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt
2015-08-13 22:36:47,281 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:47,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-08-13 22:36:47,292 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-13 22:36:47,309 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:47,310 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,318 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-13 22:36:47,319 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-08-13 22:36:47,323 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 22:36:47,324 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 22:36:47,337 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2015-08-13 22:36:47,358 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2015-08-13 22:36:47,369 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:47,370 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:47,384 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:47,384 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:47,384 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-08-13 22:36:47,385 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:47,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:47,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:47,387 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-08-13 22:36:47,425 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0012
2015-08-13 22:36:47,426 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:47,430 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:47,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:47,435 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,441 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:47,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-08-13 22:36:47,458 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2015-08-13 22:36:47,469 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/replace
2015-08-13 22:36:47,480 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:47,481 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:47,498 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-13 22:36:47,498 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:47,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-08-13 22:36:47,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-08-13 22:36:47,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-08-13 22:36:47,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-08-13 22:36:47,500 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-08-13 22:36:47,539 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local_0013
2015-08-13 22:36:47,540 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-13 22:36:47,544 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-08-13 22:36:47,629 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:47,630 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,638 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:47,638 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:47,657 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:47,658 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:47,665 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:47,666 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-08-13 22:36:47,690 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2015-08-13 22:36:47,714 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count2
2015-08-13 22:36:47,976 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:47,977 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:47,993 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-13 22:36:47,994 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:47,994 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-08-13 22:36:47,994 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-08-13 22:36:47,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-08-13 22:36:47,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-08-13 22:36:47,997 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-08-13 22:36:48,033 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local_0014
2015-08-13 22:36:48,035 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-13 22:36:48,040 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-08-13 22:36:48,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:48,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:48,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:48,088 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:48,089 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,096 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:48,096 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-08-13 22:36:48,117 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2015-08-13 22:36:48,138 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count3
2015-08-13 22:36:48,149 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:48,149 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:48,166 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-13 22:36:48,166 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:48,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-08-13 22:36:48,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-08-13 22:36:48,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-08-13 22:36:48,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-08-13 22:36:48,169 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-08-13 22:36:48,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local_0015
2015-08-13 22:36:48,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-13 22:36:48,215 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-08-13 22:36:48,294 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:48,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 22:36:48,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:48,322 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:48,322 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,330 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-13 22:36:48,330 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-08-13 22:36:48,352 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2015-08-13 22:36:48,376 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count4
2015-08-13 22:36:48,388 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:48,389 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:48,403 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:48,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:48,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-08-13 22:36:48,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:48,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:48,405 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:48,405 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-08-13 22:36:48,444 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0016
2015-08-13 22:36:48,445 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:48,450 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:48,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:48,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:48,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-08-13 22:36:48,476 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2015-08-13 22:36:48,488 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filter
2015-08-13 22:36:48,503 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 22:36:48,504 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 22:36:48,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 22:36:48,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:48,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-08-13 22:36:48,526 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-08-13 22:36:48,526 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-13 22:36:48,526 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-13 22:36:48,527 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-08-13 22:36:48,566 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0017
2015-08-13 22:36:48,566 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 22:36:48,571 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-08-13 22:36:48,721 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 22:36:48,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-08-13 22:36:48,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:48,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 22:36:48,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 22:36:48,758 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-13 22:36:48,758 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-08-13 22:36:48,779 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2015-08-13 22:36:48,791 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simple