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