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