Class cascading.SortedValuesPlatformTest

4

tests

0

failures

0

ignored

2m52.04s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparatorValues 12.256s passed
testCoGroupComparatorValuesReversed 13.341s passed
testComprehensiveGroupBy 2m26.41s passed
testSortFails 0.038s passed

Standard output

2016-01-14 19:50:27,116 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 19:50:27,131 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop
2016-01-14 19:50:27,160 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 19:50:27,397 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 19:50:27,502 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:50:27,504 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:50:27,599 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 81D8288B8FF54E12813F553811F6C4E4
2016-01-14 19:50:27,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.207
2016-01-14 19:50:27,854 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:50:27,855 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:50:28,062 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 19:50:28,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2016-01-14 19:50:28,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2016-01-14 19:50:28,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 19:50:28,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-01-14 19:50:28,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2016-01-14 19:50:28,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2016-01-14 19:50:28,071 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2016-01-14 19:50:28,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2016-01-14 19:50:28,121 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 19:50:28,156 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 19:50:28,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local_0001
2016-01-14 19:50:28,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2016-01-14 19:50:28,466 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt
2016-01-14 19:50:28,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:28,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:28,612 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, ordinal: 0
2016-01-14 19:50:28,657 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2016-01-14 19:50:28,657 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:28,658 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, mem on start (mb), free: 85, total: 223, max: 672
2016-01-14 19:50:28,730 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, mem on close (mb), free: 84, total: 223, max: 672
2016-01-14 19:50:34,447 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt
2016-01-14 19:50:34,467 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:34,467 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:34,487 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, ordinal: 0
2016-01-14 19:50:34,489 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 19:50:34,489 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:34,489 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, mem on start (mb), free: 148, total: 386, max: 672
2016-01-14 19:50:34,494 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3FF2C4636A45E6906575213DEDF28E, mem on close (mb), free: 148, total: 386, max: 672
2016-01-14 19:50:37,468 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:50:37,469 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:50:37,480 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DC7513A3BAB748BF912E6BD5B5DCC4CA, ordinal: 1
2016-01-14 19:50:37,482 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:37,483 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-01-14 19:50:37,483 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DC7513A3BAB748BF912E6BD5B5DCC4CA, mem on start (mb), free: 299, total: 433, max: 672
2016-01-14 19:50:37,496 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 19:50:37,496 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 19:50:38,664 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DC7513A3BAB748BF912E6BD5B5DCC4CA, mem on close (mb), free: 146, total: 434, max: 672
2016-01-14 19:50:40,466 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2016-01-14 19:50:40,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:12.399
2016-01-14 19:50:40,498 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2016-01-14 19:50:40,511 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:50:40,512 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:50:40,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-01-14 19:50:40,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:50:40,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:50:40,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2016-01-14 19:50:40,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2016-01-14 19:50:40,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 19:50:40,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-01-14 19:50:40,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2016-01-14 19:50:40,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2016-01-14 19:50:40,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2016-01-14 19:50:40,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2016-01-14 19:50:40,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local_0002
2016-01-14 19:50:40,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2016-01-14 19:50:40,715 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt
2016-01-14 19:50:40,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:40,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:40,755 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, ordinal: 0
2016-01-14 19:50:40,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2016-01-14 19:50:40,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:40,757 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, mem on start (mb), free: 207, total: 434, max: 672
2016-01-14 19:50:40,804 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, mem on close (mb), free: 207, total: 434, max: 672
2016-01-14 19:50:46,721 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt
2016-01-14 19:50:46,737 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:46,737 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:46,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, ordinal: 0
2016-01-14 19:50:46,750 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 19:50:46,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:46,751 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, mem on start (mb), free: 323, total: 578, max: 672
2016-01-14 19:50:46,754 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52B41EDB2A4410EBAC9338DF77C84A0, mem on close (mb), free: 323, total: 578, max: 672
2016-01-14 19:50:49,732 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:50:49,732 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:50:49,741 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DDB66896E91348F39702197AACCC45F7, ordinal: 1
2016-01-14 19:50:49,742 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 19:50:49,742 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-01-14 19:50:49,742 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DDB66896E91348F39702197AACCC45F7, mem on start (mb), free: 530, total: 675, max: 675
2016-01-14 19:50:49,745 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 19:50:49,745 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 19:50:50,700 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DDB66896E91348F39702197AACCC45F7, mem on close (mb), free: 394, total: 674, max: 674
2016-01-14 19:50:52,734 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2016-01-14 19:50:52,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:12.081
2016-01-14 19:50:52,756 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2016-01-14 19:50:52,766 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:50:52,766 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:50:52,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.023
2016-01-14 19:50:52,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 19:50:52,803 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:50:52,803 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:50:52,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 19:50:52,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:50:52,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:50:52,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:50:52,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:50:52,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-01-14 19:50:52,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:50:52,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:50:52,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:50:52,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2016-01-14 19:50:52,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0003
2016-01-14 19:50:52,914 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:50:52,918 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:50:52,943 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:52,944 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:52,951 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F246C844823A4F81BDFB40EE12DE681F, ordinal: 0
2016-01-14 19:50:52,952 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:50:52,953 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:50:52,953 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F246C844823A4F81BDFB40EE12DE681F, mem on start (mb), free: 449, total: 675, max: 675
2016-01-14 19:50:52,958 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F246C844823A4F81BDFB40EE12DE681F, mem on close (mb), free: 449, total: 675, max: 675
2016-01-14 19:50:55,922 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:50:55,922 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:50:55,929 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B65DEFDFE94B464F9AF63D05C1767DFF, ordinal: 1
2016-01-14 19:50:55,930 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:50:55,930 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-01-14 19:50:55,931 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B65DEFDFE94B464F9AF63D05C1767DFF, mem on start (mb), free: 446, total: 675, max: 675
2016-01-14 19:50:55,938 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B65DEFDFE94B464F9AF63D05C1767DFF, mem on close (mb), free: 445, total: 675, max: 675
2016-01-14 19:50:58,925 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2016-01-14 19:50:58,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.057
2016-01-14 19:50:58,940 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:50:58,940 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:50:58,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 19:50:58,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:50:58,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:50:59,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:50:59,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:50:59,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-01-14 19:50:59,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:50:59,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:50:59,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:50:59,005 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2016-01-14 19:50:59,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0004
2016-01-14 19:50:59,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:50:59,039 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:50:59,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:50:59,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:50:59,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B8424872F2FA4F268EE3339D38F02876, ordinal: 0
2016-01-14 19:50:59,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:50:59,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:50:59,068 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8424872F2FA4F268EE3339D38F02876, mem on start (mb), free: 457, total: 672, max: 672
2016-01-14 19:50:59,074 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8424872F2FA4F268EE3339D38F02876, mem on close (mb), free: 457, total: 672, max: 672
2016-01-14 19:51:02,043 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:02,043 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:02,049 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1E7EE36F34F4CE28AB8257DF13065AB, ordinal: 1
2016-01-14 19:51:02,050 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:02,050 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-01-14 19:51:02,050 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1E7EE36F34F4CE28AB8257DF13065AB, mem on start (mb), free: 578, total: 735, max: 735
2016-01-14 19:51:02,058 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1E7EE36F34F4CE28AB8257DF13065AB, mem on close (mb), free: 576, total: 735, max: 735
2016-01-14 19:51:05,052 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2016-01-14 19:51:05,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.051
2016-01-14 19:51:05,066 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:05,066 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:05,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 19:51:05,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:05,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:05,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:05,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:05,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-01-14 19:51:05,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:05,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:05,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:05,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2016-01-14 19:51:05,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0005
2016-01-14 19:51:05,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:05,157 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:05,171 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:05,171 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:05,181 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFDB0B35291D49DAA417E4600C8AB544, ordinal: 0
2016-01-14 19:51:05,182 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:05,183 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:05,183 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFDB0B35291D49DAA417E4600C8AB544, mem on start (mb), free: 461, total: 735, max: 735
2016-01-14 19:51:05,189 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFDB0B35291D49DAA417E4600C8AB544, mem on close (mb), free: 461, total: 735, max: 735
2016-01-14 19:51:08,161 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:08,161 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:08,167 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FE332B203DDC443CA82E0C51679EC360, ordinal: 1
2016-01-14 19:51:08,168 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:08,168 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-01-14 19:51:08,168 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE332B203DDC443CA82E0C51679EC360, mem on start (mb), free: 460, total: 735, max: 735
2016-01-14 19:51:08,174 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE332B203DDC443CA82E0C51679EC360, mem on close (mb), free: 458, total: 735, max: 735
2016-01-14 19:51:11,166 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2016-01-14 19:51:11,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.041
2016-01-14 19:51:11,180 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:11,180 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:11,226 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 19:51:11,227 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:11,227 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:11,243 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:11,243 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:11,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-01-14 19:51:11,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:11,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:11,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:11,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2016-01-14 19:51:11,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0006
2016-01-14 19:51:11,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:11,276 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:11,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:11,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:11,303 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3C997345F9B4400A98736BDB7E22DFE, ordinal: 0
2016-01-14 19:51:11,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:11,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:11,304 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3C997345F9B4400A98736BDB7E22DFE, mem on start (mb), free: 516, total: 733, max: 733
2016-01-14 19:51:11,309 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3C997345F9B4400A98736BDB7E22DFE, mem on close (mb), free: 516, total: 733, max: 733
2016-01-14 19:51:14,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:14,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:14,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C4E2CF9C5DB94AB5B6B99A5227FD86BB, ordinal: 1
2016-01-14 19:51:14,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:14,288 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-01-14 19:51:14,288 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C4E2CF9C5DB94AB5B6B99A5227FD86BB, mem on start (mb), free: 576, total: 734, max: 734
2016-01-14 19:51:14,294 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C4E2CF9C5DB94AB5B6B99A5227FD86BB, mem on close (mb), free: 575, total: 734, max: 734
2016-01-14 19:51:17,283 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2016-01-14 19:51:17,284 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.040
2016-01-14 19:51:17,297 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:17,298 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:17,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 19:51:17,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:17,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:17,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:17,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:17,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-01-14 19:51:17,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:17,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:17,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:17,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2016-01-14 19:51:17,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0007
2016-01-14 19:51:17,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:17,408 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:17,424 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:17,424 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:17,431 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB27B1FD42DF44D8AB87EFAEE0335CC0, ordinal: 0
2016-01-14 19:51:17,432 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:17,432 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:17,432 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB27B1FD42DF44D8AB87EFAEE0335CC0, mem on start (mb), free: 461, total: 734, max: 734
2016-01-14 19:51:17,437 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB27B1FD42DF44D8AB87EFAEE0335CC0, mem on close (mb), free: 461, total: 734, max: 734
2016-01-14 19:51:20,412 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:20,412 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:20,418 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FCEBDCF991AA430DA1A4E8962EF5A419, ordinal: 1
2016-01-14 19:51:20,419 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:20,419 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-01-14 19:51:20,419 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCEBDCF991AA430DA1A4E8962EF5A419, mem on start (mb), free: 460, total: 734, max: 734
2016-01-14 19:51:20,426 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCEBDCF991AA430DA1A4E8962EF5A419, mem on close (mb), free: 458, total: 734, max: 734
2016-01-14 19:51:23,414 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2016-01-14 19:51:23,415 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.044
2016-01-14 19:51:23,428 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:23,428 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:23,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 19:51:23,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:23,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:23,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:23,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:23,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-01-14 19:51:23,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:23,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:23,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:23,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2016-01-14 19:51:23,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0008
2016-01-14 19:51:23,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:23,511 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:23,557 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:23,557 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:23,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D0A09344EAF84D549BFA6C5A8FA0A08D, ordinal: 0
2016-01-14 19:51:23,564 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:23,564 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:23,564 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0A09344EAF84D549BFA6C5A8FA0A08D, mem on start (mb), free: 616, total: 725, max: 725
2016-01-14 19:51:23,568 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0A09344EAF84D549BFA6C5A8FA0A08D, mem on close (mb), free: 616, total: 725, max: 725
2016-01-14 19:51:26,515 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:26,515 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:26,521 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A5AC927202724F9DB4AC14454FAF25BC, ordinal: 1
2016-01-14 19:51:26,522 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:26,522 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-01-14 19:51:26,522 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A5AC927202724F9DB4AC14454FAF25BC, mem on start (mb), free: 487, total: 734, max: 734
2016-01-14 19:51:26,529 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A5AC927202724F9DB4AC14454FAF25BC, mem on close (mb), free: 486, total: 734, max: 734
2016-01-14 19:51:29,519 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2016-01-14 19:51:29,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.040
2016-01-14 19:51:29,532 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:29,532 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:29,563 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 19:51:29,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:29,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:29,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-01-14 19:51:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:29,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2016-01-14 19:51:29,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0009
2016-01-14 19:51:29,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:29,612 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:29,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:29,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:29,672 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7B5F26B4F414252BA643162460FD6CF, ordinal: 0
2016-01-14 19:51:29,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:29,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:29,673 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7B5F26B4F414252BA643162460FD6CF, mem on start (mb), free: 618, total: 733, max: 733
2016-01-14 19:51:29,678 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7B5F26B4F414252BA643162460FD6CF, mem on close (mb), free: 618, total: 733, max: 733
2016-01-14 19:51:32,616 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:32,616 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:32,622 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EEDD8C4B7C4E4BA481DCE8BDC0FF678D, ordinal: 1
2016-01-14 19:51:32,622 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:32,622 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-01-14 19:51:32,623 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EEDD8C4B7C4E4BA481DCE8BDC0FF678D, mem on start (mb), free: 410, total: 734, max: 734
2016-01-14 19:51:32,629 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EEDD8C4B7C4E4BA481DCE8BDC0FF678D, mem on close (mb), free: 410, total: 734, max: 734
2016-01-14 19:51:35,625 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2016-01-14 19:51:35,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.046
2016-01-14 19:51:35,637 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:35,638 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:35,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 19:51:35,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:35,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:35,696 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:35,696 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:35,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-01-14 19:51:35,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:35,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:35,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:35,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2016-01-14 19:51:35,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0010
2016-01-14 19:51:35,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:35,757 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:35,771 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:35,771 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:35,777 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AD0C2B477E8845E0AB23AEDFF1CC34D5, ordinal: 0
2016-01-14 19:51:35,777 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:35,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:35,778 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD0C2B477E8845E0AB23AEDFF1CC34D5, mem on start (mb), free: 611, total: 735, max: 735
2016-01-14 19:51:35,782 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD0C2B477E8845E0AB23AEDFF1CC34D5, mem on close (mb), free: 611, total: 735, max: 735
2016-01-14 19:51:38,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:38,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:38,767 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FEDB53F9D9D94382A4924011C42B495F, ordinal: 1
2016-01-14 19:51:38,767 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:38,767 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-01-14 19:51:38,768 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FEDB53F9D9D94382A4924011C42B495F, mem on start (mb), free: 586, total: 735, max: 735
2016-01-14 19:51:38,774 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FEDB53F9D9D94382A4924011C42B495F, mem on close (mb), free: 586, total: 735, max: 735
2016-01-14 19:51:41,764 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2016-01-14 19:51:41,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.068
2016-01-14 19:51:41,776 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:41,777 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:41,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 19:51:41,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:41,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:41,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:41,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:41,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-01-14 19:51:41,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:41,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:41,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:41,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2016-01-14 19:51:41,846 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0011
2016-01-14 19:51:41,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:41,850 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:41,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:41,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:41,872 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8E04FDFB4EE41D682CECD8F2F195027, ordinal: 0
2016-01-14 19:51:41,872 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:41,872 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:41,873 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8E04FDFB4EE41D682CECD8F2F195027, mem on start (mb), free: 471, total: 735, max: 735
2016-01-14 19:51:41,877 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8E04FDFB4EE41D682CECD8F2F195027, mem on close (mb), free: 471, total: 735, max: 735
2016-01-14 19:51:44,854 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:44,854 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:44,860 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CEBC00FDA5974D2996E8BE59620E927F, ordinal: 1
2016-01-14 19:51:44,861 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:44,861 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-01-14 19:51:44,862 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEBC00FDA5974D2996E8BE59620E927F, mem on start (mb), free: 470, total: 735, max: 735
2016-01-14 19:51:44,869 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEBC00FDA5974D2996E8BE59620E927F, mem on close (mb), free: 468, total: 735, max: 735
2016-01-14 19:51:47,860 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2016-01-14 19:51:47,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.041
2016-01-14 19:51:47,873 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:47,873 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:47,911 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 19:51:47,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:47,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:47,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:47,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-01-14 19:51:47,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:47,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:47,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:47,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2016-01-14 19:51:47,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0012
2016-01-14 19:51:47,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:47,950 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:47,998 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:47,998 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:48,003 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A93D516D3A8F46999FC4F42C45DE306A, ordinal: 0
2016-01-14 19:51:48,004 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:48,004 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:48,004 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A93D516D3A8F46999FC4F42C45DE306A, mem on start (mb), free: 624, total: 734, max: 734
2016-01-14 19:51:48,009 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A93D516D3A8F46999FC4F42C45DE306A, mem on close (mb), free: 624, total: 734, max: 734
2016-01-14 19:51:50,955 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:50,955 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:50,961 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CC4C0DEF9B47468AB354EDDA19BEB0FA, ordinal: 1
2016-01-14 19:51:50,961 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:50,961 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-01-14 19:51:50,962 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CC4C0DEF9B47468AB354EDDA19BEB0FA, mem on start (mb), free: 490, total: 735, max: 735
2016-01-14 19:51:50,969 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CC4C0DEF9B47468AB354EDDA19BEB0FA, mem on close (mb), free: 490, total: 735, max: 735
2016-01-14 19:51:53,957 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2016-01-14 19:51:53,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.033
2016-01-14 19:51:53,969 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:51:53,969 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:51:53,998 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 19:51:53,998 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:51:53,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:51:54,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:51:54,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:54,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-01-14 19:51:54,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:51:54,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:51:54,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:51:54,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2016-01-14 19:51:54,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0013
2016-01-14 19:51:54,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:51:54,044 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:51:54,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:51:54,114 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:51:54,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BBD7C11442E54FDFA752F741D8B14D5A, ordinal: 0
2016-01-14 19:51:54,123 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:51:54,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:54,124 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBD7C11442E54FDFA752F741D8B14D5A, mem on start (mb), free: 618, total: 734, max: 734
2016-01-14 19:51:54,130 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBD7C11442E54FDFA752F741D8B14D5A, mem on close (mb), free: 618, total: 734, max: 734
2016-01-14 19:51:57,050 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:51:57,051 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:51:57,059 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DAA5FC2280CC47CCAA1411700B269839, ordinal: 1
2016-01-14 19:51:57,060 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:51:57,061 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-01-14 19:51:57,061 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DAA5FC2280CC47CCAA1411700B269839, mem on start (mb), free: 421, total: 734, max: 734
2016-01-14 19:51:57,070 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DAA5FC2280CC47CCAA1411700B269839, mem on close (mb), free: 421, total: 734, max: 734
2016-01-14 19:52:00,052 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2016-01-14 19:52:00,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.040
2016-01-14 19:52:00,066 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:00,066 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:00,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 19:52:00,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:00,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:00,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:00,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:00,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-01-14 19:52:00,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:00,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:00,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:00,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2016-01-14 19:52:00,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0014
2016-01-14 19:52:00,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:00,176 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:00,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:00,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:00,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABE37ACC1DBB4BDE9DFE112FB92A6196, ordinal: 0
2016-01-14 19:52:00,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:00,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:00,199 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE37ACC1DBB4BDE9DFE112FB92A6196, mem on start (mb), free: 613, total: 735, max: 735
2016-01-14 19:52:00,204 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE37ACC1DBB4BDE9DFE112FB92A6196, mem on close (mb), free: 613, total: 735, max: 735
2016-01-14 19:52:03,179 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:03,179 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:03,184 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B7FA5A806A95461CB8808A5BA9D4A838, ordinal: 1
2016-01-14 19:52:03,184 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:03,185 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-01-14 19:52:03,185 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B7FA5A806A95461CB8808A5BA9D4A838, mem on start (mb), free: 588, total: 735, max: 735
2016-01-14 19:52:03,191 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B7FA5A806A95461CB8808A5BA9D4A838, mem on close (mb), free: 588, total: 735, max: 735
2016-01-14 19:52:06,180 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2016-01-14 19:52:06,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.069
2016-01-14 19:52:06,191 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:06,191 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:06,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 19:52:06,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:06,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:06,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:06,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:06,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-01-14 19:52:06,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:06,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:06,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:06,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2016-01-14 19:52:06,259 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0015
2016-01-14 19:52:06,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:06,263 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:06,277 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:06,277 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:06,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDCCB116519248199727D2480D76AF63, ordinal: 0
2016-01-14 19:52:06,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:06,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:06,283 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDCCB116519248199727D2480D76AF63, mem on start (mb), free: 476, total: 735, max: 735
2016-01-14 19:52:06,287 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDCCB116519248199727D2480D76AF63, mem on close (mb), free: 476, total: 735, max: 735
2016-01-14 19:52:09,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:09,267 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:09,271 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DFF553087AE04076838EA7B8D878C082, ordinal: 1
2016-01-14 19:52:09,272 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:09,272 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-01-14 19:52:09,272 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFF553087AE04076838EA7B8D878C082, mem on start (mb), free: 474, total: 735, max: 735
2016-01-14 19:52:09,279 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFF553087AE04076838EA7B8D878C082, mem on close (mb), free: 473, total: 735, max: 735
2016-01-14 19:52:12,270 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2016-01-14 19:52:12,271 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.034
2016-01-14 19:52:12,281 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:12,281 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:12,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 19:52:12,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:12,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:12,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:12,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:12,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-01-14 19:52:12,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:12,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:12,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:12,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2016-01-14 19:52:12,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0016
2016-01-14 19:52:12,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:12,340 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:12,387 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:12,388 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:12,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B28626F6A53544618D5AB2F27DB1C118, ordinal: 0
2016-01-14 19:52:12,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:12,395 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:12,395 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B28626F6A53544618D5AB2F27DB1C118, mem on start (mb), free: 625, total: 734, max: 734
2016-01-14 19:52:12,400 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B28626F6A53544618D5AB2F27DB1C118, mem on close (mb), free: 625, total: 734, max: 734
2016-01-14 19:52:15,344 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:15,345 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:15,351 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D59FF382F4E9435D92314B1BF4840656, ordinal: 1
2016-01-14 19:52:15,352 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:15,352 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-01-14 19:52:15,353 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D59FF382F4E9435D92314B1BF4840656, mem on start (mb), free: 623, total: 734, max: 734
2016-01-14 19:52:15,361 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D59FF382F4E9435D92314B1BF4840656, mem on close (mb), free: 623, total: 734, max: 734
2016-01-14 19:52:18,352 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2016-01-14 19:52:18,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.035
2016-01-14 19:52:18,363 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:18,364 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:18,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 19:52:18,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:18,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:18,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:18,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2016-01-14 19:52:18,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0017
2016-01-14 19:52:18,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:18,422 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:18,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:18,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:18,515 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5E253AB0325497AA725E1E846EE727C, ordinal: 0
2016-01-14 19:52:18,515 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:18,516 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:18,516 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5E253AB0325497AA725E1E846EE727C, mem on start (mb), free: 629, total: 735, max: 735
2016-01-14 19:52:18,519 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5E253AB0325497AA725E1E846EE727C, mem on close (mb), free: 629, total: 735, max: 735
2016-01-14 19:52:21,425 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:21,426 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:21,431 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C28D9A90C091453CBBE25D5476753154, ordinal: 1
2016-01-14 19:52:21,431 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:21,431 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-01-14 19:52:21,431 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C28D9A90C091453CBBE25D5476753154, mem on start (mb), free: 627, total: 735, max: 735
2016-01-14 19:52:21,437 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C28D9A90C091453CBBE25D5476753154, mem on close (mb), free: 626, total: 735, max: 735
2016-01-14 19:52:24,429 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2016-01-14 19:52:24,430 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.028
2016-01-14 19:52:24,440 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:24,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:24,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 19:52:24,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:24,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:24,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:24,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:24,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-01-14 19:52:24,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:24,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:24,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:24,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2016-01-14 19:52:24,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0018
2016-01-14 19:52:24,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:24,499 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:24,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:24,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:24,519 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD4D94A6FA2F4E93A0391497751E4850, ordinal: 0
2016-01-14 19:52:24,520 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:24,520 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:24,520 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD4D94A6FA2F4E93A0391497751E4850, mem on start (mb), free: 516, total: 735, max: 735
2016-01-14 19:52:24,527 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD4D94A6FA2F4E93A0391497751E4850, mem on close (mb), free: 516, total: 735, max: 735
2016-01-14 19:52:27,503 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:27,503 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:27,508 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AFD270202E794712BE37AACF60C6A594, ordinal: 1
2016-01-14 19:52:27,508 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:27,509 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-01-14 19:52:27,509 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AFD270202E794712BE37AACF60C6A594, mem on start (mb), free: 514, total: 735, max: 735
2016-01-14 19:52:27,514 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AFD270202E794712BE37AACF60C6A594, mem on close (mb), free: 514, total: 735, max: 735
2016-01-14 19:52:30,512 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2016-01-14 19:52:30,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.036
2016-01-14 19:52:30,523 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:30,523 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:30,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 19:52:30,550 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:30,550 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:30,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:30,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:30,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-01-14 19:52:30,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:30,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:30,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:30,562 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2016-01-14 19:52:30,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0019
2016-01-14 19:52:30,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:30,586 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:30,639 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:30,640 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:30,647 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAF83250D0314C1E9368ED15AD3B41C9, ordinal: 0
2016-01-14 19:52:30,648 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:30,648 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:30,648 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAF83250D0314C1E9368ED15AD3B41C9, mem on start (mb), free: 628, total: 734, max: 734
2016-01-14 19:52:30,654 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAF83250D0314C1E9368ED15AD3B41C9, mem on close (mb), free: 628, total: 734, max: 734
2016-01-14 19:52:33,589 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:33,589 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:33,594 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C8A3EEC1EDFB4F929D3D714AEFF685A5, ordinal: 1
2016-01-14 19:52:33,595 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:33,595 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-01-14 19:52:33,596 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C8A3EEC1EDFB4F929D3D714AEFF685A5, mem on start (mb), free: 626, total: 734, max: 734
2016-01-14 19:52:33,604 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C8A3EEC1EDFB4F929D3D714AEFF685A5, mem on close (mb), free: 626, total: 734, max: 734
2016-01-14 19:52:36,594 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2016-01-14 19:52:36,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.034
2016-01-14 19:52:36,604 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:36,604 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:36,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 19:52:36,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:36,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:36,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:36,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:36,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-01-14 19:52:36,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:36,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:36,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:36,649 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2016-01-14 19:52:36,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0020
2016-01-14 19:52:36,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:36,670 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:36,777 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:36,777 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:36,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D913F0D67899434C84EAB025CA771666, ordinal: 0
2016-01-14 19:52:36,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:36,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:36,783 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D913F0D67899434C84EAB025CA771666, mem on start (mb), free: 629, total: 734, max: 734
2016-01-14 19:52:36,788 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D913F0D67899434C84EAB025CA771666, mem on close (mb), free: 629, total: 734, max: 734
2016-01-14 19:52:39,673 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:39,673 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:39,677 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B38BB8CF29A54B84A9384D405E11992E, ordinal: 1
2016-01-14 19:52:39,677 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:39,677 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-01-14 19:52:39,678 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B38BB8CF29A54B84A9384D405E11992E, mem on start (mb), free: 627, total: 734, max: 734
2016-01-14 19:52:39,683 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B38BB8CF29A54B84A9384D405E11992E, mem on close (mb), free: 626, total: 734, max: 734
2016-01-14 19:52:42,683 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2016-01-14 19:52:42,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.038
2016-01-14 19:52:42,693 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:42,693 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:42,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 19:52:42,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:42,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:42,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:42,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:42,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-01-14 19:52:42,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:42,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:42,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:42,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2016-01-14 19:52:42,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0021
2016-01-14 19:52:42,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:42,753 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:42,768 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:42,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:42,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABFAC3C1CF23404FBF313E4EF731D024, ordinal: 0
2016-01-14 19:52:42,776 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:42,776 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:42,776 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABFAC3C1CF23404FBF313E4EF731D024, mem on start (mb), free: 516, total: 734, max: 734
2016-01-14 19:52:42,780 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABFAC3C1CF23404FBF313E4EF731D024, mem on close (mb), free: 516, total: 734, max: 734
2016-01-14 19:52:45,756 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:45,757 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:45,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E0E52D2E958C4CBDA19BBD601708125B, ordinal: 1
2016-01-14 19:52:45,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:45,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-01-14 19:52:45,762 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0E52D2E958C4CBDA19BBD601708125B, mem on start (mb), free: 514, total: 734, max: 734
2016-01-14 19:52:45,767 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0E52D2E958C4CBDA19BBD601708125B, mem on close (mb), free: 514, total: 734, max: 734
2016-01-14 19:52:48,759 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2016-01-14 19:52:48,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.031
2016-01-14 19:52:48,769 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:48,769 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:48,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 19:52:48,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:48,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:48,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:48,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:48,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-01-14 19:52:48,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:48,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:48,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:48,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2016-01-14 19:52:48,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0022
2016-01-14 19:52:48,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:48,830 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:48,878 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:48,878 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:48,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C068B452F2044C5584DD68A08D32B188, ordinal: 0
2016-01-14 19:52:48,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:48,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:48,883 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C068B452F2044C5584DD68A08D32B188, mem on start (mb), free: 629, total: 735, max: 735
2016-01-14 19:52:48,886 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C068B452F2044C5584DD68A08D32B188, mem on close (mb), free: 629, total: 735, max: 735
2016-01-14 19:52:51,833 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:51,834 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:51,838 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB8666E6AF494D97A586B99721FE0730, ordinal: 1
2016-01-14 19:52:51,838 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:51,838 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-01-14 19:52:51,838 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB8666E6AF494D97A586B99721FE0730, mem on start (mb), free: 627, total: 735, max: 735
2016-01-14 19:52:51,843 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB8666E6AF494D97A586B99721FE0730, mem on close (mb), free: 627, total: 735, max: 735
2016-01-14 19:52:54,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2016-01-14 19:52:54,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.034
2016-01-14 19:52:54,846 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:52:54,847 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:52:54,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 19:52:54,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:52:54,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:52:54,882 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:52:54,883 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:54,883 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-01-14 19:52:54,883 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:52:54,883 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:52:54,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:52:54,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2016-01-14 19:52:54,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0023
2016-01-14 19:52:54,903 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:52:54,906 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:52:55,002 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:52:55,002 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:52:55,006 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA307A375535440BA8FC8960C297A831, ordinal: 0
2016-01-14 19:52:55,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:52:55,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:55,007 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA307A375535440BA8FC8960C297A831, mem on start (mb), free: 630, total: 735, max: 735
2016-01-14 19:52:55,010 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA307A375535440BA8FC8960C297A831, mem on close (mb), free: 630, total: 735, max: 735
2016-01-14 19:52:57,909 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:52:57,909 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:52:57,913 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E0D90284A9F147C29A02C833B526B2D7, ordinal: 1
2016-01-14 19:52:57,914 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:52:57,914 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-01-14 19:52:57,914 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0D90284A9F147C29A02C833B526B2D7, mem on start (mb), free: 628, total: 735, max: 735
2016-01-14 19:52:57,919 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0D90284A9F147C29A02C833B526B2D7, mem on close (mb), free: 627, total: 735, max: 735
2016-01-14 19:53:00,913 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2016-01-14 19:53:00,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.030
2016-01-14 19:53:00,923 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:53:00,923 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:53:00,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 19:53:00,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:53:00,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:53:00,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:53:00,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:00,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-01-14 19:53:00,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:53:00,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:53:00,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:53:00,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2016-01-14 19:53:00,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0024
2016-01-14 19:53:00,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:53:00,986 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:53:01,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:53:01,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:53:01,006 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C64AB6351EA848819BB6AFE4F74D6EDF, ordinal: 0
2016-01-14 19:53:01,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:01,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:01,007 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C64AB6351EA848819BB6AFE4F74D6EDF, mem on start (mb), free: 517, total: 735, max: 735
2016-01-14 19:53:01,012 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C64AB6351EA848819BB6AFE4F74D6EDF, mem on close (mb), free: 517, total: 735, max: 735
2016-01-14 19:53:03,989 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:53:03,990 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:53:03,994 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E6963258C37F40EEA3BBE5B6B4970CEF, ordinal: 1
2016-01-14 19:53:03,995 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:03,995 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-01-14 19:53:03,995 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6963258C37F40EEA3BBE5B6B4970CEF, mem on start (mb), free: 515, total: 735, max: 735
2016-01-14 19:53:04,001 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6963258C37F40EEA3BBE5B6B4970CEF, mem on close (mb), free: 514, total: 735, max: 735
2016-01-14 19:53:06,997 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2016-01-14 19:53:06,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.040
2016-01-14 19:53:07,007 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:53:07,007 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:53:07,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 19:53:07,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:53:07,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:53:07,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:53:07,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-01-14 19:53:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:53:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:53:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:53:07,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2016-01-14 19:53:07,063 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0025
2016-01-14 19:53:07,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:53:07,069 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:53:07,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:53:07,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:53:07,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC20ED3243BB43A493B3522706BE9389, ordinal: 0
2016-01-14 19:53:07,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:07,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:07,121 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC20ED3243BB43A493B3522706BE9389, mem on start (mb), free: 629, total: 735, max: 735
2016-01-14 19:53:07,125 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC20ED3243BB43A493B3522706BE9389, mem on close (mb), free: 629, total: 735, max: 735
2016-01-14 19:53:10,110 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:53:10,110 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:53:10,115 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D083BDEF8A8F4A88A60277DA96B30838, ordinal: 1
2016-01-14 19:53:10,115 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:10,115 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-01-14 19:53:10,116 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D083BDEF8A8F4A88A60277DA96B30838, mem on start (mb), free: 627, total: 735, max: 735
2016-01-14 19:53:10,121 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D083BDEF8A8F4A88A60277DA96B30838, mem on close (mb), free: 626, total: 735, max: 735
2016-01-14 19:53:13,119 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2016-01-14 19:53:13,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.077
2016-01-14 19:53:13,128 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:53:13,129 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 19:53:13,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 19:53:13,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:53:13,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:53:13,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 19:53:13,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:13,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-01-14 19:53:13,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2016-01-14 19:53:13,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2016-01-14 19:53:13,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2016-01-14 19:53:13,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2016-01-14 19:53:13,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local_0026
2016-01-14 19:53:13,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 19:53:13,181 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 19:53:13,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 19:53:13,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 19:53:13,292 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3E3B0B869B647758C5FF2C973F31CA1, ordinal: 0
2016-01-14 19:53:13,294 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 19:53:13,294 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:13,295 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3E3B0B869B647758C5FF2C973F31CA1, mem on start (mb), free: 630, total: 735, max: 735
2016-01-14 19:53:13,301 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3E3B0B869B647758C5FF2C973F31CA1, mem on close (mb), free: 630, total: 735, max: 735
2016-01-14 19:53:16,185 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 19:53:16,185 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 19:53:16,189 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A8CD5BAC3F764AA1A9B9DE06FCEDCC9B, ordinal: 1
2016-01-14 19:53:16,190 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 19:53:16,190 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-01-14 19:53:16,190 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8CD5BAC3F764AA1A9B9DE06FCEDCC9B, mem on start (mb), free: 628, total: 735, max: 735
2016-01-14 19:53:16,195 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8CD5BAC3F764AA1A9B9DE06FCEDCC9B, mem on close (mb), free: 627, total: 735, max: 735
2016-01-14 19:53:19,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2016-01-14 19:53:19,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:06.028
2016-01-14 19:53:19,194 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true
2016-01-14 19:53:19,194 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2016-01-14 19:53:19,194 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2016-01-14 19:53:19,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2016-01-14 19:53:19,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2016-01-14 19:53:19,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2016-01-14 19:53:19,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2016-01-14 19:53:19,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2016-01-14 19:53:19,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2016-01-14 19:53:19,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2016-01-14 19:53:19,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2016-01-14 19:53:19,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2016-01-14 19:53:19,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2016-01-14 19:53:19,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2016-01-14 19:53:19,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2016-01-14 19:53:19,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2016-01-14 19:53:19,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2016-01-14 19:53:19,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2016-01-14 19:53:19,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2016-01-14 19:53:19,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2016-01-14 19:53:19,199 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2016-01-14 19:53:19,199 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2016-01-14 19:53:19,199 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2016-01-14 19:53:19,199 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false