2016-05-17 22:25:31,577 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:25:31,601 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop
2016-05-17 22:25:31,645 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 22:25:31,889 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:25:31,995 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:31,997 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:25:32,112 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 7BC61689738941EA86A2147F43AA455D
2016-05-17 22:25:32,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.208
2016-05-17 22:25:32,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:25:32,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:32,577 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:25:32,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-17 22:25:32,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 22:25:32,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:32,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-17 22:25:32,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-17 22:25:32,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-17 22:25:32,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-17 22:25:32,596 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2016-05-17 22:25:32,628 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 22:25:32,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local_0001
2016-05-17 22:25:32,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-17 22:25:32,935 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt
2016-05-17 22:25:33,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:33,079 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:33,100 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, ordinal: 0
2016-05-17 22:25:33,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 22:25:33,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:33,141 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, mem on start (mb), free: 83, total: 223, max: 672
2016-05-17 22:25:33,212 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, mem on close (mb), free: 83, total: 223, max: 672
2016-05-17 22:25:35,914 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 22:25:36,013 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:36,013 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:36,032 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, ordinal: 0
2016-05-17 22:25:36,033 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:36,034 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:36,034 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, mem on start (mb), free: 76, total: 318, max: 672
2016-05-17 22:25:36,040 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBFBB6D404D144A5B3E95746AD0218FD, mem on close (mb), free: 76, total: 318, max: 672
2016-05-17 22:25:38,934 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:25:38,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:25:38,946 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BE9E14C5F611407EB2613C17AA8F0827, ordinal: 1
2016-05-17 22:25:38,949 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:38,949 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-17 22:25:38,950 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BE9E14C5F611407EB2613C17AA8F0827, mem on start (mb), free: 74, total: 318, max: 672
2016-05-17 22:25:38,969 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:25:38,970 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:25:39,006 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BE9E14C5F611407EB2613C17AA8F0827, mem on close (mb), free: 72, total: 318, max: 672
2016-05-17 22:25:41,933 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2016-05-17 22:25:41,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:09.349
2016-05-17 22:25:41,996 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2016-05-17 22:25:42,031 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:42,032 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:25:42,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.138
2016-05-17 22:25:42,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:25:42,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:42,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-17 22:25:42,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 22:25:42,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:42,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-17 22:25:42,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-17 22:25:42,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-17 22:25:42,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-17 22:25:42,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2016-05-17 22:25:42,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local_0002
2016-05-17 22:25:42,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-17 22:25:42,341 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt
2016-05-17 22:25:42,436 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:42,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:42,451 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F247FE3EC02C4374857B57BB43680A77, ordinal: 0
2016-05-17 22:25:42,452 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 22:25:42,452 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:42,452 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F247FE3EC02C4374857B57BB43680A77, mem on start (mb), free: 112, total: 414, max: 672
2016-05-17 22:25:42,493 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F247FE3EC02C4374857B57BB43680A77, mem on close (mb), free: 112, total: 414, max: 672
2016-05-17 22:25:45,344 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 22:25:45,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:45,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:45,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F247FE3EC02C4374857B57BB43680A77, ordinal: 0
2016-05-17 22:25:45,451 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:45,451 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:45,451 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F247FE3EC02C4374857B57BB43680A77, mem on start (mb), free: 106, total: 509, max: 672
2016-05-17 22:25:45,454 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F247FE3EC02C4374857B57BB43680A77, mem on close (mb), free: 106, total: 509, max: 672
2016-05-17 22:25:48,353 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:25:48,353 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:25:48,363 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D38333390D7447CBA55B85B1288D3B7A, ordinal: 1
2016-05-17 22:25:48,364 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-17 22:25:48,364 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-17 22:25:48,364 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D38333390D7447CBA55B85B1288D3B7A, mem on start (mb), free: 104, total: 509, max: 672
2016-05-17 22:25:48,371 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:25:48,371 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:25:48,396 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D38333390D7447CBA55B85B1288D3B7A, mem on close (mb), free: 103, total: 509, max: 672
2016-05-17 22:25:51,359 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2016-05-17 22:25:51,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:09.135
2016-05-17 22:25:51,398 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2016-05-17 22:25:51,417 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:51,417 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:25:51,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.022
2016-05-17 22:25:51,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 22:25:51,462 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:51,462 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:25:51,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-17 22:25:51,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:25:51,511 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:51,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:25:51,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:25:51,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-17 22:25:51,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:25:51,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:25:51,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:25:51,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2016-05-17 22:25:51,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0003
2016-05-17 22:25:51,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:25:51,605 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:25:51,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:51,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:51,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E4F816A2D7CD40E09583D2FCDFED48E1, ordinal: 0
2016-05-17 22:25:51,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:25:51,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:25:51,713 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4F816A2D7CD40E09583D2FCDFED48E1, mem on start (mb), free: 51, total: 572, max: 672
2016-05-17 22:25:51,719 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4F816A2D7CD40E09583D2FCDFED48E1, mem on close (mb), free: 51, total: 572, max: 672
2016-05-17 22:25:54,610 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:25:54,610 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:25:54,617 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E06DBF9BE26E43A3B9E45CD23A80A97A, ordinal: 1
2016-05-17 22:25:54,618 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:25:54,618 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-17 22:25:54,618 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E06DBF9BE26E43A3B9E45CD23A80A97A, mem on start (mb), free: 50, total: 572, max: 672
2016-05-17 22:25:54,627 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E06DBF9BE26E43A3B9E45CD23A80A97A, mem on close (mb), free: 49, total: 572, max: 672
2016-05-17 22:25:57,614 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2016-05-17 22:25:57,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.081
2016-05-17 22:25:57,635 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:57,635 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:25:57,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 22:25:57,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:25:57,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:57,704 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:25:57,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:25:57,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-17 22:25:57,707 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:25:57,707 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:25:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:25:57,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2016-05-17 22:25:57,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0004
2016-05-17 22:25:57,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:25:57,763 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:25:58,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:25:58,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:25:58,010 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDDFD6B560B148F2A349797E3D84568A, ordinal: 0
2016-05-17 22:25:58,012 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:25:58,012 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:25:58,012 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDDFD6B560B148F2A349797E3D84568A, mem on start (mb), free: 140, total: 247, max: 672
2016-05-17 22:25:58,018 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDDFD6B560B148F2A349797E3D84568A, mem on close (mb), free: 140, total: 247, max: 672
2016-05-17 22:26:00,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:00,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:00,776 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B49F54CE3884408E8560A8CD6DC7BB47, ordinal: 1
2016-05-17 22:26:00,776 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:00,777 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-17 22:26:00,777 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B49F54CE3884408E8560A8CD6DC7BB47, mem on start (mb), free: 139, total: 247, max: 672
2016-05-17 22:26:00,785 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B49F54CE3884408E8560A8CD6DC7BB47, mem on close (mb), free: 139, total: 247, max: 672
2016-05-17 22:26:03,773 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2016-05-17 22:26:03,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.069
2016-05-17 22:26:03,795 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:03,795 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:03,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 22:26:03,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:03,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:03,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-17 22:26:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:03,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:03,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:03,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2016-05-17 22:26:03,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0005
2016-05-17 22:26:03,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:03,965 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:04,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:04,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:04,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BCEB4C7B4F734783860E9AA322796FB0, ordinal: 0
2016-05-17 22:26:04,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:04,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:04,076 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCEB4C7B4F734783860E9AA322796FB0, mem on start (mb), free: 124, total: 343, max: 672
2016-05-17 22:26:04,080 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCEB4C7B4F734783860E9AA322796FB0, mem on close (mb), free: 124, total: 343, max: 672
2016-05-17 22:26:06,970 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:06,970 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:06,978 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ACAA23E838694CCAB829B2243097AA53, ordinal: 1
2016-05-17 22:26:06,978 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:06,979 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-17 22:26:06,979 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ACAA23E838694CCAB829B2243097AA53, mem on start (mb), free: 123, total: 343, max: 672
2016-05-17 22:26:06,987 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ACAA23E838694CCAB829B2243097AA53, mem on close (mb), free: 122, total: 343, max: 672
2016-05-17 22:26:09,976 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2016-05-17 22:26:09,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.094
2016-05-17 22:26:09,994 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:09,995 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:10,043 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 22:26:10,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:10,046 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:10,066 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:10,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:10,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-17 22:26:10,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:10,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:10,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:10,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2016-05-17 22:26:10,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0006
2016-05-17 22:26:10,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:10,110 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:10,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:10,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:10,214 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EC6E9EE805614F99A3679B54A2EB3644, ordinal: 0
2016-05-17 22:26:10,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:10,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:10,216 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC6E9EE805614F99A3679B54A2EB3644, mem on start (mb), free: 107, total: 438, max: 672
2016-05-17 22:26:10,223 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC6E9EE805614F99A3679B54A2EB3644, mem on close (mb), free: 107, total: 438, max: 672
2016-05-17 22:26:13,115 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:13,115 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:13,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C4DA0CF882CD4354915C30C6566C8D10, ordinal: 1
2016-05-17 22:26:13,122 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:13,122 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-17 22:26:13,122 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C4DA0CF882CD4354915C30C6566C8D10, mem on start (mb), free: 106, total: 438, max: 672
2016-05-17 22:26:13,130 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C4DA0CF882CD4354915C30C6566C8D10, mem on close (mb), free: 106, total: 438, max: 672
2016-05-17 22:26:16,120 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2016-05-17 22:26:16,120 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.053
2016-05-17 22:26:16,146 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:16,146 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:16,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:26:16,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:16,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:16,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:16,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:16,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-17 22:26:16,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:16,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:16,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:16,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2016-05-17 22:26:16,271 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0007
2016-05-17 22:26:16,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:16,279 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:16,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:16,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:16,413 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5AE3B04D582444CB27F3CCDB2FFA8DE, ordinal: 0
2016-05-17 22:26:16,415 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:16,415 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:16,416 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5AE3B04D582444CB27F3CCDB2FFA8DE, mem on start (mb), free: 92, total: 534, max: 672
2016-05-17 22:26:16,421 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5AE3B04D582444CB27F3CCDB2FFA8DE, mem on close (mb), free: 92, total: 534, max: 672
2016-05-17 22:26:19,283 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:19,284 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:19,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FDBEEBD2F7674A2C8180A6D0933AF869, ordinal: 1
2016-05-17 22:26:19,291 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:19,291 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-17 22:26:19,291 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDBEEBD2F7674A2C8180A6D0933AF869, mem on start (mb), free: 91, total: 534, max: 672
2016-05-17 22:26:19,300 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDBEEBD2F7674A2C8180A6D0933AF869, mem on close (mb), free: 90, total: 534, max: 672
2016-05-17 22:26:22,292 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2016-05-17 22:26:22,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.074
2016-05-17 22:26:22,315 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:22,316 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:22,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 22:26:22,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:22,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:22,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:22,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:22,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-17 22:26:22,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:22,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:22,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:22,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2016-05-17 22:26:22,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0008
2016-05-17 22:26:22,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:22,422 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:22,520 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:22,520 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:22,527 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D617BB16A8704C4283ECFFCD6D826C09, ordinal: 0
2016-05-17 22:26:22,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:22,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:22,528 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D617BB16A8704C4283ECFFCD6D826C09, mem on start (mb), free: 71, total: 572, max: 672
2016-05-17 22:26:22,535 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D617BB16A8704C4283ECFFCD6D826C09, mem on close (mb), free: 70, total: 572, max: 672
2016-05-17 22:26:25,427 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:25,428 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:25,433 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E3A2F1CDE4E442D5A6256D4FE9386928, ordinal: 1
2016-05-17 22:26:25,434 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:25,435 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-17 22:26:25,435 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3A2F1CDE4E442D5A6256D4FE9386928, mem on start (mb), free: 69, total: 572, max: 672
2016-05-17 22:26:25,446 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3A2F1CDE4E442D5A6256D4FE9386928, mem on close (mb), free: 69, total: 572, max: 672
2016-05-17 22:26:28,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2016-05-17 22:26:28,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.052
2016-05-17 22:26:28,457 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:28,458 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:28,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 22:26:28,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:28,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:28,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:28,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:28,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-17 22:26:28,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:28,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:28,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:28,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2016-05-17 22:26:28,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0009
2016-05-17 22:26:28,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:28,566 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:28,615 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:28,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:28,623 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDA6F587C3324964922CA0825F34997E, ordinal: 0
2016-05-17 22:26:28,624 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:28,624 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:28,625 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDA6F587C3324964922CA0825F34997E, mem on start (mb), free: 41, total: 628, max: 672
2016-05-17 22:26:28,629 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDA6F587C3324964922CA0825F34997E, mem on close (mb), free: 41, total: 628, max: 672
2016-05-17 22:26:31,571 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:31,572 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:31,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F6B5B70114FE47E4A375729B53CE5183, ordinal: 1
2016-05-17 22:26:31,579 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:31,579 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-17 22:26:31,580 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6B5B70114FE47E4A375729B53CE5183, mem on start (mb), free: 38, total: 628, max: 672
2016-05-17 22:26:31,588 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6B5B70114FE47E4A375729B53CE5183, mem on close (mb), free: 38, total: 628, max: 672
2016-05-17 22:26:34,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2016-05-17 22:26:34,581 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.063
2016-05-17 22:26:34,601 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:34,601 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:34,641 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:26:34,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:34,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:34,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:34,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:34,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-17 22:26:34,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:34,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:34,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:34,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2016-05-17 22:26:34,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0010
2016-05-17 22:26:34,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:34,718 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:34,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:34,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:34,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FC975E213E714A5E985AAEBB6ECF3A1F, ordinal: 0
2016-05-17 22:26:34,761 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:34,761 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:34,761 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC975E213E714A5E985AAEBB6ECF3A1F, mem on start (mb), free: 42, total: 629, max: 672
2016-05-17 22:26:34,766 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC975E213E714A5E985AAEBB6ECF3A1F, mem on close (mb), free: 42, total: 629, max: 672
2016-05-17 22:26:37,722 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:37,723 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:37,728 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D527593560A2464C9831FA9E4ACF584D, ordinal: 1
2016-05-17 22:26:37,729 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:37,729 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-17 22:26:37,730 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D527593560A2464C9831FA9E4ACF584D, mem on start (mb), free: 40, total: 629, max: 672
2016-05-17 22:26:37,738 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D527593560A2464C9831FA9E4ACF584D, mem on close (mb), free: 40, total: 629, max: 672
2016-05-17 22:26:40,733 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2016-05-17 22:26:40,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.070
2016-05-17 22:26:40,756 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:40,756 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:40,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:26:40,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:40,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:40,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:40,813 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:40,813 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-17 22:26:40,814 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:40,814 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:40,814 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:40,815 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2016-05-17 22:26:40,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0011
2016-05-17 22:26:40,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:40,847 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:40,879 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:40,879 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:40,886 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACD3C787C4F948718479E0BE189A782B, ordinal: 0
2016-05-17 22:26:40,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:40,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:40,887 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACD3C787C4F948718479E0BE189A782B, mem on start (mb), free: 152, total: 739, max: 739
2016-05-17 22:26:40,891 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACD3C787C4F948718479E0BE189A782B, mem on close (mb), free: 152, total: 739, max: 739
2016-05-17 22:26:43,852 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:43,852 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:43,858 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A767D88EE42F427B863659D0DD13433C, ordinal: 1
2016-05-17 22:26:43,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:43,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-17 22:26:43,859 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A767D88EE42F427B863659D0DD13433C, mem on start (mb), free: 150, total: 739, max: 739
2016-05-17 22:26:43,866 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A767D88EE42F427B863659D0DD13433C, mem on close (mb), free: 149, total: 739, max: 739
2016-05-17 22:26:46,862 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2016-05-17 22:26:46,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.050
2016-05-17 22:26:46,884 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:46,884 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:46,916 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:26:46,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:46,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:46,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:46,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:46,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-17 22:26:46,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:46,936 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:46,937 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:46,938 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2016-05-17 22:26:46,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0012
2016-05-17 22:26:46,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:46,968 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:47,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:47,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:47,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E21749A591414D59B706CF973E67EF21, ordinal: 0
2016-05-17 22:26:47,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:47,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:47,064 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E21749A591414D59B706CF973E67EF21, mem on start (mb), free: 37, total: 739, max: 739
2016-05-17 22:26:47,068 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E21749A591414D59B706CF973E67EF21, mem on close (mb), free: 37, total: 739, max: 739
2016-05-17 22:26:49,973 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:49,973 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:49,981 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F424C400A93141E980AB6FA138ADC91C, ordinal: 1
2016-05-17 22:26:49,982 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:49,982 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-17 22:26:49,983 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F424C400A93141E980AB6FA138ADC91C, mem on start (mb), free: 35, total: 739, max: 739
2016-05-17 22:26:49,991 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F424C400A93141E980AB6FA138ADC91C, mem on close (mb), free: 34, total: 739, max: 739
2016-05-17 22:26:52,981 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2016-05-17 22:26:52,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.049
2016-05-17 22:26:53,000 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:53,001 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:53,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:26:53,033 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:53,033 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:53,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:53,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:53,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-17 22:26:53,050 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:53,050 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:53,051 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:53,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2016-05-17 22:26:53,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0013
2016-05-17 22:26:53,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:53,235 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:53,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:53,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:53,263 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CBFAB8130ACC4678AD5C55906CB6D61F, ordinal: 0
2016-05-17 22:26:53,264 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:53,265 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:53,266 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBFAB8130ACC4678AD5C55906CB6D61F, mem on start (mb), free: 213, total: 324, max: 672
2016-05-17 22:26:53,272 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBFAB8130ACC4678AD5C55906CB6D61F, mem on close (mb), free: 213, total: 324, max: 672
2016-05-17 22:26:56,239 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:26:56,240 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:26:56,246 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BCBF40A4BAF14ECFBAA2BA1C79E7CA54, ordinal: 1
2016-05-17 22:26:56,247 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:56,248 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-17 22:26:56,249 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BCBF40A4BAF14ECFBAA2BA1C79E7CA54, mem on start (mb), free: 211, total: 324, max: 672
2016-05-17 22:26:56,256 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BCBF40A4BAF14ECFBAA2BA1C79E7CA54, mem on close (mb), free: 210, total: 324, max: 672
2016-05-17 22:26:59,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2016-05-17 22:26:59,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.201
2016-05-17 22:26:59,268 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:59,268 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:26:59,308 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:26:59,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:26:59,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:59,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:26:59,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:59,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-17 22:26:59,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:26:59,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:26:59,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:26:59,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2016-05-17 22:26:59,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0014
2016-05-17 22:26:59,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:26:59,357 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:26:59,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:59,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:59,386 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F06212D35531479095900E2FCDEBB892, ordinal: 0
2016-05-17 22:26:59,386 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:26:59,387 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:26:59,387 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F06212D35531479095900E2FCDEBB892, mem on start (mb), free: 96, total: 324, max: 672
2016-05-17 22:26:59,392 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F06212D35531479095900E2FCDEBB892, mem on close (mb), free: 96, total: 324, max: 672
2016-05-17 22:27:02,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:02,361 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:02,365 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1B08AB4B807497091DF2506A1A53867, ordinal: 1
2016-05-17 22:27:02,365 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:02,365 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-17 22:27:02,366 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1B08AB4B807497091DF2506A1A53867, mem on start (mb), free: 93, total: 324, max: 672
2016-05-17 22:27:02,372 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1B08AB4B807497091DF2506A1A53867, mem on close (mb), free: 92, total: 324, max: 672
2016-05-17 22:27:05,361 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2016-05-17 22:27:05,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.039
2016-05-17 22:27:05,377 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:05,377 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:05,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:27:05,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:05,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:05,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:05,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:05,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-17 22:27:05,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:05,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:05,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:05,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2016-05-17 22:27:05,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0015
2016-05-17 22:27:05,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:05,465 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:05,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:05,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:05,484 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C41F1B979E8841B18BAB05CAE211FD58, ordinal: 0
2016-05-17 22:27:05,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:05,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:05,485 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C41F1B979E8841B18BAB05CAE211FD58, mem on start (mb), free: 212, total: 329, max: 672
2016-05-17 22:27:05,489 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C41F1B979E8841B18BAB05CAE211FD58, mem on close (mb), free: 212, total: 329, max: 672
2016-05-17 22:27:08,469 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:08,469 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:08,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E51E6A3CCE274B0C936BB5717655253F, ordinal: 1
2016-05-17 22:27:08,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:08,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-17 22:27:08,475 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E51E6A3CCE274B0C936BB5717655253F, mem on start (mb), free: 210, total: 329, max: 672
2016-05-17 22:27:08,481 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E51E6A3CCE274B0C936BB5717655253F, mem on close (mb), free: 210, total: 329, max: 672
2016-05-17 22:27:11,476 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2016-05-17 22:27:11,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.042
2016-05-17 22:27:11,491 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:11,491 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:11,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 22:27:11,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:11,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:11,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:11,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:11,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-17 22:27:11,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:11,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:11,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:11,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2016-05-17 22:27:11,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0016
2016-05-17 22:27:11,561 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:11,565 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:11,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:11,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:11,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE9C46FAA7144823801C05B2A2EBB44D, ordinal: 0
2016-05-17 22:27:11,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:11,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:11,590 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE9C46FAA7144823801C05B2A2EBB44D, mem on start (mb), free: 99, total: 329, max: 672
2016-05-17 22:27:11,594 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE9C46FAA7144823801C05B2A2EBB44D, mem on close (mb), free: 99, total: 329, max: 672
2016-05-17 22:27:14,571 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:14,571 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:14,576 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E882D10A1D9F47EFA279F94F78A59724, ordinal: 1
2016-05-17 22:27:14,577 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:14,577 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-17 22:27:14,578 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E882D10A1D9F47EFA279F94F78A59724, mem on start (mb), free: 97, total: 329, max: 672
2016-05-17 22:27:14,585 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E882D10A1D9F47EFA279F94F78A59724, mem on close (mb), free: 97, total: 329, max: 672
2016-05-17 22:27:17,571 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2016-05-17 22:27:17,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.039
2016-05-17 22:27:17,585 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:17,586 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:17,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 22:27:17,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:17,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:17,643 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:17,643 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:17,643 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-17 22:27:17,644 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:17,644 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:17,644 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:17,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2016-05-17 22:27:17,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0017
2016-05-17 22:27:17,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:17,684 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:17,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:17,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:17,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E65F587A14C742BA9B0B5C6CF69859AD, ordinal: 0
2016-05-17 22:27:17,706 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:17,706 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:17,707 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E65F587A14C742BA9B0B5C6CF69859AD, mem on start (mb), free: 216, total: 329, max: 672
2016-05-17 22:27:17,711 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E65F587A14C742BA9B0B5C6CF69859AD, mem on close (mb), free: 216, total: 329, max: 672
2016-05-17 22:27:20,688 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:20,688 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:20,693 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CFAD37BF469C46579A7A04D44A2885BA, ordinal: 1
2016-05-17 22:27:20,693 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:20,694 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-17 22:27:20,694 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CFAD37BF469C46579A7A04D44A2885BA, mem on start (mb), free: 215, total: 329, max: 672
2016-05-17 22:27:20,700 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CFAD37BF469C46579A7A04D44A2885BA, mem on close (mb), free: 215, total: 329, max: 672
2016-05-17 22:27:23,699 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2016-05-17 22:27:23,701 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.057
2016-05-17 22:27:23,714 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:23,714 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:23,739 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-17 22:27:23,740 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:23,740 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:23,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:23,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:23,750 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-17 22:27:23,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:23,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:23,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:23,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2016-05-17 22:27:23,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0018
2016-05-17 22:27:23,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:23,779 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:23,795 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:23,795 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:23,801 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1A6DD339D364A99AD7BF6CA1BA793D1, ordinal: 0
2016-05-17 22:27:23,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:23,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:23,803 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1A6DD339D364A99AD7BF6CA1BA793D1, mem on start (mb), free: 102, total: 329, max: 672
2016-05-17 22:27:23,808 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1A6DD339D364A99AD7BF6CA1BA793D1, mem on close (mb), free: 102, total: 329, max: 672
2016-05-17 22:27:26,792 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:26,792 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:26,797 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CD8D54D117104AE7A095BBCFA70FB9C8, ordinal: 1
2016-05-17 22:27:26,797 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:26,798 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-17 22:27:26,798 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CD8D54D117104AE7A095BBCFA70FB9C8, mem on start (mb), free: 100, total: 329, max: 672
2016-05-17 22:27:26,804 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CD8D54D117104AE7A095BBCFA70FB9C8, mem on close (mb), free: 100, total: 329, max: 672
2016-05-17 22:27:29,798 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2016-05-17 22:27:29,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.049
2016-05-17 22:27:29,812 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:29,812 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:29,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-17 22:27:29,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:29,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:29,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:29,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:29,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-17 22:27:29,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:29,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:29,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:29,861 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2016-05-17 22:27:29,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0019
2016-05-17 22:27:29,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:29,897 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:29,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:29,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:29,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDB9AEFE16874580AE6F5EFB96829142, ordinal: 0
2016-05-17 22:27:29,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:29,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:29,920 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDB9AEFE16874580AE6F5EFB96829142, mem on start (mb), free: 218, total: 328, max: 672
2016-05-17 22:27:29,925 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDB9AEFE16874580AE6F5EFB96829142, mem on close (mb), free: 218, total: 328, max: 672
2016-05-17 22:27:32,901 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:32,902 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:32,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E613CC2C715D4713B8F0E338D7980A5F, ordinal: 1
2016-05-17 22:27:32,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:32,908 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-17 22:27:32,908 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E613CC2C715D4713B8F0E338D7980A5F, mem on start (mb), free: 217, total: 328, max: 672
2016-05-17 22:27:32,917 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E613CC2C715D4713B8F0E338D7980A5F, mem on close (mb), free: 217, total: 328, max: 672
2016-05-17 22:27:35,911 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2016-05-17 22:27:35,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.052
2016-05-17 22:27:35,925 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:35,925 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:35,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:27:35,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:35,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:35,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:35,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:35,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-17 22:27:35,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:35,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:35,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:35,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2016-05-17 22:27:35,999 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0020
2016-05-17 22:27:35,999 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:36,003 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:36,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:36,019 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:36,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAE697F40C8440EF87CE57E7544560E1, ordinal: 0
2016-05-17 22:27:36,028 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:36,028 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:36,028 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAE697F40C8440EF87CE57E7544560E1, mem on start (mb), free: 104, total: 328, max: 672
2016-05-17 22:27:36,035 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAE697F40C8440EF87CE57E7544560E1, mem on close (mb), free: 104, total: 328, max: 672
2016-05-17 22:27:39,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:39,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:39,012 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A4DF6BB365544E869D7C07C5CE48E67D, ordinal: 1
2016-05-17 22:27:39,013 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:39,013 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-17 22:27:39,013 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DF6BB365544E869D7C07C5CE48E67D, mem on start (mb), free: 103, total: 328, max: 672
2016-05-17 22:27:39,021 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DF6BB365544E869D7C07C5CE48E67D, mem on close (mb), free: 103, total: 328, max: 672
2016-05-17 22:27:42,008 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2016-05-17 22:27:42,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.035
2016-05-17 22:27:42,022 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:42,023 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:42,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 22:27:42,056 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:42,056 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:42,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:42,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:42,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-17 22:27:42,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:42,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:42,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:42,072 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2016-05-17 22:27:42,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0021
2016-05-17 22:27:42,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:42,105 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:42,125 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:42,125 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:42,132 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B89BD05FDFB843A48E25C1BF7DF236C7, ordinal: 0
2016-05-17 22:27:42,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:42,134 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:42,134 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B89BD05FDFB843A48E25C1BF7DF236C7, mem on start (mb), free: 220, total: 329, max: 672
2016-05-17 22:27:42,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B89BD05FDFB843A48E25C1BF7DF236C7, mem on close (mb), free: 220, total: 329, max: 672
2016-05-17 22:27:45,109 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:45,110 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:45,116 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F9F1F8A2DA7840AB8F54EAA85E8F0469, ordinal: 1
2016-05-17 22:27:45,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:45,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-17 22:27:45,119 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F9F1F8A2DA7840AB8F54EAA85E8F0469, mem on start (mb), free: 218, total: 329, max: 672
2016-05-17 22:27:45,126 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F9F1F8A2DA7840AB8F54EAA85E8F0469, mem on close (mb), free: 217, total: 329, max: 672
2016-05-17 22:27:48,117 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2016-05-17 22:27:48,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.048
2016-05-17 22:27:48,132 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:48,133 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:48,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:27:48,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:48,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:48,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:48,168 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:48,168 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-17 22:27:48,168 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:48,169 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:48,169 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:48,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2016-05-17 22:27:48,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0022
2016-05-17 22:27:48,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:48,194 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:48,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:48,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:48,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED889C4D1C014664B7ED0EF083329191, ordinal: 0
2016-05-17 22:27:48,214 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:48,214 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:48,214 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED889C4D1C014664B7ED0EF083329191, mem on start (mb), free: 106, total: 329, max: 672
2016-05-17 22:27:48,218 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED889C4D1C014664B7ED0EF083329191, mem on close (mb), free: 106, total: 329, max: 672
2016-05-17 22:27:51,199 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:51,199 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:51,203 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F8F986286D114210835C4F6B54638C0D, ordinal: 1
2016-05-17 22:27:51,204 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:51,204 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-17 22:27:51,204 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8F986286D114210835C4F6B54638C0D, mem on start (mb), free: 104, total: 329, max: 672
2016-05-17 22:27:51,210 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8F986286D114210835C4F6B54638C0D, mem on close (mb), free: 104, total: 329, max: 672
2016-05-17 22:27:54,207 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2016-05-17 22:27:54,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.040
2016-05-17 22:27:54,223 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:27:54,223 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:27:54,245 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:27:54,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:27:54,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:27:54,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:27:54,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:54,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-17 22:27:54,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:27:54,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:27:54,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:27:54,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2016-05-17 22:27:54,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0023
2016-05-17 22:27:54,283 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:27:54,287 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:27:54,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:27:54,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:27:54,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F0C3CFA021054B65A3408ACFA6C61953, ordinal: 0
2016-05-17 22:27:54,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:27:54,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:54,309 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0C3CFA021054B65A3408ACFA6C61953, mem on start (mb), free: 219, total: 328, max: 672
2016-05-17 22:27:54,312 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0C3CFA021054B65A3408ACFA6C61953, mem on close (mb), free: 219, total: 328, max: 672
2016-05-17 22:27:57,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:27:57,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:27:57,295 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FE35C7435A124561B3AD3D4E419B2612, ordinal: 1
2016-05-17 22:27:57,296 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:27:57,296 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-17 22:27:57,296 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE35C7435A124561B3AD3D4E419B2612, mem on start (mb), free: 217, total: 328, max: 672
2016-05-17 22:27:57,303 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE35C7435A124561B3AD3D4E419B2612, mem on close (mb), free: 216, total: 328, max: 672
2016-05-17 22:28:00,292 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2016-05-17 22:28:00,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.036
2016-05-17 22:28:00,307 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:28:00,307 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:28:00,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 22:28:00,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:28:00,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:28:00,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:28:00,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:00,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-17 22:28:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:28:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:28:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:28:00,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2016-05-17 22:28:00,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0024
2016-05-17 22:28:00,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:28:00,366 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:28:00,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:28:00,380 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:28:00,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3BE66AC821D446190E1C237A9A701C7, ordinal: 0
2016-05-17 22:28:00,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:00,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:00,385 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3BE66AC821D446190E1C237A9A701C7, mem on start (mb), free: 105, total: 328, max: 672
2016-05-17 22:28:00,391 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3BE66AC821D446190E1C237A9A701C7, mem on close (mb), free: 105, total: 328, max: 672
2016-05-17 22:28:03,370 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:28:03,370 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:28:03,375 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F91FDF197277470AA1F06F2E45783081, ordinal: 1
2016-05-17 22:28:03,375 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:03,376 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-17 22:28:03,376 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F91FDF197277470AA1F06F2E45783081, mem on start (mb), free: 104, total: 328, max: 672
2016-05-17 22:28:03,383 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F91FDF197277470AA1F06F2E45783081, mem on close (mb), free: 103, total: 328, max: 672
2016-05-17 22:28:06,379 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2016-05-17 22:28:06,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.041
2016-05-17 22:28:06,393 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:28:06,393 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:28:06,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:28:06,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:28:06,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:28:06,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:28:06,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:06,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-17 22:28:06,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:28:06,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:28:06,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:28:06,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2016-05-17 22:28:06,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0025
2016-05-17 22:28:06,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:28:06,460 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:28:06,478 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:28:06,478 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:28:06,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF7613CD0DE3434CA1308423CFC391D3, ordinal: 0
2016-05-17 22:28:06,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:06,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:06,487 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF7613CD0DE3434CA1308423CFC391D3, mem on start (mb), free: 220, total: 328, max: 672
2016-05-17 22:28:06,492 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF7613CD0DE3434CA1308423CFC391D3, mem on close (mb), free: 219, total: 328, max: 672
2016-05-17 22:28:09,484 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:28:09,485 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:28:09,489 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D4CAE4E5B7AA44318EB0859DE1CE7C91, ordinal: 1
2016-05-17 22:28:09,490 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:09,490 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-17 22:28:09,490 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D4CAE4E5B7AA44318EB0859DE1CE7C91, mem on start (mb), free: 214, total: 328, max: 672
2016-05-17 22:28:09,497 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D4CAE4E5B7AA44318EB0859DE1CE7C91, mem on close (mb), free: 214, total: 328, max: 672
2016-05-17 22:28:12,485 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2016-05-17 22:28:12,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.059
2016-05-17 22:28:12,503 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:28:12,504 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:28:12,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:28:12,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:28:12,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:28:12,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-17 22:28:12,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:12,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-17 22:28:12,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-17 22:28:12,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-17 22:28:12,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-17 22:28:12,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2016-05-17 22:28:12,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0026
2016-05-17 22:28:12,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-17 22:28:12,560 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt
2016-05-17 22:28:12,574 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:28:12,574 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:28:12,578 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3DB7879C43049B499EE9D4D40395BEC, ordinal: 0
2016-05-17 22:28:12,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-17 22:28:12,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:12,579 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3DB7879C43049B499EE9D4D40395BEC, mem on start (mb), free: 103, total: 328, max: 672
2016-05-17 22:28:12,584 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3DB7879C43049B499EE9D4D40395BEC, mem on close (mb), free: 103, total: 328, max: 672
2016-05-17 22:28:15,564 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:28:15,564 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:28:15,567 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ADE214DC1773469E8A567B8A9B9DC1D5, ordinal: 1
2016-05-17 22:28:15,568 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-17 22:28:15,568 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-17 22:28:15,568 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADE214DC1773469E8A567B8A9B9DC1D5, mem on start (mb), free: 101, total: 328, max: 672
2016-05-17 22:28:15,573 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADE214DC1773469E8A567B8A9B9DC1D5, mem on close (mb), free: 100, total: 328, max: 672
2016-05-17 22:28:18,572 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2016-05-17 22:28:18,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:06.038
2016-05-17 22:28:18,583 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2016-05-17 22:28:18,583 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2016-05-17 22:28:18,584 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2016-05-17 22:28:18,585 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true
2016-05-17 22:28:18,585 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2016-05-17 22:28:18,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2016-05-17 22:28:18,587 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2016-05-17 22:28:18,587 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2016-05-17 22:28:18,588 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2016-05-17 22:28:18,588 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2016-05-17 22:28:18,589 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2016-05-17 22:28:18,589 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2016-05-17 22:28:18,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2016-05-17 22:28:18,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2016-05-17 22:28:18,591 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2016-05-17 22:28:18,591 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2016-05-17 22:28:18,591 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2016-05-17 22:28:18,592 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2016-05-17 22:28:18,592 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2016-05-17 22:28:18,593 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2016-05-17 22:28:18,593 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2016-05-17 22:28:18,594 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2016-05-17 22:28:18,594 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2016-05-17 22:28:18,595 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true