Class cascading.SortedValuesPlatformTest

4

tests

0

failures

0

ignored

1m59.64s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparatorValues 33.035s passed
testCoGroupComparatorValuesReversed 44.632s passed
testComprehensiveGroupBy 41.905s passed
testSortFails 0.068s passed

Standard output

2015-08-12 16:47:33,969 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 16:47:34,082 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop2-mr1
2015-08-12 16:47:34,132 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 16:47:35,362 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-12 16:47:35,720 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-08-12 16:47:36,006 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:47:36,032 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:47:36,293 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 852242BB272F4A3C8C3B0FB13DC97152
2015-08-12 16:47:36,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.332
2015-08-12 16:47:36,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:47:36,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:47:37,122 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 16:47:37,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2015-08-12 16:47:37,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 16:47:37,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 16:47:37,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2015-08-12 16:47:37,130 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2015-08-12 16:47:37,131 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2015-08-12 16:47:37,132 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2015-08-12 16:47:37,133 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2015-08-12 16:47:38,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local451736570_0001
2015-08-12 16:47:38,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2015-08-12 16:47:38,272 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt
2015-08-12 16:47:38,373 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:47:38,373 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:47:38,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, ordinal: 0
2015-08-12 16:47:38,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 16:47:38,480 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:47:38,481 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, mem on start (mb), free: 111, total: 249, max: 672
2015-08-12 16:47:38,570 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, mem on close (mb), free: 109, total: 249, max: 672
2015-08-12 16:48:08,747 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 16:48:08,774 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:08,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:08,804 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, ordinal: 0
2015-08-12 16:48:08,813 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 16:48:08,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:48:08,815 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, mem on start (mb), free: 90, total: 392, max: 672
2015-08-12 16:48:08,840 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FABB97B996DF48ADA490F91C92293CC7, mem on close (mb), free: 90, total: 392, max: 672
2015-08-12 16:48:18,399 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:48:18,399 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:48:18,433 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D5D44A6032E04D9785DBED231385D91F, ordinal: 1
2015-08-12 16:48:18,443 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:48:18,444 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2015-08-12 16:48:18,444 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5D44A6032E04D9785DBED231385D91F, mem on start (mb), free: 300, total: 467, max: 672
2015-08-12 16:48:18,524 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 16:48:18,524 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 16:48:18,572 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5D44A6032E04D9785DBED231385D91F, mem on close (mb), free: 293, total: 467, max: 672
2015-08-12 16:48:18,623 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2015-08-12 16:48:18,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:41.497
2015-08-12 16:48:18,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2015-08-12 16:48:18,797 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:18,808 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:18,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.140
2015-08-12 16:48:18,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:48:18,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:48:19,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2015-08-12 16:48:19,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 16:48:19,052 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 16:48:19,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2015-08-12 16:48:19,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  parallel execution of steps is enabled: false
2015-08-12 16:48:19,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  executing total steps: 1
2015-08-12 16:48:19,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  allocating management threads: 1
2015-08-12 16:48:19,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2015-08-12 16:48:19,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local1563002804_0002
2015-08-12 16:48:19,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2015-08-12 16:48:19,303 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt
2015-08-12 16:48:19,335 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:19,337 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:19,369 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, ordinal: 0
2015-08-12 16:48:19,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 16:48:19,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:48:19,372 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, mem on start (mb), free: 249, total: 467, max: 672
2015-08-12 16:48:19,412 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, mem on close (mb), free: 249, total: 467, max: 672
2015-08-12 16:48:43,812 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 16:48:43,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:43,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:43,855 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, ordinal: 0
2015-08-12 16:48:43,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 16:48:43,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:48:43,856 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, mem on start (mb), free: 284, total: 510, max: 672
2015-08-12 16:48:43,861 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6FEDFACF9314BBFBBBA2E726C85FDAC, mem on close (mb), free: 284, total: 510, max: 672
2015-08-12 16:48:51,628 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:48:51,629 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:48:51,642 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D659CB25C1EB44C8AA3DD96B88A0D799, ordinal: 1
2015-08-12 16:48:51,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-08-12 16:48:51,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2015-08-12 16:48:51,644 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D659CB25C1EB44C8AA3DD96B88A0D799, mem on start (mb), free: 288, total: 486, max: 672
2015-08-12 16:48:51,660 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 16:48:51,661 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 16:48:51,692 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D659CB25C1EB44C8AA3DD96B88A0D799, mem on close (mb), free: 281, total: 486, max: 672
2015-08-12 16:48:51,724 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2015-08-12 16:48:51,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip]  completed in: 00:32.676
2015-08-12 16:48:51,797 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2015-08-12 16:48:51,827 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:51,829 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.027
2015-08-12 16:48:51,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 16:48:51,890 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:51,891 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:51,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.091
2015-08-12 16:48:51,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:48:51,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:48:52,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:48:52,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:52,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2015-08-12 16:48:52,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:48:52,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:48:52,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:48:52,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2015-08-12 16:48:52,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1441107804_0003
2015-08-12 16:48:52,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:48:52,232 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:48:52,269 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:52,270 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:52,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B4C2AB46DF3D45D894802E44EB348E17, ordinal: 0
2015-08-12 16:48:52,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:52,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:52,284 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4C2AB46DF3D45D894802E44EB348E17, mem on start (mb), free: 263, total: 482, max: 672
2015-08-12 16:48:52,289 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4C2AB46DF3D45D894802E44EB348E17, mem on close (mb), free: 263, total: 482, max: 672
2015-08-12 16:48:52,321 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:48:52,323 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:48:52,331 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BDDD079D247646DF9D9EB2A353CE29A2, ordinal: 1
2015-08-12 16:48:52,332 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:52,333 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2015-08-12 16:48:52,333 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDDD079D247646DF9D9EB2A353CE29A2, mem on start (mb), free: 251, total: 482, max: 672
2015-08-12 16:48:52,355 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDDD079D247646DF9D9EB2A353CE29A2, mem on close (mb), free: 249, total: 482, max: 672
2015-08-12 16:48:52,380 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2015-08-12 16:48:52,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.350
2015-08-12 16:48:52,453 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:52,454 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:52,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2015-08-12 16:48:52,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:48:52,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:48:52,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:48:52,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:52,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2015-08-12 16:48:52,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:48:52,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:48:52,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:48:52,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2015-08-12 16:48:52,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local858944018_0004
2015-08-12 16:48:52,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:48:52,741 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:48:52,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:52,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:52,867 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5ABCD3E9963453BB9D38B42CED12732, ordinal: 0
2015-08-12 16:48:52,873 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:52,873 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:52,874 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5ABCD3E9963453BB9D38B42CED12732, mem on start (mb), free: 268, total: 485, max: 672
2015-08-12 16:48:52,884 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5ABCD3E9963453BB9D38B42CED12732, mem on close (mb), free: 268, total: 485, max: 672
2015-08-12 16:48:56,205 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:48:56,205 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:48:56,213 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E865952C0296422D9CC0AABF67B8F49C, ordinal: 1
2015-08-12 16:48:56,214 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:56,223 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2015-08-12 16:48:56,225 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E865952C0296422D9CC0AABF67B8F49C, mem on start (mb), free: 370, total: 519, max: 672
2015-08-12 16:48:56,236 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E865952C0296422D9CC0AABF67B8F49C, mem on close (mb), free: 369, total: 519, max: 672
2015-08-12 16:48:56,261 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2015-08-12 16:48:56,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.695
2015-08-12 16:48:56,340 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:56,342 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:56,415 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-08-12 16:48:56,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:48:56,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:48:56,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:48:56,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:56,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2015-08-12 16:48:56,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:48:56,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:48:56,457 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:48:56,466 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2015-08-12 16:48:56,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local752480198_0005
2015-08-12 16:48:56,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:48:56,660 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:48:56,689 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:56,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:56,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC0BAE99F64246428C75459AB3246436, ordinal: 0
2015-08-12 16:48:56,700 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:56,701 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:56,701 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC0BAE99F64246428C75459AB3246436, mem on start (mb), free: 193, total: 519, max: 672
2015-08-12 16:48:56,709 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC0BAE99F64246428C75459AB3246436, mem on close (mb), free: 193, total: 519, max: 672
2015-08-12 16:48:56,737 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:48:56,737 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:48:56,751 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EEE885BD14B44029B750F76C05D238C7, ordinal: 1
2015-08-12 16:48:56,753 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:56,756 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2015-08-12 16:48:56,758 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EEE885BD14B44029B750F76C05D238C7, mem on start (mb), free: 182, total: 519, max: 672
2015-08-12 16:48:56,772 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EEE885BD14B44029B750F76C05D238C7, mem on close (mb), free: 181, total: 519, max: 672
2015-08-12 16:48:56,797 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2015-08-12 16:48:56,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.346
2015-08-12 16:48:56,889 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:48:56,891 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:48:56,952 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2015-08-12 16:48:56,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:48:56,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:48:56,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:48:56,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:56,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2015-08-12 16:48:57,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:48:57,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:48:57,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:48:57,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2015-08-12 16:48:57,172 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1847871347_0006
2015-08-12 16:48:57,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:48:57,181 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:48:57,201 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:48:57,202 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:48:57,209 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DBE4E8CE261941488EFFA8B5235B1D30, ordinal: 0
2015-08-12 16:48:57,210 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:48:57,212 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:48:57,214 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBE4E8CE261941488EFFA8B5235B1D30, mem on start (mb), free: 243, total: 519, max: 672
2015-08-12 16:48:57,224 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBE4E8CE261941488EFFA8B5235B1D30, mem on close (mb), free: 243, total: 519, max: 672
2015-08-12 16:49:00,012 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:00,013 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:00,018 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C1CD353EBA344B2683597A34E8D44633, ordinal: 1
2015-08-12 16:49:00,019 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:00,019 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2015-08-12 16:49:00,019 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C1CD353EBA344B2683597A34E8D44633, mem on start (mb), free: 357, total: 566, max: 672
2015-08-12 16:49:00,034 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C1CD353EBA344B2683597A34E8D44633, mem on close (mb), free: 356, total: 566, max: 672
2015-08-12 16:49:00,059 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2015-08-12 16:49:00,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:03.073
2015-08-12 16:49:00,124 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:00,125 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:00,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2015-08-12 16:49:00,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:00,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:00,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:00,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:00,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2015-08-12 16:49:00,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:00,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:00,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:00,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2015-08-12 16:49:00,435 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local399605498_0007
2015-08-12 16:49:00,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:00,444 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:00,471 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:00,471 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:00,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FA020AF23FC0414B9DD65E76C8FD58D3, ordinal: 0
2015-08-12 16:49:00,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:00,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:00,487 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA020AF23FC0414B9DD65E76C8FD58D3, mem on start (mb), free: 350, total: 566, max: 672
2015-08-12 16:49:00,495 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA020AF23FC0414B9DD65E76C8FD58D3, mem on close (mb), free: 350, total: 566, max: 672
2015-08-12 16:49:00,531 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:00,531 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:00,541 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F41191D7B24044BF8DC4E67885D5FCFA, ordinal: 1
2015-08-12 16:49:00,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:00,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2015-08-12 16:49:00,542 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F41191D7B24044BF8DC4E67885D5FCFA, mem on start (mb), free: 341, total: 566, max: 672
2015-08-12 16:49:00,561 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F41191D7B24044BF8DC4E67885D5FCFA, mem on close (mb), free: 340, total: 566, max: 672
2015-08-12 16:49:00,583 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2015-08-12 16:49:00,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.272
2015-08-12 16:49:00,641 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:00,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:00,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2015-08-12 16:49:00,722 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:00,722 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:00,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:00,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:00,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2015-08-12 16:49:00,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:00,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:00,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:00,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2015-08-12 16:49:00,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local2097012009_0008
2015-08-12 16:49:00,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:00,906 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:00,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:00,935 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:00,947 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B345EB5E70FC4C4FA00CC41CFDB20679, ordinal: 0
2015-08-12 16:49:00,948 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:00,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:00,949 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B345EB5E70FC4C4FA00CC41CFDB20679, mem on start (mb), free: 344, total: 558, max: 672
2015-08-12 16:49:00,956 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B345EB5E70FC4C4FA00CC41CFDB20679, mem on close (mb), free: 344, total: 558, max: 672
2015-08-12 16:49:05,532 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:05,533 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:05,553 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C2A2938DFCFB44CD83E98FA9820377B9, ordinal: 1
2015-08-12 16:49:05,554 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:05,554 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2015-08-12 16:49:05,555 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2A2938DFCFB44CD83E98FA9820377B9, mem on start (mb), free: 420, total: 597, max: 672
2015-08-12 16:49:05,567 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2A2938DFCFB44CD83E98FA9820377B9, mem on close (mb), free: 418, total: 597, max: 672
2015-08-12 16:49:05,586 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2015-08-12 16:49:05,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:04.841
2015-08-12 16:49:05,659 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:05,660 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:05,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-08-12 16:49:05,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:05,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:05,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:05,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:05,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2015-08-12 16:49:05,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:05,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:05,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:05,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2015-08-12 16:49:05,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1437220361_0009
2015-08-12 16:49:05,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:05,900 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:05,923 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:05,923 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:05,935 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FBC7720F5BE243149F34AEE33E091AAB, ordinal: 0
2015-08-12 16:49:05,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:05,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:05,937 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FBC7720F5BE243149F34AEE33E091AAB, mem on start (mb), free: 379, total: 596, max: 672
2015-08-12 16:49:05,944 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FBC7720F5BE243149F34AEE33E091AAB, mem on close (mb), free: 379, total: 596, max: 672
2015-08-12 16:49:11,602 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:11,603 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:11,618 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BE2E6ACED3CC479D9EA3253CBCB57A51, ordinal: 1
2015-08-12 16:49:11,619 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:11,619 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2015-08-12 16:49:11,619 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BE2E6ACED3CC479D9EA3253CBCB57A51, mem on start (mb), free: 267, total: 611, max: 672
2015-08-12 16:49:11,630 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BE2E6ACED3CC479D9EA3253CBCB57A51, mem on close (mb), free: 265, total: 611, max: 672
2015-08-12 16:49:11,660 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2015-08-12 16:49:11,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:05.900
2015-08-12 16:49:11,714 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:11,715 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:11,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-08-12 16:49:11,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:11,774 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:11,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:11,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:11,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2015-08-12 16:49:11,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:11,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:11,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:11,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2015-08-12 16:49:11,919 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1115632597_0010
2015-08-12 16:49:11,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:11,940 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:11,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:11,962 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:11,973 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9F23EB66D334FB5A598C7A56D3172ED, ordinal: 0
2015-08-12 16:49:11,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:11,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:11,976 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9F23EB66D334FB5A598C7A56D3172ED, mem on start (mb), free: 320, total: 611, max: 672
2015-08-12 16:49:12,002 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9F23EB66D334FB5A598C7A56D3172ED, mem on close (mb), free: 319, total: 611, max: 672
2015-08-12 16:49:14,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:14,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:14,649 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C74BB55484794A41B2A42308775A0879, ordinal: 1
2015-08-12 16:49:14,650 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:14,650 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2015-08-12 16:49:14,651 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C74BB55484794A41B2A42308775A0879, mem on start (mb), free: 457, total: 619, max: 672
2015-08-12 16:49:14,667 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C74BB55484794A41B2A42308775A0879, mem on close (mb), free: 456, total: 619, max: 672
2015-08-12 16:49:14,693 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2015-08-12 16:49:14,695 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.896
2015-08-12 16:49:14,748 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:14,752 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:14,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-08-12 16:49:14,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:14,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:14,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:14,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:14,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2015-08-12 16:49:14,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:14,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:14,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:14,824 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2015-08-12 16:49:14,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1663833084_0011
2015-08-12 16:49:14,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:14,950 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:14,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:14,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:14,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC31E06C55C14140BD564F9C5664EDC5, ordinal: 0
2015-08-12 16:49:14,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:14,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:14,980 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC31E06C55C14140BD564F9C5664EDC5, mem on start (mb), free: 282, total: 619, max: 672
2015-08-12 16:49:14,988 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC31E06C55C14140BD564F9C5664EDC5, mem on close (mb), free: 282, total: 619, max: 672
2015-08-12 16:49:15,008 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:15,009 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:15,027 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C7D5A95E8B044C3184E915AB00B660F1, ordinal: 1
2015-08-12 16:49:15,028 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:15,029 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2015-08-12 16:49:15,030 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7D5A95E8B044C3184E915AB00B660F1, mem on start (mb), free: 505, total: 619, max: 672
2015-08-12 16:49:15,043 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7D5A95E8B044C3184E915AB00B660F1, mem on close (mb), free: 504, total: 619, max: 672
2015-08-12 16:49:15,064 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2015-08-12 16:49:15,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.242
2015-08-12 16:49:15,111 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:15,112 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:15,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2015-08-12 16:49:15,182 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:15,183 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:15,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:15,233 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:15,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2015-08-12 16:49:15,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:15,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:15,239 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:15,241 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2015-08-12 16:49:15,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local375887540_0012
2015-08-12 16:49:15,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:15,410 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:15,429 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:15,429 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:15,441 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADE933783D8D4B7DBC09A3D84125CAD0, ordinal: 0
2015-08-12 16:49:15,444 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:15,445 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:15,446 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADE933783D8D4B7DBC09A3D84125CAD0, mem on start (mb), free: 335, total: 619, max: 672
2015-08-12 16:49:15,455 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADE933783D8D4B7DBC09A3D84125CAD0, mem on close (mb), free: 335, total: 619, max: 672
2015-08-12 16:49:19,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:19,652 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:19,662 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A7FB2A6B8D9444C5B5B27CDDF0A4AD61, ordinal: 1
2015-08-12 16:49:19,664 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:19,666 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2015-08-12 16:49:19,668 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A7FB2A6B8D9444C5B5B27CDDF0A4AD61, mem on start (mb), free: 404, total: 647, max: 672
2015-08-12 16:49:19,678 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A7FB2A6B8D9444C5B5B27CDDF0A4AD61, mem on close (mb), free: 403, total: 647, max: 672
2015-08-12 16:49:19,701 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2015-08-12 16:49:19,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:04.469
2015-08-12 16:49:19,755 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:19,758 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:19,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-08-12 16:49:19,824 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:19,824 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:19,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:19,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:19,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2015-08-12 16:49:19,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:19,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:19,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:19,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2015-08-12 16:49:20,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1573123931_0013
2015-08-12 16:49:20,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:20,194 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:20,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:20,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:20,243 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABBE4927A0614EAC9D3638630529AE84, ordinal: 0
2015-08-12 16:49:20,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:20,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:20,245 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABBE4927A0614EAC9D3638630529AE84, mem on start (mb), free: 431, total: 647, max: 672
2015-08-12 16:49:20,252 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABBE4927A0614EAC9D3638630529AE84, mem on close (mb), free: 431, total: 647, max: 672
2015-08-12 16:49:25,225 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:25,226 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:25,234 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AC1518B4955E442095ADAAE3D61C57A3, ordinal: 1
2015-08-12 16:49:25,236 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:25,238 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2015-08-12 16:49:25,238 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AC1518B4955E442095ADAAE3D61C57A3, mem on start (mb), free: 317, total: 656, max: 672
2015-08-12 16:49:25,251 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AC1518B4955E442095ADAAE3D61C57A3, mem on close (mb), free: 315, total: 656, max: 672
2015-08-12 16:49:25,268 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2015-08-12 16:49:25,269 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:05.383
2015-08-12 16:49:25,330 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:25,331 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:25,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-08-12 16:49:25,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:25,387 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:25,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:25,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:25,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2015-08-12 16:49:25,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:25,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:25,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:25,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2015-08-12 16:49:25,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1553590041_0014
2015-08-12 16:49:25,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:25,576 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:25,606 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:25,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:25,615 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3BBFE3ACCCE4AFCB82B3C56A8689358, ordinal: 0
2015-08-12 16:49:25,616 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:25,617 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:25,617 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3BBFE3ACCCE4AFCB82B3C56A8689358, mem on start (mb), free: 371, total: 655, max: 672
2015-08-12 16:49:25,624 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3BBFE3ACCCE4AFCB82B3C56A8689358, mem on close (mb), free: 371, total: 655, max: 672
2015-08-12 16:49:28,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:28,177 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:28,184 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FF10C150358A4D3885BF75E992167FCB, ordinal: 1
2015-08-12 16:49:28,184 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:28,185 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2015-08-12 16:49:28,185 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FF10C150358A4D3885BF75E992167FCB, mem on start (mb), free: 502, total: 656, max: 672
2015-08-12 16:49:28,198 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FF10C150358A4D3885BF75E992167FCB, mem on close (mb), free: 500, total: 656, max: 672
2015-08-12 16:49:28,233 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2015-08-12 16:49:28,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:02.819
2015-08-12 16:49:28,306 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:28,306 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:28,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-08-12 16:49:28,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:28,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:28,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:28,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:28,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2015-08-12 16:49:28,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:28,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:28,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:28,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2015-08-12 16:49:28,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1364552226_0015
2015-08-12 16:49:28,493 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:28,507 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:28,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:28,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:28,531 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DEF394704F094AAFB010A186E4A9061B, ordinal: 0
2015-08-12 16:49:28,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:28,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:28,534 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEF394704F094AAFB010A186E4A9061B, mem on start (mb), free: 326, total: 656, max: 672
2015-08-12 16:49:28,540 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEF394704F094AAFB010A186E4A9061B, mem on close (mb), free: 326, total: 656, max: 672
2015-08-12 16:49:28,564 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:28,564 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:28,573 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A76048EB766B4E6D8A49EC4064E8A8CD, ordinal: 1
2015-08-12 16:49:28,574 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:28,575 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2015-08-12 16:49:28,575 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A76048EB766B4E6D8A49EC4064E8A8CD, mem on start (mb), free: 315, total: 656, max: 672
2015-08-12 16:49:28,585 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A76048EB766B4E6D8A49EC4064E8A8CD, mem on close (mb), free: 314, total: 656, max: 672
2015-08-12 16:49:28,617 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2015-08-12 16:49:28,618 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.250
2015-08-12 16:49:28,678 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:28,680 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:28,714 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-08-12 16:49:28,715 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:28,716 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:28,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:28,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:28,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2015-08-12 16:49:28,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:28,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:28,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:28,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2015-08-12 16:49:28,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local736731217_0016
2015-08-12 16:49:28,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:28,881 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:28,900 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:28,901 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:28,908 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDEFAD4EB7114EAFB725780395CBAE17, ordinal: 0
2015-08-12 16:49:28,910 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:28,912 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:28,915 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDEFAD4EB7114EAFB725780395CBAE17, mem on start (mb), free: 377, total: 656, max: 672
2015-08-12 16:49:28,922 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDEFAD4EB7114EAFB725780395CBAE17, mem on close (mb), free: 377, total: 656, max: 672
2015-08-12 16:49:28,959 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:28,971 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:28,982 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A6E026D59EA7403A8A13563287821176, ordinal: 1
2015-08-12 16:49:28,984 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:28,985 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2015-08-12 16:49:28,987 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6E026D59EA7403A8A13563287821176, mem on start (mb), free: 366, total: 656, max: 672
2015-08-12 16:49:28,997 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6E026D59EA7403A8A13563287821176, mem on close (mb), free: 365, total: 656, max: 672
2015-08-12 16:49:29,015 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2015-08-12 16:49:29,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.279
2015-08-12 16:49:29,077 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:29,078 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:29,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-08-12 16:49:29,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:29,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:29,131 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:29,132 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:29,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2015-08-12 16:49:29,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:29,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:29,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:29,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2015-08-12 16:49:29,271 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1365704080_0017
2015-08-12 16:49:29,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:29,277 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:29,294 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:29,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:29,301 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DFCD14660C0C42B9BBC2EF448B09A7B3, ordinal: 0
2015-08-12 16:49:29,302 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:29,303 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:29,303 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFCD14660C0C42B9BBC2EF448B09A7B3, mem on start (mb), free: 425, total: 655, max: 672
2015-08-12 16:49:29,309 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFCD14660C0C42B9BBC2EF448B09A7B3, mem on close (mb), free: 425, total: 655, max: 672
2015-08-12 16:49:29,333 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:29,334 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:29,341 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FFE9B6566AC0490CBDE02C0D6754C175, ordinal: 1
2015-08-12 16:49:29,342 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:29,342 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2015-08-12 16:49:29,343 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FFE9B6566AC0490CBDE02C0D6754C175, mem on start (mb), free: 417, total: 655, max: 672
2015-08-12 16:49:29,356 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FFE9B6566AC0490CBDE02C0D6754C175, mem on close (mb), free: 416, total: 655, max: 672
2015-08-12 16:49:29,399 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2015-08-12 16:49:29,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.267
2015-08-12 16:49:29,471 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:29,472 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:29,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-08-12 16:49:29,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:29,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:29,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:29,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2015-08-12 16:49:29,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:29,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:29,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:29,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2015-08-12 16:49:29,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1284629351_0018
2015-08-12 16:49:29,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:29,691 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:29,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:29,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:29,731 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E3B3CBF47FD9430F8A9168295A0104FD, ordinal: 0
2015-08-12 16:49:29,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:29,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:29,733 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3B3CBF47FD9430F8A9168295A0104FD, mem on start (mb), free: 432, total: 647, max: 672
2015-08-12 16:49:29,740 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3B3CBF47FD9430F8A9168295A0104FD, mem on close (mb), free: 432, total: 647, max: 672
2015-08-12 16:49:29,759 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:29,761 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:29,769 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F10B420283F3496086EF1725F73D7DD4, ordinal: 1
2015-08-12 16:49:29,770 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:29,771 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2015-08-12 16:49:29,771 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F10B420283F3496086EF1725F73D7DD4, mem on start (mb), free: 425, total: 647, max: 672
2015-08-12 16:49:29,783 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F10B420283F3496086EF1725F73D7DD4, mem on close (mb), free: 424, total: 647, max: 672
2015-08-12 16:49:29,804 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2015-08-12 16:49:29,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.237
2015-08-12 16:49:29,866 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:29,867 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:29,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-08-12 16:49:29,931 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:29,931 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:29,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:29,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:29,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2015-08-12 16:49:29,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:29,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:29,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:29,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2015-08-12 16:49:30,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local580511531_0019
2015-08-12 16:49:30,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:30,097 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:30,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:30,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:30,138 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4148665717A4DFCADC3150394AAB8FB, ordinal: 0
2015-08-12 16:49:30,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:30,141 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:30,142 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4148665717A4DFCADC3150394AAB8FB, mem on start (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:30,149 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4148665717A4DFCADC3150394AAB8FB, mem on close (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:30,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:30,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:30,177 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D7480CA573F24153B1D909584762933D, ordinal: 1
2015-08-12 16:49:30,178 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:30,178 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2015-08-12 16:49:30,178 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7480CA573F24153B1D909584762933D, mem on start (mb), free: 435, total: 655, max: 672
2015-08-12 16:49:30,197 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7480CA573F24153B1D909584762933D, mem on close (mb), free: 434, total: 655, max: 672
2015-08-12 16:49:30,217 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2015-08-12 16:49:30,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.252
2015-08-12 16:49:30,276 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:30,283 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:30,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-08-12 16:49:30,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:30,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:30,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:30,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:30,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2015-08-12 16:49:30,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:30,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:30,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:30,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2015-08-12 16:49:30,457 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local639066324_0020
2015-08-12 16:49:30,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:30,466 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:30,488 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:30,489 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:30,512 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E323DE3EEFED48A9A77DB18AEF6EA3D5, ordinal: 0
2015-08-12 16:49:30,516 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:30,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:30,517 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E323DE3EEFED48A9A77DB18AEF6EA3D5, mem on start (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:30,585 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E323DE3EEFED48A9A77DB18AEF6EA3D5, mem on close (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:30,663 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:30,665 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:30,674 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AEEB304B557042AAA2705CA815E92DF2, ordinal: 1
2015-08-12 16:49:30,675 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:30,677 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2015-08-12 16:49:30,678 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AEEB304B557042AAA2705CA815E92DF2, mem on start (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:30,690 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AEEB304B557042AAA2705CA815E92DF2, mem on close (mb), free: 436, total: 655, max: 672
2015-08-12 16:49:30,714 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2015-08-12 16:49:30,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.380
2015-08-12 16:49:30,789 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:30,790 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:30,846 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 16:49:30,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:30,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:30,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:30,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:30,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2015-08-12 16:49:30,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:30,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:30,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:30,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2015-08-12 16:49:31,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local545533589_0021
2015-08-12 16:49:31,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:31,108 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:31,131 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:31,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:31,153 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5C108FC66E949569CBE26D6D1A1AD56, ordinal: 0
2015-08-12 16:49:31,156 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:31,156 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:31,156 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5C108FC66E949569CBE26D6D1A1AD56, mem on start (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:31,162 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5C108FC66E949569CBE26D6D1A1AD56, mem on close (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:31,220 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:31,227 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:31,237 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AE2429D2CBC64B99AED4E9078A77CB8A, ordinal: 1
2015-08-12 16:49:31,237 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:31,238 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2015-08-12 16:49:31,238 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AE2429D2CBC64B99AED4E9078A77CB8A, mem on start (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:31,249 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AE2429D2CBC64B99AED4E9078A77CB8A, mem on close (mb), free: 436, total: 655, max: 672
2015-08-12 16:49:31,275 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2015-08-12 16:49:31,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.407
2015-08-12 16:49:31,331 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:31,333 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:31,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-08-12 16:49:31,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:31,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:31,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:31,413 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:31,413 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2015-08-12 16:49:31,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:31,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:31,415 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:31,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2015-08-12 16:49:31,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1336607471_0022
2015-08-12 16:49:31,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:31,595 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:31,617 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:31,617 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:31,623 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5F66117970741CABB03457D65CF589E, ordinal: 0
2015-08-12 16:49:31,625 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:31,625 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:31,626 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5F66117970741CABB03457D65CF589E, mem on start (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:31,632 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5F66117970741CABB03457D65CF589E, mem on close (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:31,659 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:31,659 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:31,665 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DB909B89ECA445C18814EA3F5A8C5C64, ordinal: 1
2015-08-12 16:49:31,665 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:31,666 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2015-08-12 16:49:31,666 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB909B89ECA445C18814EA3F5A8C5C64, mem on start (mb), free: 438, total: 655, max: 672
2015-08-12 16:49:31,681 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB909B89ECA445C18814EA3F5A8C5C64, mem on close (mb), free: 436, total: 655, max: 672
2015-08-12 16:49:31,701 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2015-08-12 16:49:31,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.296
2015-08-12 16:49:31,754 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:31,755 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:31,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-08-12 16:49:31,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:31,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:31,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:31,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:31,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2015-08-12 16:49:31,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:31,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:31,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:31,812 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2015-08-12 16:49:31,931 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local163882990_0023
2015-08-12 16:49:31,932 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:31,956 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:31,985 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:31,986 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:31,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE8BB67AA88C46C68FEC7633EBEBBBFE, ordinal: 0
2015-08-12 16:49:31,998 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:31,998 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:31,999 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE8BB67AA88C46C68FEC7633EBEBBBFE, mem on start (mb), free: 442, total: 654, max: 672
2015-08-12 16:49:32,002 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE8BB67AA88C46C68FEC7633EBEBBBFE, mem on close (mb), free: 442, total: 654, max: 672
2015-08-12 16:49:32,061 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:32,061 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:32,075 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B08EEF8E424741B4A5B0F675F0929C24, ordinal: 1
2015-08-12 16:49:32,077 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:32,079 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2015-08-12 16:49:32,081 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B08EEF8E424741B4A5B0F675F0929C24, mem on start (mb), free: 437, total: 654, max: 672
2015-08-12 16:49:32,092 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B08EEF8E424741B4A5B0F675F0929C24, mem on close (mb), free: 436, total: 654, max: 672
2015-08-12 16:49:32,120 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2015-08-12 16:49:32,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.316
2015-08-12 16:49:32,193 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:32,194 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:32,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 16:49:32,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:32,251 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:32,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:32,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:32,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2015-08-12 16:49:32,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:32,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:32,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:32,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2015-08-12 16:49:32,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1885689930_0024
2015-08-12 16:49:32,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:32,633 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:32,660 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:32,660 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:32,667 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A68400645D4E41BEA376EBD37507D8B7, ordinal: 0
2015-08-12 16:49:32,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:32,669 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:32,669 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A68400645D4E41BEA376EBD37507D8B7, mem on start (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:32,678 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A68400645D4E41BEA376EBD37507D8B7, mem on close (mb), free: 442, total: 655, max: 672
2015-08-12 16:49:32,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:32,723 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:32,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EC769BA6136C427ABDFB950454424D64, ordinal: 1
2015-08-12 16:49:32,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:32,730 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2015-08-12 16:49:32,730 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC769BA6136C427ABDFB950454424D64, mem on start (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:32,745 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC769BA6136C427ABDFB950454424D64, mem on close (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:32,767 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2015-08-12 16:49:32,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.469
2015-08-12 16:49:32,839 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:32,840 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:32,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-08-12 16:49:32,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:32,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:32,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:32,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:32,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2015-08-12 16:49:32,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:32,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:32,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:32,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2015-08-12 16:49:33,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local267592598_0025
2015-08-12 16:49:33,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:33,092 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:33,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:33,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:33,131 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CCCA7B167F094A559FC718F1829E9761, ordinal: 0
2015-08-12 16:49:33,132 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:33,132 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:33,132 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CCCA7B167F094A559FC718F1829E9761, mem on start (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:33,140 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CCCA7B167F094A559FC718F1829E9761, mem on close (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:33,217 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:33,222 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:33,253 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F2AC4498BA7E4AA2B6736F4535A7BAB9, ordinal: 1
2015-08-12 16:49:33,257 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:33,258 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2015-08-12 16:49:33,258 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2AC4498BA7E4AA2B6736F4535A7BAB9, mem on start (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:33,283 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2AC4498BA7E4AA2B6736F4535A7BAB9, mem on close (mb), free: 436, total: 655, max: 672
2015-08-12 16:49:33,326 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2015-08-12 16:49:33,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.409
2015-08-12 16:49:33,435 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:49:33,436 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:49:33,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-08-12 16:49:33,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:49:33,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:49:33,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2015-08-12 16:49:33,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:33,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2015-08-12 16:49:33,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  parallel execution of steps is enabled: false
2015-08-12 16:49:33,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  executing total steps: 1
2015-08-12 16:49:33,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  allocating management threads: 1
2015-08-12 16:49:33,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2015-08-12 16:49:33,615 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local799361096_0026
2015-08-12 16:49:33,615 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-08-12 16:49:33,624 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-08-12 16:49:33,644 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 16:49:33,645 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 16:49:33,651 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D613F7C49D274D9BA937F6D22E027FC6, ordinal: 0
2015-08-12 16:49:33,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 16:49:33,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:33,653 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D613F7C49D274D9BA937F6D22E027FC6, mem on start (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:33,661 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D613F7C49D274D9BA937F6D22E027FC6, mem on close (mb), free: 443, total: 655, max: 672
2015-08-12 16:49:33,693 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 16:49:33,694 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 16:49:33,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EA255FF6B3DC41CF8A6115CAEF7049AC, ordinal: 1
2015-08-12 16:49:33,709 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-08-12 16:49:33,709 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2015-08-12 16:49:33,709 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA255FF6B3DC41CF8A6115CAEF7049AC, mem on start (mb), free: 438, total: 655, max: 672
2015-08-12 16:49:33,725 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA255FF6B3DC41CF8A6115CAEF7049AC, mem on close (mb), free: 437, total: 655, max: 672
2015-08-12 16:49:33,740 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2015-08-12 16:49:33,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort]  completed in: 00:00.259
2015-08-12 16:49:33,765 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2015-08-12 16:49:33,766 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2015-08-12 16:49:33,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2015-08-12 16:49:33,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2015-08-12 16:49:33,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2015-08-12 16:49:33,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2015-08-12 16:49:33,768 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2015-08-12 16:49:33,768 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2015-08-12 16:49:33,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2015-08-12 16:49:33,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2015-08-12 16:49:33,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2015-08-12 16:49:33,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2015-08-12 16:49:33,770 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2015-08-12 16:49:33,770 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2015-08-12 16:49:33,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2015-08-12 16:49:33,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2015-08-12 16:49:33,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2015-08-12 16:49:33,772 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2015-08-12 16:49:33,772 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2015-08-12 16:49:33,773 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2015-08-12 16:49:33,773 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2015-08-12 16:49:33,773 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2015-08-12 16:49:33,773 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2015-08-12 16:49:33,774 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true