Class cascading.SortedValuesPlatformTest

4

tests

0

failures

0

ignored

1m2.69s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparatorValues 17.635s passed
testCoGroupComparatorValuesReversed 22.397s passed
testComprehensiveGroupBy 22.640s passed
testSortFails 0.022s passed

Standard output

2015-05-20 17:20:36,036 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 17:20:36,070 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 17:20:36,071 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.SortedValuesPlatformTest
2015-05-20 17:20:36,093 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-05-20 17:20:36,689 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-05-20 17:20:36,902 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:20:36,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:20:36,917 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: D4C827ADCF68459898E61204DBDE7CAE
2015-05-20 17:20:37,151 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 17:20:37,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip] starting
2015-05-20 17:20:37,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt"]
2015-05-20 17:20:37,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:20:37,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcomparereversed"]
2015-05-20 17:20:37,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  parallel execution is enabled: false
2015-05-20 17:20:37,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  starting jobs: 1
2015-05-20 17:20:37,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  allocating threads: 1
2015-05-20 17:20:37,155 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] starting step: (1/1) ...rm/cogroupcomparereversed
2015-05-20 17:20:37,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] submitted hadoop job: job_local1976863140_0001
2015-05-20 17:20:37,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] tracking url: http://localhost:8080/
2015-05-20 17:20:37,838 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt
2015-05-20 17:20:37,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:20:37,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:20:37,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt"]
2015-05-20 17:20:37,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:20:53,687 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt
2015-05-20 17:20:53,717 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:20:53,717 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:20:53,728 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:20:53,728 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:20:58,350 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:20:58,350 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:20:58,362 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:20:58,362 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcomparereversed"]
2015-05-20 17:20:58,378 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-05-20 17:20:58,378 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-05-20 17:20:58,443 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcomparereversed/_temporary
2015-05-20 17:20:58,488 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/cogroupcomparereversed
2015-05-20 17:20:58,518 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:20:58,519 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:20:58,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip] starting
2015-05-20 17:20:58,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt"]
2015-05-20 17:20:58,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:20:58,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcompareforward"]
2015-05-20 17:20:58,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  parallel execution is enabled: false
2015-05-20 17:20:58,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  starting jobs: 1
2015-05-20 17:20:58,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [apache*ip]  allocating threads: 1
2015-05-20 17:20:58,555 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] starting step: (1/1) ...orm/cogroupcompareforward
2015-05-20 17:20:58,723 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] submitted hadoop job: job_local1845347822_0002
2015-05-20 17:20:58,723 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache*ip] tracking url: http://localhost:8080/
2015-05-20 17:20:58,727 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt
2015-05-20 17:20:58,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:20:58,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:20:58,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.200.txt"]
2015-05-20 17:20:58,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:21:11,795 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt
2015-05-20 17:21:11,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:11,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:11,823 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:21:11,823 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:21:16,008 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:16,008 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:16,019 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-05-20 17:21:16,019 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcompareforward"]
2015-05-20 17:21:16,030 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-05-20 17:21:16,030 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-05-20 17:21:16,081 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/cogroupcompareforward/_temporary
2015-05-20 17:21:16,124 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/cogroupcompareforward
2015-05-20 17:21:16,139 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:16,140 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:16,159 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:16,160 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_false"]
2015-05-20 17:21:16,185 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:16,185 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:16,185 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:16,186 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2015-05-20 17:21:16,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local2076712484_0003
2015-05-20 17:21:16,353 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:16,356 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:16,374 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:16,374 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:16,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:16,380 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:16,397 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:16,398 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:16,408 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:16,408 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_false"]
2015-05-20 17:21:16,450 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_false/_temporary
2015-05-20 17:21:16,482 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:16,483 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:16,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:16,499 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:16,500 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_false"]
2015-05-20 17:21:16,501 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:16,501 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:16,501 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:16,501 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2015-05-20 17:21:16,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1457223452_0004
2015-05-20 17:21:16,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:16,646 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:16,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:16,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:16,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:16,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:18,165 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:18,165 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:18,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:18,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_false"]
2015-05-20 17:21:18,209 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_false/_temporary
2015-05-20 17:21:18,244 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:18,245 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:18,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:18,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:18,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_false"]
2015-05-20 17:21:18,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:18,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:18,260 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:18,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2015-05-20 17:21:18,390 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local725961062_0005
2015-05-20 17:21:18,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:18,395 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:18,425 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:18,426 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:18,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:18,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:18,449 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:18,450 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:18,455 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:18,456 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_false"]
2015-05-20 17:21:18,499 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_false/_temporary
2015-05-20 17:21:18,535 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:18,535 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:18,551 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:18,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:18,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_false"]
2015-05-20 17:21:18,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:18,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:18,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:18,553 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2015-05-20 17:21:18,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1039151155_0006
2015-05-20 17:21:18,668 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:18,672 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:18,694 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:18,695 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:18,703 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:18,703 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:20,208 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:20,208 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:20,213 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:20,213 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_false"]
2015-05-20 17:21:20,248 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_false/_temporary
2015-05-20 17:21:20,281 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:20,282 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:20,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:20,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:20,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_false"]
2015-05-20 17:21:20,307 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:20,307 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:20,308 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:20,310 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2015-05-20 17:21:20,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local47928704_0007
2015-05-20 17:21:20,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:20,436 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:20,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:20,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:20,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:20,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:20,476 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:20,476 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:20,482 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:20,483 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_false"]
2015-05-20 17:21:20,529 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_false/_temporary
2015-05-20 17:21:20,562 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:20,562 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:20,574 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:20,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:20,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_false"]
2015-05-20 17:21:20,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:20,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:20,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:20,575 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2015-05-20 17:21:20,711 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1281686019_0008
2015-05-20 17:21:20,711 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:20,714 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:20,735 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:20,735 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:20,739 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:20,739 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:22,972 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:22,973 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:22,977 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:22,977 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_false"]
2015-05-20 17:21:23,011 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_false/_temporary
2015-05-20 17:21:23,056 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:23,056 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:23,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:23,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:23,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_false"]
2015-05-20 17:21:23,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:23,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:23,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:23,075 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2015-05-20 17:21:23,248 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1483203772_0009
2015-05-20 17:21:23,248 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:23,251 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:23,267 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:23,267 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:23,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:23,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:26,207 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:26,207 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:26,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:26,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_false"]
2015-05-20 17:21:26,260 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_false/_temporary
2015-05-20 17:21:26,311 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:26,312 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:26,330 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:26,330 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:26,330 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_false"]
2015-05-20 17:21:26,330 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:26,331 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:26,331 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:26,331 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2015-05-20 17:21:26,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local2130746783_0010
2015-05-20 17:21:26,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:26,456 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:26,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:26,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:26,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:26,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:27,939 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:27,940 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:27,945 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:27,945 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_false"]
2015-05-20 17:21:27,985 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_false/_temporary
2015-05-20 17:21:28,029 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:28,030 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:28,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:28,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:28,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_false"]
2015-05-20 17:21:28,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:28,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:28,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:28,050 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2015-05-20 17:21:28,164 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1006475538_0011
2015-05-20 17:21:28,164 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:28,167 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:28,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:28,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:28,190 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:28,190 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:28,207 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:28,208 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:28,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:28,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_false"]
2015-05-20 17:21:28,256 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_false/_temporary
2015-05-20 17:21:28,290 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:28,290 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:28,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:28,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:28,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_false"]
2015-05-20 17:21:28,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:28,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:28,306 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:28,307 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2015-05-20 17:21:28,430 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local722202413_0012
2015-05-20 17:21:28,431 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:28,434 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:28,452 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:28,452 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:28,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:28,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:30,908 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:30,909 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:30,913 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:30,914 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_false"]
2015-05-20 17:21:30,955 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_false/_temporary
2015-05-20 17:21:30,992 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:30,993 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:31,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:31,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:31,007 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_false"]
2015-05-20 17:21:31,007 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:31,007 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:31,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:31,008 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2015-05-20 17:21:31,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local316609388_0013
2015-05-20 17:21:31,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:31,148 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:31,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:31,163 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:31,167 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:31,167 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:34,013 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:34,013 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:34,017 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:34,017 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_false"]
2015-05-20 17:21:34,056 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_false/_temporary
2015-05-20 17:21:34,091 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:34,091 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:34,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:34,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:34,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_false"]
2015-05-20 17:21:34,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:34,104 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:34,104 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:34,104 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2015-05-20 17:21:34,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1826858469_0014
2015-05-20 17:21:34,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:34,228 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:34,247 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:34,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:34,253 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:34,254 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:35,648 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:35,649 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:35,652 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:35,653 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_false"]
2015-05-20 17:21:35,680 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_false/_temporary
2015-05-20 17:21:35,719 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:35,720 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_true"]
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:35,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:35,730 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2015-05-20 17:21:35,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1465817977_0015
2015-05-20 17:21:35,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:35,849 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:35,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:35,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:35,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:35,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:35,889 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:35,889 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:35,894 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:35,894 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_true"]
2015-05-20 17:21:35,943 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_true/_temporary
2015-05-20 17:21:35,973 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:35,974 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:35,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:35,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:35,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_true"]
2015-05-20 17:21:35,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:35,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:35,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:35,989 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2015-05-20 17:21:36,125 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local2047670452_0016
2015-05-20 17:21:36,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:36,130 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:36,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:36,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,166 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:36,166 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_true"]
2015-05-20 17:21:36,203 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_true/_temporary
2015-05-20 17:21:36,246 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:36,247 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:36,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:36,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_true"]
2015-05-20 17:21:36,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:36,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:36,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:36,259 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2015-05-20 17:21:36,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local78656079_0017
2015-05-20 17:21:36,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:36,399 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:36,428 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:36,428 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,447 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:36,447 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,451 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,451 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_true"]
2015-05-20 17:21:36,486 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_true/_temporary
2015-05-20 17:21:36,524 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:36,525 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:36,534 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:36,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_true"]
2015-05-20 17:21:36,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:36,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:36,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:36,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2015-05-20 17:21:36,647 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1703194925_0018
2015-05-20 17:21:36,648 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:36,651 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:36,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:36,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,683 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:36,683 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,689 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,689 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_true"]
2015-05-20 17:21:36,728 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_true/_temporary
2015-05-20 17:21:36,759 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:36,759 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_true"]
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:36,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:36,769 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2015-05-20 17:21:36,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local922197086_0019
2015-05-20 17:21:36,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:36,893 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:36,920 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:36,921 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,926 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:36,926 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,941 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:36,942 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:36,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:36,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_true"]
2015-05-20 17:21:36,981 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_true/_temporary
2015-05-20 17:21:37,021 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:37,022 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_true"]
2015-05-20 17:21:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:37,034 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:37,034 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:37,034 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2015-05-20 17:21:37,153 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local38893410_0020
2015-05-20 17:21:37,153 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:37,156 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:37,172 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:37,173 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,196 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:37,196 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,205 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,206 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_true"]
2015-05-20 17:21:37,240 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_true/_temporary
2015-05-20 17:21:37,271 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:37,271 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_true"]
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:37,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:37,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2015-05-20 17:21:37,392 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local234373368_0021
2015-05-20 17:21:37,393 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:37,397 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:37,421 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:37,421 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,425 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,425 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,439 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:37,440 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,446 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,446 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_true"]
2015-05-20 17:21:37,482 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_true/_temporary
2015-05-20 17:21:37,535 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:37,536 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:37,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:37,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_true"]
2015-05-20 17:21:37,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:37,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:37,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:37,544 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2015-05-20 17:21:37,657 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local910229571_0022
2015-05-20 17:21:37,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:37,661 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:37,679 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:37,680 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,685 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,685 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,706 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:37,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,712 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,712 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_true"]
2015-05-20 17:21:37,748 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_true/_temporary
2015-05-20 17:21:37,779 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:37,779 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_true"]
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:37,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:37,789 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2015-05-20 17:21:37,913 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1731850609_0023
2015-05-20 17:21:37,913 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:37,917 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:37,933 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:37,933 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:37,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,952 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:37,952 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:37,956 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:37,956 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_true"]
2015-05-20 17:21:37,991 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_true/_temporary
2015-05-20 17:21:38,035 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:38,035 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:38,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:38,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_true"]
2015-05-20 17:21:38,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:38,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:38,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:38,047 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2015-05-20 17:21:38,162 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local1113622492_0024
2015-05-20 17:21:38,162 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:38,165 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:38,184 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:38,184 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,189 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,189 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,210 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:38,211 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,216 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,216 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_true"]
2015-05-20 17:21:38,252 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_true/_temporary
2015-05-20 17:21:38,285 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:38,285 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:38,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:38,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_true"]
2015-05-20 17:21:38,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:38,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:38,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:38,295 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2015-05-20 17:21:38,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local531215379_0025
2015-05-20 17:21:38,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:38,425 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:38,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:38,444 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,449 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,449 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,465 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:38,465 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,469 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,469 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_true"]
2015-05-20 17:21:38,516 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_true/_temporary
2015-05-20 17:21:38,550 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:21:38,551 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort] starting
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_true"]
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  parallel execution is enabled: false
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  starting jobs: 1
2015-05-20 17:21:38,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [comprehensivesort]  allocating threads: 1
2015-05-20 17:21:38,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2015-05-20 17:21:38,670 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] submitted hadoop job: job_local704717174_0026
2015-05-20 17:21:38,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-05-20 17:21:38,673 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt
2015-05-20 17:21:38,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 17:21:38,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,696 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lhs+rhs-cross.txt"]
2015-05-20 17:21:38,696 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-05-20 17:21:38,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-05-20 17:21:38,726 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-05-20 17:21:38,726 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_true"]
2015-05-20 17:21:38,759 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_true/_temporary
2015-05-20 17:21:38,782 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_false
2015-05-20 17:21:38,782 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_true
2015-05-20 17:21:38,782 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_true
2015-05-20 17:21:38,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_false
2015-05-20 17:21:38,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_false
2015-05-20 17:21:38,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_true
2015-05-20 17:21:38,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_false_false
2015-05-20 17:21:38,784 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_false_true
2015-05-20 17:21:38,784 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_true_true
2015-05-20 17:21:38,784 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_true
2015-05-20 17:21:38,784 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_false
2015-05-20 17:21:38,784 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_false
2015-05-20 17:21:38,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_true
2015-05-20 17:21:38,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_false
2015-05-20 17:21:38,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_true_false
2015-05-20 17:21:38,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_true_false_true
2015-05-20 17:21:38,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_true_true_false
2015-05-20 17:21:38,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_true
2015-05-20 17:21:38,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_false_true
2015-05-20 17:21:38,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_false_false
2015-05-20 17:21:38,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_false_true_false
2015-05-20 17:21:38,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_false_true_false
2015-05-20 17:21:38,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/true_null_true_true
2015-05-20 17:21:38,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/sortedvaluesplatform/comprehensive/false_null_false_true