Class cascading.SortedValuesPlatformTest

4

tests

0

failures

0

ignored

1m31.74s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparatorValues 23.058s passed
testCoGroupComparatorValuesReversed 40.461s passed
testComprehensiveGroupBy 28.177s passed
testSortFails 0.047s passed

Standard output

2015-09-24 12:59:30,780 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 12:59:30,830 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop2-mr1
2015-09-24 12:59:30,859 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-09-24 12:59:42,571 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-09-24 12:59:42,708 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-09-24 12:59:42,866 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:59:42,870 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 12:59:42,988 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5EF99BABA8BA456B819A1BB0772A3ED5
2015-09-24 12:59:43,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.219
2015-09-24 12:59:43,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 12:59:43,279 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'
2015-09-24 12:59:43,498 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 12:59:43,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2015-09-24 12:59:43,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt"]
2015-09-24 12:59:43,501 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-09-24 12:59:43,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2015-09-24 12:59:43,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2015-09-24 12:59:43,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2015-09-24 12:59:43,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2015-09-24 12:59:43,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2015-09-24 12:59:44,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local747371559_0001
2015-09-24 12:59:44,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2015-09-24 12:59:44,265 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt
2015-09-24 12:59:44,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 12:59:44,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 12:59:44,417 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, ordinal: 0
2015-09-24 12:59:44,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt"]
2015-09-24 12:59:44,465 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 12:59:44,466 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, mem on start (mb), free: 82, total: 223, max: 672
2015-09-24 12:59:44,532 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, mem on close (mb), free: 81, total: 223, max: 672
2015-09-24 13:00:04,979 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt
2015-09-24 13:00:05,004 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:05,004 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:05,025 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, ordinal: 0
2015-09-24 13:00:05,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-09-24 13:00:05,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 13:00:05,027 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, mem on start (mb), free: 191, total: 425, max: 672
2015-09-24 13:00:05,032 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F12430E848EE48ED89AB1F3869EEBB0A, mem on close (mb), free: 191, total: 425, max: 672
2015-09-24 13:00:11,155 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:11,156 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:11,170 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B3D9BE5310024B8AAE73972ABDB4AD2C, ordinal: 1
2015-09-24 13:00:11,173 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 13:00:11,173 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2015-09-24 13:00:11,173 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B3D9BE5310024B8AAE73972ABDB4AD2C, mem on start (mb), free: 191, total: 404, max: 672
2015-09-24 13:00:11,190 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-09-24 13:00:11,191 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-09-24 13:00:11,226 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B3D9BE5310024B8AAE73972ABDB4AD2C, mem on close (mb), free: 185, total: 404, max: 672
2015-09-24 13:00:11,259 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2015-09-24 13:00:11,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:27.759
2015-09-24 13:00:11,317 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2015-09-24 13:00:11,343 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:11,344 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:11,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.114
2015-09-24 13:00:11,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:11,471 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'
2015-09-24 13:00:11,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2015-09-24 13:00:11,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt"]
2015-09-24 13:00:11,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-09-24 13:00:11,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2015-09-24 13:00:11,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2015-09-24 13:00:11,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2015-09-24 13:00:11,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2015-09-24 13:00:11,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2015-09-24 13:00:11,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local1997776080_0002
2015-09-24 13:00:11,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2015-09-24 13:00:11,682 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt
2015-09-24 13:00:11,704 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:11,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:11,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, ordinal: 0
2015-09-24 13:00:11,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.200.txt"]
2015-09-24 13:00:11,721 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 13:00:11,721 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, mem on start (mb), free: 172, total: 397, max: 672
2015-09-24 13:00:11,754 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, mem on close (mb), free: 172, total: 397, max: 672
2015-09-24 13:00:28,713 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt
2015-09-24 13:00:28,736 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:28,736 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:28,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, ordinal: 0
2015-09-24 13:00:28,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-09-24 13:00:28,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 13:00:28,748 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, mem on start (mb), free: 170, total: 403, max: 672
2015-09-24 13:00:28,751 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E27F62CA642C4FA397DE604A5000AD0F, mem on close (mb), free: 170, total: 403, max: 672
2015-09-24 13:00:34,241 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:34,242 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:34,255 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9A3E859C92A4BDC9385687142DCFD9A, ordinal: 1
2015-09-24 13:00:34,256 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-09-24 13:00:34,256 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2015-09-24 13:00:34,256 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9A3E859C92A4BDC9385687142DCFD9A, mem on start (mb), free: 255, total: 396, max: 672
2015-09-24 13:00:34,264 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-09-24 13:00:34,264 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-09-24 13:00:34,290 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9A3E859C92A4BDC9385687142DCFD9A, mem on close (mb), free: 253, total: 396, max: 672
2015-09-24 13:00:34,321 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2015-09-24 13:00:34,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:22.804
2015-09-24 13:00:34,377 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2015-09-24 13:00:34,399 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:34,400 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:34,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.018
2015-09-24 13:00:34,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-09-24 13:00:34,441 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:34,442 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:34,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-09-24 13:00:34,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:34,493 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'
2015-09-24 13:00:34,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:34,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:34,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2015-09-24 13:00:34,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:34,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:34,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:34,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2015-09-24 13:00:34,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local960779059_0003
2015-09-24 13:00:34,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:34,686 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:34,701 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:34,701 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:34,708 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BD383BA1FCA14BC1874F9AAB8EC9E2E2, ordinal: 0
2015-09-24 13:00:34,709 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:34,709 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:34,709 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD383BA1FCA14BC1874F9AAB8EC9E2E2, mem on start (mb), free: 59, total: 396, max: 672
2015-09-24 13:00:34,714 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD383BA1FCA14BC1874F9AAB8EC9E2E2, mem on close (mb), free: 59, total: 396, max: 672
2015-09-24 13:00:34,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:34,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:34,736 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A88C0A83B4F54D64BFAFFA55641BC6BA, ordinal: 1
2015-09-24 13:00:34,737 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:34,737 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2015-09-24 13:00:34,737 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A88C0A83B4F54D64BFAFFA55641BC6BA, mem on start (mb), free: 43, total: 396, max: 672
2015-09-24 13:00:34,754 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A88C0A83B4F54D64BFAFFA55641BC6BA, mem on close (mb), free: 275, total: 393, max: 672
2015-09-24 13:00:34,779 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2015-09-24 13:00:34,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.262
2015-09-24 13:00:34,836 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:34,837 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:34,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2015-09-24 13:00:34,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:34,902 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'
2015-09-24 13:00:34,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:34,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:34,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2015-09-24 13:00:34,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:34,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:34,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:34,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2015-09-24 13:00:35,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local125208095_0004
2015-09-24 13:00:35,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:35,059 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:35,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:35,080 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:35,087 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F802C13F6E9A492BA71E2E493013D528, ordinal: 0
2015-09-24 13:00:35,088 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:35,088 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:35,089 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F802C13F6E9A492BA71E2E493013D528, mem on start (mb), free: 105, total: 393, max: 672
2015-09-24 13:00:35,094 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F802C13F6E9A492BA71E2E493013D528, mem on close (mb), free: 105, total: 393, max: 672
2015-09-24 13:00:37,063 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:37,063 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:37,070 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A92E93F9455A4C10B27DC356D6A05CF6, ordinal: 1
2015-09-24 13:00:37,071 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:37,071 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2015-09-24 13:00:37,071 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A92E93F9455A4C10B27DC356D6A05CF6, mem on start (mb), free: 195, total: 396, max: 672
2015-09-24 13:00:37,083 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A92E93F9455A4C10B27DC356D6A05CF6, mem on close (mb), free: 194, total: 396, max: 672
2015-09-24 13:00:37,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2015-09-24 13:00:37,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.189
2015-09-24 13:00:37,160 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:37,161 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:37,205 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-09-24 13:00:37,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:37,206 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'
2015-09-24 13:00:37,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:37,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:37,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2015-09-24 13:00:37,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:37,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:37,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:37,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2015-09-24 13:00:37,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local615239459_0005
2015-09-24 13:00:37,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:37,352 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:37,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:37,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:37,378 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DFE08C383DAA4E4EA4D49E16679FC345, ordinal: 0
2015-09-24 13:00:37,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:37,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:37,379 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFE08C383DAA4E4EA4D49E16679FC345, mem on start (mb), free: 170, total: 388, max: 672
2015-09-24 13:00:37,384 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFE08C383DAA4E4EA4D49E16679FC345, mem on close (mb), free: 170, total: 388, max: 672
2015-09-24 13:00:37,398 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:37,399 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:37,404 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B1C5D0A8146A4AE7909974FF55538444, ordinal: 1
2015-09-24 13:00:37,405 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:37,405 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2015-09-24 13:00:37,405 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1C5D0A8146A4AE7909974FF55538444, mem on start (mb), free: 161, total: 388, max: 672
2015-09-24 13:00:37,416 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1C5D0A8146A4AE7909974FF55538444, mem on close (mb), free: 160, total: 388, max: 672
2015-09-24 13:00:37,448 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2015-09-24 13:00:37,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.225
2015-09-24 13:00:37,490 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:37,490 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:37,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-09-24 13:00:37,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:37,539 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'
2015-09-24 13:00:37,556 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:37,556 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:37,556 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2015-09-24 13:00:37,556 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:37,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:37,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:37,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2015-09-24 13:00:37,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local293389241_0006
2015-09-24 13:00:37,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:37,680 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:37,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:37,700 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:37,706 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B687A71DC14F4450917247B083B04487, ordinal: 0
2015-09-24 13:00:37,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:37,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:37,707 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B687A71DC14F4450917247B083B04487, mem on start (mb), free: 178, total: 393, max: 672
2015-09-24 13:00:37,711 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B687A71DC14F4450917247B083B04487, mem on close (mb), free: 178, total: 393, max: 672
2015-09-24 13:00:39,637 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:39,638 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:39,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E7159592B5D147BAA3E51B225F07C267, ordinal: 1
2015-09-24 13:00:39,644 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:39,644 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2015-09-24 13:00:39,644 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7159592B5D147BAA3E51B225F07C267, mem on start (mb), free: 258, total: 397, max: 672
2015-09-24 13:00:39,655 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7159592B5D147BAA3E51B225F07C267, mem on close (mb), free: 256, total: 397, max: 672
2015-09-24 13:00:39,685 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2015-09-24 13:00:39,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.129
2015-09-24 13:00:39,723 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:39,724 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:39,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 13:00:39,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:39,765 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'
2015-09-24 13:00:39,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:39,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:39,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2015-09-24 13:00:39,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:39,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:39,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:39,791 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2015-09-24 13:00:39,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local84666140_0007
2015-09-24 13:00:39,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:39,909 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:39,924 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:39,924 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:39,930 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A55F4FD55692452C8A8D268F00D71EBE, ordinal: 0
2015-09-24 13:00:39,931 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:39,932 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:39,932 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A55F4FD55692452C8A8D268F00D71EBE, mem on start (mb), free: 91, total: 397, max: 672
2015-09-24 13:00:39,936 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A55F4FD55692452C8A8D268F00D71EBE, mem on close (mb), free: 91, total: 397, max: 672
2015-09-24 13:00:39,951 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:39,951 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:39,957 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D0BCF9184F97418BADA338BCFB18D576, ordinal: 1
2015-09-24 13:00:39,958 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:39,958 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2015-09-24 13:00:39,958 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D0BCF9184F97418BADA338BCFB18D576, mem on start (mb), free: 81, total: 397, max: 672
2015-09-24 13:00:39,970 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D0BCF9184F97418BADA338BCFB18D576, mem on close (mb), free: 79, total: 397, max: 672
2015-09-24 13:00:39,993 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2015-09-24 13:00:39,994 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.204
2015-09-24 13:00:40,038 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:40,039 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:40,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-09-24 13:00:40,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:40,082 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'
2015-09-24 13:00:40,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:40,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:40,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2015-09-24 13:00:40,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:40,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:40,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:40,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2015-09-24 13:00:40,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1541007450_0008
2015-09-24 13:00:40,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:40,219 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:40,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:40,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:40,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF9F48B4896849418C80184D2F85BDC3, ordinal: 0
2015-09-24 13:00:40,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:40,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:40,245 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF9F48B4896849418C80184D2F85BDC3, mem on start (mb), free: 137, total: 386, max: 672
2015-09-24 13:00:40,251 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF9F48B4896849418C80184D2F85BDC3, mem on close (mb), free: 137, total: 386, max: 672
2015-09-24 13:00:43,209 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:43,209 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:43,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE05398803C54F86B696BAB161FAFDD8, ordinal: 1
2015-09-24 13:00:43,215 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:43,215 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2015-09-24 13:00:43,215 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE05398803C54F86B696BAB161FAFDD8, mem on start (mb), free: 116, total: 397, max: 672
2015-09-24 13:00:43,226 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE05398803C54F86B696BAB161FAFDD8, mem on close (mb), free: 114, total: 397, max: 672
2015-09-24 13:00:43,245 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2015-09-24 13:00:43,245 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.147
2015-09-24 13:00:43,286 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:43,286 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:43,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-09-24 13:00:43,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:43,324 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'
2015-09-24 13:00:43,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:43,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:43,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2015-09-24 13:00:43,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:43,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:43,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:43,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2015-09-24 13:00:43,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1042001718_0009
2015-09-24 13:00:43,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:43,466 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:43,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:43,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:43,489 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BCED466B9A3B4E94997BC0FDF12F1348, ordinal: 0
2015-09-24 13:00:43,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:43,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:43,490 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCED466B9A3B4E94997BC0FDF12F1348, mem on start (mb), free: 164, total: 398, max: 672
2015-09-24 13:00:43,494 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCED466B9A3B4E94997BC0FDF12F1348, mem on close (mb), free: 164, total: 398, max: 672
2015-09-24 13:00:47,236 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:47,236 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:47,241 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E5799A946EC04F098DFA8F7E2504E8A3, ordinal: 1
2015-09-24 13:00:47,242 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:47,242 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2015-09-24 13:00:47,242 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5799A946EC04F098DFA8F7E2504E8A3, mem on start (mb), free: 98, total: 402, max: 672
2015-09-24 13:00:47,253 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5799A946EC04F098DFA8F7E2504E8A3, mem on close (mb), free: 96, total: 402, max: 672
2015-09-24 13:00:47,280 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2015-09-24 13:00:47,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.933
2015-09-24 13:00:47,327 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:47,327 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:47,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-09-24 13:00:47,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:47,365 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'
2015-09-24 13:00:47,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:47,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:47,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2015-09-24 13:00:47,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:47,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:47,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:47,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2015-09-24 13:00:47,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local651081481_0010
2015-09-24 13:00:47,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:47,497 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:47,512 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:47,512 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:47,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FC9136FDB2324962ABA28EB1E9AE19E1, ordinal: 0
2015-09-24 13:00:47,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:47,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:47,518 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC9136FDB2324962ABA28EB1E9AE19E1, mem on start (mb), free: 146, total: 401, max: 672
2015-09-24 13:00:47,523 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC9136FDB2324962ABA28EB1E9AE19E1, mem on close (mb), free: 144, total: 401, max: 672
2015-09-24 13:00:49,356 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:49,357 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:49,363 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FDDF0713EEA14EF18A5984D7CA72226E, ordinal: 1
2015-09-24 13:00:49,363 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:49,363 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2015-09-24 13:00:49,364 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDDF0713EEA14EF18A5984D7CA72226E, mem on start (mb), free: 272, total: 404, max: 672
2015-09-24 13:00:49,374 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDDF0713EEA14EF18A5984D7CA72226E, mem on close (mb), free: 271, total: 404, max: 672
2015-09-24 13:00:49,394 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2015-09-24 13:00:49,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.015
2015-09-24 13:00:49,440 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:49,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:49,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 13:00:49,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:49,477 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'
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:49,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:49,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2015-09-24 13:00:49,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local974278047_0011
2015-09-24 13:00:49,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:49,612 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:49,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:49,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:49,638 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D69C77E3C48646EEAB8D6CDCDCABB5EF, ordinal: 0
2015-09-24 13:00:49,640 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:49,640 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:49,640 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D69C77E3C48646EEAB8D6CDCDCABB5EF, mem on start (mb), free: 106, total: 404, max: 672
2015-09-24 13:00:49,645 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D69C77E3C48646EEAB8D6CDCDCABB5EF, mem on close (mb), free: 106, total: 404, max: 672
2015-09-24 13:00:49,661 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:49,661 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:49,667 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ABAD29EBD8454939B46418B22E95120D, ordinal: 1
2015-09-24 13:00:49,667 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:49,668 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2015-09-24 13:00:49,668 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ABAD29EBD8454939B46418B22E95120D, mem on start (mb), free: 95, total: 404, max: 672
2015-09-24 13:00:49,679 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ABAD29EBD8454939B46418B22E95120D, mem on close (mb), free: 94, total: 404, max: 672
2015-09-24 13:00:49,706 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2015-09-24 13:00:49,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.217
2015-09-24 13:00:49,743 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:49,744 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:49,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 13:00:49,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:49,781 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'
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:49,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:49,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2015-09-24 13:00:49,919 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local626050613_0012
2015-09-24 13:00:49,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:49,925 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:49,941 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:49,941 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:49,948 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACBCF447E4D943F8B0DA326EB09CCFDB, ordinal: 0
2015-09-24 13:00:49,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:49,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:49,949 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACBCF447E4D943F8B0DA326EB09CCFDB, mem on start (mb), free: 151, total: 393, max: 672
2015-09-24 13:00:49,954 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACBCF447E4D943F8B0DA326EB09CCFDB, mem on close (mb), free: 151, total: 393, max: 672
2015-09-24 13:00:52,853 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:52,853 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:52,859 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BC0049B9FD084853877D8F922AF164BF, ordinal: 1
2015-09-24 13:00:52,860 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:52,860 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2015-09-24 13:00:52,860 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BC0049B9FD084853877D8F922AF164BF, mem on start (mb), free: 139, total: 406, max: 672
2015-09-24 13:00:52,871 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BC0049B9FD084853877D8F922AF164BF, mem on close (mb), free: 137, total: 406, max: 672
2015-09-24 13:00:52,889 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2015-09-24 13:00:52,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.095
2015-09-24 13:00:52,929 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:52,930 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:52,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-09-24 13:00:52,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:52,964 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'
2015-09-24 13:00:52,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:52,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:52,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2015-09-24 13:00:52,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:52,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:52,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:52,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2015-09-24 13:00:53,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local313392938_0013
2015-09-24 13:00:53,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:53,097 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:53,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:53,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:53,125 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9B429BF3EE143E78F2DA4FD79994C94, ordinal: 0
2015-09-24 13:00:53,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:53,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:53,126 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9B429BF3EE143E78F2DA4FD79994C94, mem on start (mb), free: 184, total: 406, max: 672
2015-09-24 13:00:53,131 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9B429BF3EE143E78F2DA4FD79994C94, mem on close (mb), free: 184, total: 406, max: 672
2015-09-24 13:00:56,908 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:56,908 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:56,913 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C9801A98F36244638C7B548EA2E562AD, ordinal: 1
2015-09-24 13:00:56,914 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:56,914 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2015-09-24 13:00:56,914 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9801A98F36244638C7B548EA2E562AD, mem on start (mb), free: 117, total: 410, max: 672
2015-09-24 13:00:56,924 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9801A98F36244638C7B548EA2E562AD, mem on close (mb), free: 115, total: 410, max: 672
2015-09-24 13:00:56,939 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2015-09-24 13:00:56,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.959
2015-09-24 13:00:56,977 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:56,978 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:57,005 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-09-24 13:00:57,005 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:57,005 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'
2015-09-24 13:00:57,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:57,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:57,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2015-09-24 13:00:57,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:57,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:57,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:57,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2015-09-24 13:00:57,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local990897530_0014
2015-09-24 13:00:57,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:57,129 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:57,146 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:57,146 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:57,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A6D4180D88C341BFACDBE224FBFAE472, ordinal: 0
2015-09-24 13:00:57,153 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:57,153 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:57,153 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6D4180D88C341BFACDBE224FBFAE472, mem on start (mb), free: 166, total: 411, max: 672
2015-09-24 13:00:57,157 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6D4180D88C341BFACDBE224FBFAE472, mem on close (mb), free: 166, total: 411, max: 672
2015-09-24 13:00:58,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:58,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:59,005 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A6C9A64760A04A67BAB4532DAB72FEB2, ordinal: 1
2015-09-24 13:00:59,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2015-09-24 13:00:59,006 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6C9A64760A04A67BAB4532DAB72FEB2, mem on start (mb), free: 72, total: 413, max: 672
2015-09-24 13:00:59,025 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6C9A64760A04A67BAB4532DAB72FEB2, mem on close (mb), free: 71, total: 413, max: 672
2015-09-24 13:00:59,048 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2015-09-24 13:00:59,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.030
2015-09-24 13:00:59,100 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:59,101 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:59,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-09-24 13:00:59,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:59,137 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'
2015-09-24 13:00:59,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:59,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2015-09-24 13:00:59,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:59,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:59,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:59,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2015-09-24 13:00:59,267 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local961248236_0015
2015-09-24 13:00:59,267 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:59,271 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:59,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:59,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:59,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE379EA7708244E9952DE637DC24B86F, ordinal: 0
2015-09-24 13:00:59,296 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,297 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,297 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE379EA7708244E9952DE637DC24B86F, mem on start (mb), free: 129, total: 412, max: 672
2015-09-24 13:00:59,301 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE379EA7708244E9952DE637DC24B86F, mem on close (mb), free: 129, total: 412, max: 672
2015-09-24 13:00:59,314 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:59,314 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:59,320 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C565A90853B744DA86B4A17A509B6413, ordinal: 1
2015-09-24 13:00:59,320 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,321 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2015-09-24 13:00:59,321 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C565A90853B744DA86B4A17A509B6413, mem on start (mb), free: 119, total: 412, max: 672
2015-09-24 13:00:59,331 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C565A90853B744DA86B4A17A509B6413, mem on close (mb), free: 117, total: 412, max: 672
2015-09-24 13:00:59,354 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2015-09-24 13:00:59,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.202
2015-09-24 13:00:59,397 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:59,399 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:59,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 13:00:59,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:59,438 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'
2015-09-24 13:00:59,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2015-09-24 13:00:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:59,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:59,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2015-09-24 13:00:59,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local419691089_0016
2015-09-24 13:00:59,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:59,585 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:59,601 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:59,601 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:59,608 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D0B839794A0B4DBE835C6932FEA7241A, ordinal: 0
2015-09-24 13:00:59,609 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,609 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,609 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0B839794A0B4DBE835C6932FEA7241A, mem on start (mb), free: 187, total: 412, max: 672
2015-09-24 13:00:59,613 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0B839794A0B4DBE835C6932FEA7241A, mem on close (mb), free: 187, total: 412, max: 672
2015-09-24 13:00:59,629 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:59,630 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:59,635 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E6CBB93E2C93456CB0442BD982A702C8, ordinal: 1
2015-09-24 13:00:59,635 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,636 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2015-09-24 13:00:59,636 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6CBB93E2C93456CB0442BD982A702C8, mem on start (mb), free: 180, total: 412, max: 672
2015-09-24 13:00:59,649 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6CBB93E2C93456CB0442BD982A702C8, mem on close (mb), free: 178, total: 412, max: 672
2015-09-24 13:00:59,676 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2015-09-24 13:00:59,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.227
2015-09-24 13:00:59,715 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:00:59,715 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:00:59,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-09-24 13:00:59,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:00:59,740 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'
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:00:59,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:00:59,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2015-09-24 13:00:59,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local627659948_0017
2015-09-24 13:00:59,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:00:59,866 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:00:59,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:00:59,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:00:59,894 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAA79633539048F98BB7695D58E59658, ordinal: 0
2015-09-24 13:00:59,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:00:59,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,895 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAA79633539048F98BB7695D58E59658, mem on start (mb), free: 194, total: 411, max: 672
2015-09-24 13:00:59,899 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAA79633539048F98BB7695D58E59658, mem on close (mb), free: 194, total: 411, max: 672
2015-09-24 13:00:59,911 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:00:59,912 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:00:59,917 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D5AEBCBA397C4A51B5CF540B59281C75, ordinal: 1
2015-09-24 13:00:59,918 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:00:59,918 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2015-09-24 13:00:59,918 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5AEBCBA397C4A51B5CF540B59281C75, mem on start (mb), free: 187, total: 411, max: 672
2015-09-24 13:00:59,930 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5AEBCBA397C4A51B5CF540B59281C75, mem on close (mb), free: 186, total: 411, max: 672
2015-09-24 13:00:59,949 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2015-09-24 13:00:59,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.197
2015-09-24 13:01:00,004 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:00,005 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:00,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-09-24 13:01:00,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:00,035 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'
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:00,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:00,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2015-09-24 13:01:00,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1114317141_0018
2015-09-24 13:01:00,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:00,169 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:00,188 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:00,188 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:00,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD7810C115A3405C85A2E3665CCF43B6, ordinal: 0
2015-09-24 13:01:00,195 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,195 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,195 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD7810C115A3405C85A2E3665CCF43B6, mem on start (mb), free: 182, total: 399, max: 672
2015-09-24 13:01:00,199 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD7810C115A3405C85A2E3665CCF43B6, mem on close (mb), free: 182, total: 399, max: 672
2015-09-24 13:01:00,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:00,215 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:00,223 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E270A05031EA44BE9AF864BA73734724, ordinal: 1
2015-09-24 13:01:00,223 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,224 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2015-09-24 13:01:00,224 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E270A05031EA44BE9AF864BA73734724, mem on start (mb), free: 176, total: 399, max: 672
2015-09-24 13:01:00,235 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E270A05031EA44BE9AF864BA73734724, mem on close (mb), free: 174, total: 399, max: 672
2015-09-24 13:01:00,259 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2015-09-24 13:01:00,259 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.212
2015-09-24 13:01:00,296 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:00,296 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:00,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-09-24 13:01:00,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:00,324 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'
2015-09-24 13:01:00,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:00,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2015-09-24 13:01:00,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:00,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:00,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:00,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2015-09-24 13:01:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1885592815_0019
2015-09-24 13:01:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:00,450 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:00,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:00,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:00,474 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5FF8D1F73934A239BA1F7C06FF9E1F2, ordinal: 0
2015-09-24 13:01:00,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,475 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5FF8D1F73934A239BA1F7C06FF9E1F2, mem on start (mb), free: 193, total: 411, max: 672
2015-09-24 13:01:00,480 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5FF8D1F73934A239BA1F7C06FF9E1F2, mem on close (mb), free: 193, total: 411, max: 672
2015-09-24 13:01:00,495 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:00,496 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:00,500 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CD0B68C5584A4ABE9BD7E52A988D8D04, ordinal: 1
2015-09-24 13:01:00,501 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,501 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2015-09-24 13:01:00,501 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CD0B68C5584A4ABE9BD7E52A988D8D04, mem on start (mb), free: 187, total: 411, max: 672
2015-09-24 13:01:00,510 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CD0B68C5584A4ABE9BD7E52A988D8D04, mem on close (mb), free: 186, total: 411, max: 672
2015-09-24 13:01:00,532 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2015-09-24 13:01:00,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.195
2015-09-24 13:01:00,570 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:00,570 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:00,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-09-24 13:01:00,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:00,595 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'
2015-09-24 13:01:00,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:00,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2015-09-24 13:01:00,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:00,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:00,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:00,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2015-09-24 13:01:00,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local870044284_0020
2015-09-24 13:01:00,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:00,753 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:00,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:00,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:00,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F554EE715124477CB0A862A835622D5F, ordinal: 0
2015-09-24 13:01:00,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,784 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F554EE715124477CB0A862A835622D5F, mem on start (mb), free: 193, total: 411, max: 672
2015-09-24 13:01:00,788 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F554EE715124477CB0A862A835622D5F, mem on close (mb), free: 193, total: 411, max: 672
2015-09-24 13:01:00,806 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:00,806 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:00,813 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F4ADBCB02F584356B819D34C2C066305, ordinal: 1
2015-09-24 13:01:00,814 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:00,814 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2015-09-24 13:01:00,814 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4ADBCB02F584356B819D34C2C066305, mem on start (mb), free: 187, total: 411, max: 672
2015-09-24 13:01:00,825 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4ADBCB02F584356B819D34C2C066305, mem on close (mb), free: 185, total: 411, max: 672
2015-09-24 13:01:00,855 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2015-09-24 13:01:00,858 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.246
2015-09-24 13:01:00,900 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:00,901 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:00,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-09-24 13:01:00,927 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:00,927 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'
2015-09-24 13:01:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2015-09-24 13:01:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:00,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:00,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:00,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2015-09-24 13:01:01,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local143475888_0021
2015-09-24 13:01:01,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:01,054 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:01,075 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:01,075 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:01,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D28DC6DFD6F94A4E828BE5C5B4E061E0, ordinal: 0
2015-09-24 13:01:01,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,082 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D28DC6DFD6F94A4E828BE5C5B4E061E0, mem on start (mb), free: 192, total: 411, max: 672
2015-09-24 13:01:01,085 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D28DC6DFD6F94A4E828BE5C5B4E061E0, mem on close (mb), free: 192, total: 411, max: 672
2015-09-24 13:01:01,099 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:01,099 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:01,104 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BD595204173E4D8BBF00654B40AD1AED, ordinal: 1
2015-09-24 13:01:01,105 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,105 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2015-09-24 13:01:01,105 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD595204173E4D8BBF00654B40AD1AED, mem on start (mb), free: 187, total: 411, max: 672
2015-09-24 13:01:01,115 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD595204173E4D8BBF00654B40AD1AED, mem on close (mb), free: 186, total: 411, max: 672
2015-09-24 13:01:01,135 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2015-09-24 13:01:01,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.197
2015-09-24 13:01:01,172 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:01,173 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:01,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-09-24 13:01:01,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:01,200 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'
2015-09-24 13:01:01,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2015-09-24 13:01:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:01,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2015-09-24 13:01:01,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1669369445_0022
2015-09-24 13:01:01,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:01,369 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:01,391 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:01,391 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:01,399 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E3440243E9CD4015BA9CEB568069CC3F, ordinal: 0
2015-09-24 13:01:01,400 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,400 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,400 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3440243E9CD4015BA9CEB568069CC3F, mem on start (mb), free: 192, total: 411, max: 672
2015-09-24 13:01:01,404 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3440243E9CD4015BA9CEB568069CC3F, mem on close (mb), free: 191, total: 411, max: 672
2015-09-24 13:01:01,421 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:01,421 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:01,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B5A8145C48AB40328ED018EF0AA472A2, ordinal: 1
2015-09-24 13:01:01,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2015-09-24 13:01:01,428 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B5A8145C48AB40328ED018EF0AA472A2, mem on start (mb), free: 186, total: 411, max: 672
2015-09-24 13:01:01,440 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B5A8145C48AB40328ED018EF0AA472A2, mem on close (mb), free: 185, total: 411, max: 672
2015-09-24 13:01:01,462 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2015-09-24 13:01:01,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.248
2015-09-24 13:01:01,508 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:01,508 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:01,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-09-24 13:01:01,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:01,533 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'
2015-09-24 13:01:01,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:01,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2015-09-24 13:01:01,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:01,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:01,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:01,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2015-09-24 13:01:01,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local2033821296_0023
2015-09-24 13:01:01,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:01,658 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:01,677 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:01,677 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:01,682 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C40A3A5A8F53475FB32247D276AA7C3F, ordinal: 0
2015-09-24 13:01:01,682 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,682 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,683 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C40A3A5A8F53475FB32247D276AA7C3F, mem on start (mb), free: 190, total: 410, max: 672
2015-09-24 13:01:01,686 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C40A3A5A8F53475FB32247D276AA7C3F, mem on close (mb), free: 190, total: 410, max: 672
2015-09-24 13:01:01,698 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:01,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:01,705 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB813F03ADC443EEBF97A9EC54E3FBD8, ordinal: 1
2015-09-24 13:01:01,705 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,706 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2015-09-24 13:01:01,706 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB813F03ADC443EEBF97A9EC54E3FBD8, mem on start (mb), free: 185, total: 410, max: 672
2015-09-24 13:01:01,715 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB813F03ADC443EEBF97A9EC54E3FBD8, mem on close (mb), free: 184, total: 410, max: 672
2015-09-24 13:01:01,736 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2015-09-24 13:01:01,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.195
2015-09-24 13:01:01,784 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:01,785 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:01,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-09-24 13:01:01,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:01,806 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'
2015-09-24 13:01:01,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:01,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2015-09-24 13:01:01,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:01,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:01,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:01,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2015-09-24 13:01:01,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local945935480_0024
2015-09-24 13:01:01,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:01,926 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:01,951 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:01,951 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:01,955 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C29BE98413C442C2A45488856D28BFA6, ordinal: 0
2015-09-24 13:01:01,955 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:01,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,956 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C29BE98413C442C2A45488856D28BFA6, mem on start (mb), free: 190, total: 411, max: 672
2015-09-24 13:01:01,960 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C29BE98413C442C2A45488856D28BFA6, mem on close (mb), free: 190, total: 411, max: 672
2015-09-24 13:01:01,976 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:01,976 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:01,980 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CA44C45105AE42629A55844DC07E44EB, ordinal: 1
2015-09-24 13:01:01,981 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:01,981 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2015-09-24 13:01:01,981 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA44C45105AE42629A55844DC07E44EB, mem on start (mb), free: 185, total: 411, max: 672
2015-09-24 13:01:01,992 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA44C45105AE42629A55844DC07E44EB, mem on close (mb), free: 183, total: 411, max: 672
2015-09-24 13:01:02,008 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2015-09-24 13:01:02,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.192
2015-09-24 13:01:02,054 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:02,054 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:02,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-09-24 13:01:02,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:02,081 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'
2015-09-24 13:01:02,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:02,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:02,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2015-09-24 13:01:02,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:02,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:02,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:02,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2015-09-24 13:01:02,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local389049519_0025
2015-09-24 13:01:02,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:02,212 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:02,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:02,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:02,237 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB94BE9494404EE7BC4AC07783C60FCE, ordinal: 0
2015-09-24 13:01:02,238 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:02,238 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:02,238 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB94BE9494404EE7BC4AC07783C60FCE, mem on start (mb), free: 190, total: 412, max: 672
2015-09-24 13:01:02,242 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB94BE9494404EE7BC4AC07783C60FCE, mem on close (mb), free: 190, total: 412, max: 672
2015-09-24 13:01:02,257 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:02,258 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:02,262 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F6F8DD4590D443C6A0C82336479ED062, ordinal: 1
2015-09-24 13:01:02,262 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:02,263 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2015-09-24 13:01:02,263 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6F8DD4590D443C6A0C82336479ED062, mem on start (mb), free: 185, total: 412, max: 672
2015-09-24 13:01:02,275 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F6F8DD4590D443C6A0C82336479ED062, mem on close (mb), free: 184, total: 412, max: 672
2015-09-24 13:01:02,303 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2015-09-24 13:01:02,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.207
2015-09-24 13:01:02,342 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:01:02,342 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:01:02,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2015-09-24 13:01:02,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:01:02,361 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'
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-09-24 13:01:02,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-09-24 13:01:02,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2015-09-24 13:01:02,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1749519193_0026
2015-09-24 13:01:02,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-09-24 13:01:02,488 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt
2015-09-24 13:01:02,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 13:01:02,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: 
2015-09-24 13:01:02,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C722D2969F2A4CD99E1893096F8215F0, ordinal: 0
2015-09-24 13:01:02,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross.txt"]
2015-09-24 13:01:02,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:02,514 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C722D2969F2A4CD99E1893096F8215F0, mem on start (mb), free: 190, total: 412, max: 672
2015-09-24 13:01:02,518 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C722D2969F2A4CD99E1893096F8215F0, mem on close (mb), free: 189, total: 412, max: 672
2015-09-24 13:01:02,532 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-09-24 13:01:02,532 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: 
2015-09-24 13:01:02,536 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB3BBFFA1869461CABA97DA6B0D486CD, ordinal: 1
2015-09-24 13:01:02,537 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-09-24 13:01:02,537 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2015-09-24 13:01:02,537 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB3BBFFA1869461CABA97DA6B0D486CD, mem on start (mb), free: 184, total: 412, max: 672
2015-09-24 13:01:02,547 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB3BBFFA1869461CABA97DA6B0D486CD, mem on close (mb), free: 183, total: 412, max: 672
2015-09-24 13:01:02,569 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2015-09-24 13:01:02,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.199
2015-09-24 13:01:02,597 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2015-09-24 13:01:02,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2015-09-24 13:01:02,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2015-09-24 13:01:02,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2015-09-24 13:01:02,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2015-09-24 13:01:02,599 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2015-09-24 13:01:02,599 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2015-09-24 13:01:02,599 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2015-09-24 13:01:02,599 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2015-09-24 13:01:02,600 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2015-09-24 13:01:02,600 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2015-09-24 13:01:02,600 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2015-09-24 13:01:02,600 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2015-09-24 13:01:02,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2015-09-24 13:01:02,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2015-09-24 13:01:02,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2015-09-24 13:01:02,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2015-09-24 13:01:02,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2015-09-24 13:01:02,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2015-09-24 13:01:02,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2015-09-24 13:01:02,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2015-09-24 13:01:02,603 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2015-09-24 13:01:02,603 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2015-09-24 13:01:02,603 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true