2016-01-14 22:49:20,707 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 22:49:20,723 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop
2016-01-14 22:49:20,748 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 22:49:20,977 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 22:49:21,071 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:21,074 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:21,173 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: FCD6E2121F454B1F901CBE1F878A8E61
2016-01-14 22:49:21,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.190
2016-01-14 22:49:21,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 22:49:21,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:21,596 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 22:49:21,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:21,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:21,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 22:49:21,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:21,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2016-01-14 22:49:21,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:21,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 22:49:21,637 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 22:49:21,687 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 22:49:21,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1365098985_0001
2016-01-14 22:49:21,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:21,986 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:22,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:22,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDAB8FF9A9A74085B71175B653796450, ordinal: 0
2016-01-14 22:49:22,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:22,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:22,184 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDAB8FF9A9A74085B71175B653796450, mem on start (mb), free: 81, total: 223, max: 672
2016-01-14 22:49:22,196 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDAB8FF9A9A74085B71175B653796450, mem on close (mb), free: 80, total: 223, max: 672
2016-01-14 22:49:22,229 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:22,229 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,242 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C011DD9F3E9E4E1F950DC1B7BBDD6AB6, ordinal: 1
2016-01-14 22:49:22,247 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:22,247 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][3089308328/test/]
2016-01-14 22:49:22,247 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C011DD9F3E9E4E1F950DC1B7BBDD6AB6, mem on start (mb), free: 79, total: 223, max: 672
2016-01-14 22:49:22,265 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C011DD9F3E9E4E1F950DC1B7BBDD6AB6, mem on close (mb), free: 78, total: 223, max: 672
2016-01-14 22:49:22,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-01-14 22:49:22,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1456265705_0002
2016-01-14 22:49:22,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:22,363 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3089308328_test_6977A77FFB0945489083D36748527A7C/part-00000
2016-01-14 22:49:22,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:22,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A8752046328F418685041B3A666B22F0, ordinal: 0
2016-01-14 22:49:22,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][3089308328/test/]
2016-01-14 22:49:22,480 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:22,480 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8752046328F418685041B3A666B22F0, mem on start (mb), free: 67, total: 318, max: 672
2016-01-14 22:49:22,482 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8752046328F418685041B3A666B22F0, mem on close (mb), free: 67, total: 318, max: 672
2016-01-14 22:49:22,492 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:22,492 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,503 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C693A801C7A04671BD2920F5E34F153D, ordinal: 1
2016-01-14 22:49:22,504 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:22,504 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 22:49:22,504 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C693A801C7A04671BD2920F5E34F153D, mem on start (mb), free: 66, total: 318, max: 672
2016-01-14 22:49:22,510 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C693A801C7A04671BD2920F5E34F153D, mem on close (mb), free: 66, total: 318, max: 672
2016-01-14 22:49:22,523 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-14 22:49:22,525 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.924
2016-01-14 22:49:22,555 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleChain/simplechain
2016-01-14 22:49:22,584 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:22,585 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:22,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-01-14 22:49:22,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:22,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:22,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 22:49:22,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:22,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 22:49:22,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 22:49:22,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 22:49:22,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 22:49:22,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-01-14 22:49:22,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1795145925_0003
2016-01-14 22:49:22,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 22:49:22,788 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-01-14 22:49:22,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:22,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,867 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A33B1DEF8A594BADBA3A7E55F670CA40, ordinal: 0
2016-01-14 22:49:22,868 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:22,868 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:22,868 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A33B1DEF8A594BADBA3A7E55F670CA40, mem on start (mb), free: 70, total: 377, max: 672
2016-01-14 22:49:22,873 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A33B1DEF8A594BADBA3A7E55F670CA40, mem on close (mb), free: 70, total: 377, max: 672
2016-01-14 22:49:22,890 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:22,890 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:22,904 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F6F08DA62BA5494597F548A180627DA5, ordinal: 1
2016-01-14 22:49:22,905 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:22,906 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 22:49:22,906 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6F08DA62BA5494597F548A180627DA5, mem on start (mb), free: 69, total: 377, max: 672
2016-01-14 22:49:22,917 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6F08DA62BA5494597F548A180627DA5, mem on close (mb), free: 69, total: 377, max: 672
2016-01-14 22:49:22,938 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count/_temporary
2016-01-14 22:49:22,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.246
2016-01-14 22:49:22,980 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount/count
2016-01-14 22:49:22,998 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:22,998 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:23,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-14 22:49:23,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:49:23,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:23,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:23,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:23,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 22:49:23,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:23,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:23,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:23,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-14 22:49:23,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1395232563_0004
2016-01-14 22:49:23,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:23,140 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:23,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:23,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:23,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AC380FC73C8A46878F22A8C9A9B90366, ordinal: 0
2016-01-14 22:49:23,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:23,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 22:49:23,154 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC380FC73C8A46878F22A8C9A9B90366, mem on start (mb), free: 174, total: 377, max: 672
2016-01-14 22:49:23,156 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC380FC73C8A46878F22A8C9A9B90366, mem on close (mb), free: 174, total: 377, max: 672
2016-01-14 22:49:23,168 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap/_temporary
2016-01-14 22:49:23,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.084
2016-01-14 22:49:23,179 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSwap/swap
2016-01-14 22:49:23,189 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:23,190 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:23,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 22:49:23,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:49:23,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:23,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:23,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 22:49:23,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 22:49:23,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:23,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:23,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:23,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-14 22:49:23,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1459892233_0005
2016-01-14 22:49:23,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:23,284 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower+upper.txt
2016-01-14 22:49:23,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:23,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:23,297 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F02F28F18BB54AEAA8F9BC33FCB061A6, ordinal: 0
2016-01-14 22:49:23,299 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 22:49:23,299 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 22:49:23,300 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F02F28F18BB54AEAA8F9BC33FCB061A6, mem on start (mb), free: 161, total: 377, max: 672
2016-01-14 22:49:23,302 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F02F28F18BB54AEAA8F9BC33FCB061A6, mem on close (mb), free: 161, total: 377, max: 672
2016-01-14 22:49:23,312 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-14 22:49:23,312 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.071
2016-01-14 22:49:23,322 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testUnGroup/ungrouped
2016-01-14 22:49:23,335 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:23,336 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:23,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-14 22:49:23,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:23,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:23,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 22:49:23,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 22:49:23,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:23,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 22:49:23,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 22:49:23,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 22:49:23,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 22:49:23,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-01-14 22:49:23,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1509611650_0006
2016-01-14 22:49:23,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 22:49:23,474 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt
2016-01-14 22:49:23,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:23,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:23,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, ordinal: 0
2016-01-14 22:49:23,586 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 22:49:23,586 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 22:49:23,587 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, mem on start (mb), free: 143, total: 472, max: 672
2016-01-14 22:49:23,589 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, mem on close (mb), free: 143, total: 472, max: 672
2016-01-14 22:49:23,596 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt
2016-01-14 22:49:23,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:23,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:23,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, ordinal: 0
2016-01-14 22:49:23,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:23,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 22:49:23,701 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, mem on start (mb), free: 137, total: 568, max: 672
2016-01-14 22:49:23,703 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9E8B4D3E81645528D34BEEDEA90E50F, mem on close (mb), free: 137, total: 568, max: 672
2016-01-14 22:49:23,715 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:23,716 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:23,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DF6104AB0DBA45149774E6CA08E5AAF1, ordinal: 1
2016-01-14 22:49:23,722 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 22:49:23,722 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 22:49:23,722 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF6104AB0DBA45149774E6CA08E5AAF1, mem on start (mb), free: 136, total: 568, max: 672
2016-01-14 22:49:23,731 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 22:49:23,731 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 22:49:23,738 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF6104AB0DBA45149774E6CA08E5AAF1, mem on close (mb), free: 135, total: 568, max: 672
2016-01-14 22:49:23,756 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-01-14 22:49:23,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.329
2016-01-14 22:49:23,782 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-01-14 22:49:23,792 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:23,793 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:23,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 22:49:23,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:23,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:23,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:23,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:23,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 22:49:23,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:23,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:23,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:23,861 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-01-14 22:49:23,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local757478783_0007
2016-01-14 22:49:23,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:23,903 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:23,998 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:23,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:24,005 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6CD991B6FBB45E7BFDDBB238BBCF1B8, ordinal: 0
2016-01-14 22:49:24,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:24,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:24,006 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6CD991B6FBB45E7BFDDBB238BBCF1B8, mem on start (mb), free: 83, total: 630, max: 672
2016-01-14 22:49:24,009 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6CD991B6FBB45E7BFDDBB238BBCF1B8, mem on close (mb), free: 83, total: 630, max: 672
2016-01-14 22:49:24,018 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:24,018 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:24,029 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B6C0952B826A498C9998C40D3BD34B57, ordinal: 1
2016-01-14 22:49:24,030 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:24,030 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 22:49:24,030 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6C0952B826A498C9998C40D3BD34B57, mem on start (mb), free: 81, total: 630, max: 672
2016-01-14 22:49:24,038 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6C0952B826A498C9998C40D3BD34B57, mem on close (mb), free: 81, total: 630, max: 672
2016-01-14 22:49:24,056 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-01-14 22:49:24,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.197
2016-01-14 22:49:24,065 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelative/simplerelative
2016-01-14 22:49:24,241 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:24,242 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:24,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-14 22:49:24,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:24,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:24,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:24,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:24,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 22:49:24,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:24,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:24,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:24,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-01-14 22:49:24,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local723531313_0008
2016-01-14 22:49:24,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:24,374 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt
2016-01-14 22:49:24,415 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:24,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:24,428 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6AEA6CBA7B442599352F8C2DCA87433, ordinal: 0
2016-01-14 22:49:24,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:24,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:24,430 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6AEA6CBA7B442599352F8C2DCA87433, mem on start (mb), free: 161, total: 746, max: 746
2016-01-14 22:49:24,512 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6AEA6CBA7B442599352F8C2DCA87433, mem on close (mb), free: 158, total: 746, max: 746
2016-01-14 22:49:24,522 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:24,522 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:24,528 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ADEA533640AE444389473ADD8067A91C, ordinal: 1
2016-01-14 22:49:24,529 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:24,529 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 22:49:24,529 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADEA533640AE444389473ADD8067A91C, mem on start (mb), free: 155, total: 746, max: 746
2016-01-14 22:49:24,533 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADEA533640AE444389473ADD8067A91C, mem on close (mb), free: 155, total: 746, max: 746
2016-01-14 22:49:24,553 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-01-14 22:49:24,554 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.224
2016-01-14 22:49:24,566 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleResult/simpleresult
2016-01-14 22:49:24,575 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:24,575 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:24,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 22:49:24,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:49:24,610 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:24,623 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:24,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:24,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 22:49:24,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:24,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:24,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:24,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-01-14 22:49:24,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1169792020_0009
2016-01-14 22:49:24,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:24,658 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:24,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:24,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:24,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C56CE4B704544C1C82A7B814E68C9733, ordinal: 0
2016-01-14 22:49:24,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:24,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 22:49:24,668 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56CE4B704544C1C82A7B814E68C9733, mem on start (mb), free: 139, total: 746, max: 746
2016-01-14 22:49:24,670 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56CE4B704544C1C82A7B814E68C9733, mem on close (mb), free: 139, total: 746, max: 746
2016-01-14 22:49:24,686 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall/_temporary
2016-01-14 22:49:24,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.063
2016-01-14 22:49:24,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testFilterAll/filterall
2016-01-14 22:49:24,707 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:24,707 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:24,742 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 22:49:24,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:24,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:24,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:24,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:24,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 22:49:24,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:24,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:24,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:24,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-01-14 22:49:24,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1347391896_0010
2016-01-14 22:49:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:24,804 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt
2016-01-14 22:49:25,102 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,102 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D2E0DC5791E74203A5901B778643B702, ordinal: 0
2016-01-14 22:49:25,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:25,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-01-14 22:49:25,113 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E0DC5791E74203A5901B778643B702, mem on start (mb), free: 342, total: 451, max: 672
2016-01-14 22:49:25,117 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E0DC5791E74203A5901B778643B702, mem on close (mb), free: 342, total: 451, max: 672
2016-01-14 22:49:25,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:25,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,132 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ACA08D79969D40AB8AAF3A80690FE419, ordinal: 1
2016-01-14 22:49:25,132 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-01-14 22:49:25,132 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 22:49:25,133 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ACA08D79969D40AB8AAF3A80690FE419, mem on start (mb), free: 339, total: 451, max: 672
2016-01-14 22:49:25,137 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ACA08D79969D40AB8AAF3A80690FE419, mem on close (mb), free: 339, total: 451, max: 672
2016-01-14 22:49:25,153 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-01-14 22:49:25,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.389
2016-01-14 22:49:25,162 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-01-14 22:49:25,170 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:25,171 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:25,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 22:49:25,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:25,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:25,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 22:49:25,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 22:49:25,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:25,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 22:49:25,252 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 22:49:25,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 22:49:25,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 22:49:25,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-01-14 22:49:25,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local242107297_0011
2016-01-14 22:49:25,298 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 22:49:25,306 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt
2016-01-14 22:49:25,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,326 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,337 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB902EC405E448A89BFD8D883A73B727, ordinal: 0
2016-01-14 22:49:25,339 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 22:49:25,339 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 22:49:25,339 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB902EC405E448A89BFD8D883A73B727, mem on start (mb), free: 224, total: 451, max: 672
2016-01-14 22:49:25,342 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB902EC405E448A89BFD8D883A73B727, mem on close (mb), free: 224, total: 451, max: 672
2016-01-14 22:49:25,352 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt
2016-01-14 22:49:25,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB902EC405E448A89BFD8D883A73B727, ordinal: 0
2016-01-14 22:49:25,386 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 22:49:25,387 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 22:49:25,387 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB902EC405E448A89BFD8D883A73B727, mem on start (mb), free: 122, total: 451, max: 672
2016-01-14 22:49:25,390 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB902EC405E448A89BFD8D883A73B727, mem on close (mb), free: 122, total: 451, max: 672
2016-01-14 22:49:25,407 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:25,407 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,416 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B86EAB9E8637467881FA27C0C9F8D764, ordinal: 1
2016-01-14 22:49:25,417 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 22:49:25,417 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 22:49:25,418 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B86EAB9E8637467881FA27C0C9F8D764, mem on start (mb), free: 121, total: 451, max: 672
2016-01-14 22:49:25,422 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 22:49:25,422 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 22:49:25,424 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B86EAB9E8637467881FA27C0C9F8D764, mem on close (mb), free: 120, total: 451, max: 672
2016-01-14 22:49:25,445 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-01-14 22:49:25,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.195
2016-01-14 22:49:25,469 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCoGroup/complexcogroup
2016-01-14 22:49:25,481 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:25,482 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:25,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 22:49:25,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:49:25,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:25,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:25,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:25,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 22:49:25,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:25,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:25,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:25,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-14 22:49:25,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local972746843_0012
2016-01-14 22:49:25,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:25,575 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:25,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A38C90EF7DA74CDC86BF76F1ED86B210, ordinal: 0
2016-01-14 22:49:25,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:25,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 22:49:25,591 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A38C90EF7DA74CDC86BF76F1ED86B210, mem on start (mb), free: 331, total: 451, max: 672
2016-01-14 22:49:25,594 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A38C90EF7DA74CDC86BF76F1ED86B210, mem on close (mb), free: 331, total: 451, max: 672
2016-01-14 22:49:25,606 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace/_temporary
2016-01-14 22:49:25,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.068
2016-01-14 22:49:25,616 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testReplace/replace
2016-01-14 22:49:25,624 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:25,625 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:25,653 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 22:49:25,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:25,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:25,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 22:49:25,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:25,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 22:49:25,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 22:49:25,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 22:49:25,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 22:49:25,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-01-14 22:49:25,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1992196435_0013
2016-01-14 22:49:25,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 22:49:25,704 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-01-14 22:49:25,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,726 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C7C8CF7373704FB5B420C5F951E7B54A, ordinal: 0
2016-01-14 22:49:25,727 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:25,727 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:25,728 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7C8CF7373704FB5B420C5F951E7B54A, mem on start (mb), free: 217, total: 451, max: 672
2016-01-14 22:49:25,732 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7C8CF7373704FB5B420C5F951E7B54A, mem on close (mb), free: 217, total: 451, max: 672
2016-01-14 22:49:25,741 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:25,741 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,745 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A76A6CE7100A4B689325DE6B9893C36C, ordinal: 1
2016-01-14 22:49:25,746 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:25,746 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 22:49:25,746 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A76A6CE7100A4B689325DE6B9893C36C, mem on start (mb), free: 216, total: 451, max: 672
2016-01-14 22:49:25,750 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A76A6CE7100A4B689325DE6B9893C36C, mem on close (mb), free: 216, total: 451, max: 672
2016-01-14 22:49:25,765 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2/_temporary
2016-01-14 22:49:25,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.099
2016-01-14 22:49:25,783 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount2/count2
2016-01-14 22:49:25,794 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:25,795 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:25,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 22:49:25,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:25,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:25,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 22:49:25,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:25,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 22:49:25,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 22:49:25,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 22:49:25,848 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 22:49:25,848 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-01-14 22:49:25,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local167516381_0014
2016-01-14 22:49:25,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 22:49:25,877 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-01-14 22:49:25,898 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:25,898 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,903 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3173B3A0EC14FF9B88BD5BD58D3EE78, ordinal: 0
2016-01-14 22:49:25,903 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:25,904 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:25,904 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3173B3A0EC14FF9B88BD5BD58D3EE78, mem on start (mb), free: 241, total: 450, max: 672
2016-01-14 22:49:25,906 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3173B3A0EC14FF9B88BD5BD58D3EE78, mem on close (mb), free: 241, total: 450, max: 672
2016-01-14 22:49:25,915 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:25,915 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:25,920 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D37A8351E959467AA1C8C9DF50AB5578, ordinal: 1
2016-01-14 22:49:25,921 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:25,921 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 22:49:25,921 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D37A8351E959467AA1C8C9DF50AB5578, mem on start (mb), free: 238, total: 450, max: 672
2016-01-14 22:49:25,926 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D37A8351E959467AA1C8C9DF50AB5578, mem on close (mb), free: 238, total: 450, max: 672
2016-01-14 22:49:25,936 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3/_temporary
2016-01-14 22:49:25,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.090
2016-01-14 22:49:25,951 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount3/count3
2016-01-14 22:49:25,958 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:25,959 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:25,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 22:49:25,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:25,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:25,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 22:49:25,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:25,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 22:49:25,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 22:49:25,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 22:49:25,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 22:49:25,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-01-14 22:49:26,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1491149002_0015
2016-01-14 22:49:26,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 22:49:26,024 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-01-14 22:49:26,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:26,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:26,044 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B87929924F74467FA6085D14A9B96CB7, ordinal: 0
2016-01-14 22:49:26,044 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-01-14 22:49:26,044 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:26,045 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B87929924F74467FA6085D14A9B96CB7, mem on start (mb), free: 122, total: 450, max: 672
2016-01-14 22:49:26,047 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B87929924F74467FA6085D14A9B96CB7, mem on close (mb), free: 122, total: 450, max: 672
2016-01-14 22:49:26,056 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:26,056 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:26,063 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AB83DB6CECE54DAAAD9968C794B93547, ordinal: 1
2016-01-14 22:49:26,064 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 22:49:26,064 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 22:49:26,064 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AB83DB6CECE54DAAAD9968C794B93547, mem on start (mb), free: 121, total: 450, max: 672
2016-01-14 22:49:26,070 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AB83DB6CECE54DAAAD9968C794B93547, mem on close (mb), free: 121, total: 450, max: 672
2016-01-14 22:49:26,083 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4/_temporary
2016-01-14 22:49:26,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.088
2016-01-14 22:49:26,098 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount4/count4
2016-01-14 22:49:26,105 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:26,105 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:26,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 22:49:26,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:49:26,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:26,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:26,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:26,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 22:49:26,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:26,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:26,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:26,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-14 22:49:26,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1381107235_0016
2016-01-14 22:49:26,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:26,166 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:26,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:26,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:26,173 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F31BB9E8872C4E83B4310194C9F0A19C, ordinal: 0
2016-01-14 22:49:26,174 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:26,174 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 22:49:26,174 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F31BB9E8872C4E83B4310194C9F0A19C, mem on start (mb), free: 339, total: 450, max: 672
2016-01-14 22:49:26,175 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F31BB9E8872C4E83B4310194C9F0A19C, mem on close (mb), free: 339, total: 450, max: 672
2016-01-14 22:49:26,184 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter/_temporary
2016-01-14 22:49:26,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.050
2016-01-14 22:49:26,192 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testFilter/filter
2016-01-14 22:49:26,200 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:49:26,201 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:49:26,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 22:49:26,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:49:26,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:49:26,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:49:26,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:26,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 22:49:26,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:49:26,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:49:26,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:49:26,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-01-14 22:49:26,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local21051755_0017
2016-01-14 22:49:26,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:49:26,279 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-01-14 22:49:26,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:49:26,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:49:26,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB58DC8FDCD24D4CABDE2CD95BB68E81, ordinal: 0
2016-01-14 22:49:26,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:49:26,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:26,304 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB58DC8FDCD24D4CABDE2CD95BB68E81, mem on start (mb), free: 224, total: 450, max: 672
2016-01-14 22:49:26,308 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB58DC8FDCD24D4CABDE2CD95BB68E81, mem on close (mb), free: 224, total: 450, max: 672
2016-01-14 22:49:26,318 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:49:26,318 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:49:26,324 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CF422B81EBC440D9B489C9625CF9BFCE, ordinal: 1
2016-01-14 22:49:26,325 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 22:49:26,325 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 22:49:26,325 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CF422B81EBC440D9B489C9625CF9BFCE, mem on start (mb), free: 223, total: 450, max: 672
2016-01-14 22:49:26,328 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CF422B81EBC440D9B489C9625CF9BFCE, mem on close (mb), free: 223, total: 450, max: 672
2016-01-14 22:49:26,337 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple/_temporary
2016-01-14 22:49:26,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.088
2016-01-14 22:49:26,345 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimple/simple