2016-05-18 03:51:04,700 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 03:51:04,716 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop
2016-05-18 03:51:04,745 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 03:51:04,963 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 03:51:05,056 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:05,058 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:05,158 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 3A38C89F841C414E87A0C6F3D23F49D6
2016-05-18 03:51:05,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.200
2016-05-18 03:51:05,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:05,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:05,599 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 03:51:05,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-18 03:51:05,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt"]
2016-05-18 03:51:05,603 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-05-18 03:51:05,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-18 03:51:05,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-18 03:51:05,605 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-18 03:51:05,605 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-18 03:51:05,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2016-05-18 03:51:05,643 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 03:51:05,695 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 03:51:05,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local_0001
2016-05-18 03:51:05,931 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-18 03:51:06,000 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt
2016-05-18 03:51:06,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:06,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:06,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EFB902760735474B9938A2FE530B7A6F, ordinal: 0
2016-05-18 03:51:06,217 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt"]
2016-05-18 03:51:06,218 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:06,219 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFB902760735474B9938A2FE530B7A6F, mem on start (mb), free: 80, total: 223, max: 672
2016-05-18 03:51:06,285 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFB902760735474B9938A2FE530B7A6F, mem on close (mb), free: 79, total: 223, max: 672
2016-05-18 03:51:06,318 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-05-18 03:51:06,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:06,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:06,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EFB902760735474B9938A2FE530B7A6F, ordinal: 0
2016-05-18 03:51:06,439 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-05-18 03:51:06,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:06,440 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFB902760735474B9938A2FE530B7A6F, mem on start (mb), free: 72, total: 318, max: 672
2016-05-18 03:51:06,445 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFB902760735474B9938A2FE530B7A6F, mem on close (mb), free: 72, total: 318, max: 672
2016-05-18 03:51:06,475 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:06,476 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:06,489 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B166962DC79A46738D6C5D680FC8F128, ordinal: 1
2016-05-18 03:51:06,492 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:06,493 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-18 03:51:06,494 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B166962DC79A46738D6C5D680FC8F128, mem on start (mb), free: 70, total: 318, max: 672
2016-05-18 03:51:06,512 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:51:06,512 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:51:06,550 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B166962DC79A46738D6C5D680FC8F128, mem on close (mb), free: 68, total: 318, max: 672
2016-05-18 03:51:06,570 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2016-05-18 03:51:06,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:00.968
2016-05-18 03:51:06,614 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2016-05-18 03:51:06,638 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:06,640 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:06,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.110
2016-05-18 03:51:06,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:06,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:06,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-18 03:51:06,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt"]
2016-05-18 03:51:06,793 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-05-18 03:51:06,793 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-18 03:51:06,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-18 03:51:06,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-18 03:51:06,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-18 03:51:06,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2016-05-18 03:51:06,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local_0002
2016-05-18 03:51:06,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-18 03:51:06,889 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt
2016-05-18 03:51:06,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:06,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, ordinal: 0
2016-05-18 03:51:07,008 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.200.txt"]
2016-05-18 03:51:07,008 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:07,008 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, mem on start (mb), free: 103, total: 412, max: 672
2016-05-18 03:51:07,052 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, mem on close (mb), free: 103, total: 412, max: 672
2016-05-18 03:51:07,072 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-05-18 03:51:07,173 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:07,174 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,187 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, ordinal: 0
2016-05-18 03:51:07,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-05-18 03:51:07,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:07,189 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, mem on start (mb), free: 96, total: 508, max: 672
2016-05-18 03:51:07,193 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADD135F189E7472EAF8E730562EB3B8C, mem on close (mb), free: 96, total: 508, max: 672
2016-05-18 03:51:07,209 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:07,210 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,219 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E626195033F641CB82529A671F67489B, ordinal: 1
2016-05-18 03:51:07,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 03:51:07,221 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-18 03:51:07,221 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E626195033F641CB82529A671F67489B, mem on start (mb), free: 94, total: 508, max: 672
2016-05-18 03:51:07,227 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:51:07,228 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:51:07,253 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E626195033F641CB82529A671F67489B, mem on close (mb), free: 94, total: 508, max: 672
2016-05-18 03:51:07,270 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2016-05-18 03:51:07,271 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:00.479
2016-05-18 03:51:07,310 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2016-05-18 03:51:07,331 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:07,332 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:07,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.022
2016-05-18 03:51:07,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:51:07,379 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:07,380 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:07,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 03:51:07,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:07,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:07,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:07,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-18 03:51:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:07,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:07,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2016-05-18 03:51:07,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0003
2016-05-18 03:51:07,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:07,512 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:07,615 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:07,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,624 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C116D30949CF45C6930DA840AB4311FA, ordinal: 0
2016-05-18 03:51:07,625 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:07,626 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:07,626 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C116D30949CF45C6930DA840AB4311FA, mem on start (mb), free: 38, total: 570, max: 672
2016-05-18 03:51:07,632 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C116D30949CF45C6930DA840AB4311FA, mem on close (mb), free: 38, total: 570, max: 672
2016-05-18 03:51:07,644 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:07,644 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,652 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D7ED3D4D708446A4A9A8C0FA37F633F9, ordinal: 1
2016-05-18 03:51:07,653 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:07,653 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-18 03:51:07,654 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7ED3D4D708446A4A9A8C0FA37F633F9, mem on start (mb), free: 37, total: 570, max: 672
2016-05-18 03:51:07,666 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7ED3D4D708446A4A9A8C0FA37F633F9, mem on close (mb), free: 36, total: 570, max: 672
2016-05-18 03:51:07,680 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2016-05-18 03:51:07,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.226
2016-05-18 03:51:07,703 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:07,704 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:07,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 03:51:07,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:07,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:07,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:07,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:07,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-18 03:51:07,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:07,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:07,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:07,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2016-05-18 03:51:07,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0004
2016-05-18 03:51:07,831 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:07,836 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:07,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:07,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D58C899C03914A8E946B18DE2061803D, ordinal: 0
2016-05-18 03:51:07,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:07,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:07,896 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D58C899C03914A8E946B18DE2061803D, mem on start (mb), free: 43, total: 629, max: 672
2016-05-18 03:51:07,902 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D58C899C03914A8E946B18DE2061803D, mem on close (mb), free: 42, total: 629, max: 672
2016-05-18 03:51:07,915 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:07,916 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:07,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E01F6478788340EA9FEC514722353140, ordinal: 1
2016-05-18 03:51:07,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:07,925 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-18 03:51:07,926 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E01F6478788340EA9FEC514722353140, mem on start (mb), free: 41, total: 629, max: 672
2016-05-18 03:51:07,935 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E01F6478788340EA9FEC514722353140, mem on close (mb), free: 40, total: 629, max: 672
2016-05-18 03:51:07,943 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2016-05-18 03:51:07,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.172
2016-05-18 03:51:07,975 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:07,976 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:08,036 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 03:51:08,037 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:08,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:08,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:08,056 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-18 03:51:08,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:08,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:08,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:08,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2016-05-18 03:51:08,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0005
2016-05-18 03:51:08,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:08,115 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:08,130 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:08,130 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B63D6178B0AA4C5F82A08E798091138A, ordinal: 0
2016-05-18 03:51:08,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,140 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B63D6178B0AA4C5F82A08E798091138A, mem on start (mb), free: 44, total: 630, max: 672
2016-05-18 03:51:08,145 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B63D6178B0AA4C5F82A08E798091138A, mem on close (mb), free: 44, total: 630, max: 672
2016-05-18 03:51:08,155 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:08,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,163 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B10392DD7C9E483CAFBBEDC0484AFC57, ordinal: 1
2016-05-18 03:51:08,164 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,164 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-18 03:51:08,164 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B10392DD7C9E483CAFBBEDC0484AFC57, mem on start (mb), free: 42, total: 630, max: 672
2016-05-18 03:51:08,173 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B10392DD7C9E483CAFBBEDC0484AFC57, mem on close (mb), free: 42, total: 630, max: 672
2016-05-18 03:51:08,184 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2016-05-18 03:51:08,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.129
2016-05-18 03:51:08,203 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:08,204 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:08,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 03:51:08,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:08,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:08,271 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:08,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-18 03:51:08,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:08,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:08,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:08,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2016-05-18 03:51:08,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0006
2016-05-18 03:51:08,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:08,344 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:08,360 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:08,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9F4D10A9D4745D398C576F4597A3A73, ordinal: 0
2016-05-18 03:51:08,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,371 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9F4D10A9D4745D398C576F4597A3A73, mem on start (mb), free: 45, total: 630, max: 672
2016-05-18 03:51:08,379 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9F4D10A9D4745D398C576F4597A3A73, mem on close (mb), free: 45, total: 630, max: 672
2016-05-18 03:51:08,392 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:08,393 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FA3273E230154AE8943EE47C38C707D1, ordinal: 1
2016-05-18 03:51:08,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,402 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-18 03:51:08,402 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA3273E230154AE8943EE47C38C707D1, mem on start (mb), free: 43, total: 630, max: 672
2016-05-18 03:51:08,409 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA3273E230154AE8943EE47C38C707D1, mem on close (mb), free: 43, total: 630, max: 672
2016-05-18 03:51:08,424 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2016-05-18 03:51:08,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.152
2016-05-18 03:51:08,441 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:08,442 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:08,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 03:51:08,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:08,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:08,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:08,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-18 03:51:08,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:08,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:08,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:08,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2016-05-18 03:51:08,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0007
2016-05-18 03:51:08,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:08,583 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:08,602 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:08,602 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7C55DB46ED74DBAA0C0DDAB840EC31F, ordinal: 0
2016-05-18 03:51:08,613 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,613 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,613 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7C55DB46ED74DBAA0C0DDAB840EC31F, mem on start (mb), free: 162, total: 746, max: 746
2016-05-18 03:51:08,619 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7C55DB46ED74DBAA0C0DDAB840EC31F, mem on close (mb), free: 161, total: 746, max: 746
2016-05-18 03:51:08,635 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:08,636 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,645 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AD1E133B902745598F4686B6EE24D0D7, ordinal: 1
2016-05-18 03:51:08,646 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,647 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-18 03:51:08,647 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AD1E133B902745598F4686B6EE24D0D7, mem on start (mb), free: 159, total: 746, max: 746
2016-05-18 03:51:08,658 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AD1E133B902745598F4686B6EE24D0D7, mem on close (mb), free: 159, total: 746, max: 746
2016-05-18 03:51:08,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2016-05-18 03:51:08,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.169
2016-05-18 03:51:08,697 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:08,698 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:08,750 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 03:51:08,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:08,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:08,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:08,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-18 03:51:08,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:08,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:08,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:08,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2016-05-18 03:51:08,814 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0008
2016-05-18 03:51:08,815 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:08,821 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:08,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:08,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B02C8BA6D9D64C9B9D3436EDCB4A53C3, ordinal: 0
2016-05-18 03:51:08,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:08,922 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,922 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B02C8BA6D9D64C9B9D3436EDCB4A53C3, mem on start (mb), free: 45, total: 746, max: 746
2016-05-18 03:51:08,927 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B02C8BA6D9D64C9B9D3436EDCB4A53C3, mem on close (mb), free: 44, total: 746, max: 746
2016-05-18 03:51:08,941 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:08,941 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:08,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FD0492378A0B408F8D6E96507080D2FB, ordinal: 1
2016-05-18 03:51:08,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:08,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-18 03:51:08,949 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FD0492378A0B408F8D6E96507080D2FB, mem on start (mb), free: 43, total: 746, max: 746
2016-05-18 03:51:08,958 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FD0492378A0B408F8D6E96507080D2FB, mem on close (mb), free: 43, total: 746, max: 746
2016-05-18 03:51:08,969 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2016-05-18 03:51:08,969 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.199
2016-05-18 03:51:08,994 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:08,995 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:09,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 03:51:09,037 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:09,037 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:09,056 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:09,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-18 03:51:09,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:09,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:09,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:09,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2016-05-18 03:51:09,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0009
2016-05-18 03:51:09,113 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:09,117 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:09,132 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:09,132 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AA181A7418AE41DC8EF46C0318F9BE4B, ordinal: 0
2016-05-18 03:51:09,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA181A7418AE41DC8EF46C0318F9BE4B, mem on start (mb), free: 153, total: 738, max: 738
2016-05-18 03:51:09,143 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA181A7418AE41DC8EF46C0318F9BE4B, mem on close (mb), free: 152, total: 738, max: 738
2016-05-18 03:51:09,155 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:09,155 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,160 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C2D885A9ADF6446280D0A3026030C3F9, ordinal: 1
2016-05-18 03:51:09,161 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,161 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-18 03:51:09,161 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2D885A9ADF6446280D0A3026030C3F9, mem on start (mb), free: 150, total: 738, max: 738
2016-05-18 03:51:09,169 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2D885A9ADF6446280D0A3026030C3F9, mem on close (mb), free: 150, total: 738, max: 738
2016-05-18 03:51:09,176 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2016-05-18 03:51:09,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.120
2016-05-18 03:51:09,196 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:09,197 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:09,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 03:51:09,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:09,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:09,264 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:09,264 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-18 03:51:09,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:09,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:09,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:09,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2016-05-18 03:51:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0010
2016-05-18 03:51:09,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:09,312 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:09,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:09,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F4ADAE9F54A04F32BD5370DCC6F02492, ordinal: 0
2016-05-18 03:51:09,344 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,344 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,345 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4ADAE9F54A04F32BD5370DCC6F02492, mem on start (mb), free: 35, total: 738, max: 738
2016-05-18 03:51:09,352 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4ADAE9F54A04F32BD5370DCC6F02492, mem on close (mb), free: 34, total: 738, max: 738
2016-05-18 03:51:09,369 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:09,370 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,379 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BACC31D2AA4F432699F6026E53ED9DDB, ordinal: 1
2016-05-18 03:51:09,380 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,381 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-18 03:51:09,381 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BACC31D2AA4F432699F6026E53ED9DDB, mem on start (mb), free: 32, total: 738, max: 738
2016-05-18 03:51:09,393 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BACC31D2AA4F432699F6026E53ED9DDB, mem on close (mb), free: 32, total: 738, max: 738
2016-05-18 03:51:09,409 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2016-05-18 03:51:09,410 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.145
2016-05-18 03:51:09,434 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:09,435 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:09,480 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 03:51:09,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:09,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:09,499 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:09,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-18 03:51:09,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:09,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:09,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:09,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2016-05-18 03:51:09,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0011
2016-05-18 03:51:09,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:09,557 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:09,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:09,574 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,580 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C068E0F6FC1A4F75BBDC88A82A0D3C60, ordinal: 0
2016-05-18 03:51:09,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,582 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C068E0F6FC1A4F75BBDC88A82A0D3C60, mem on start (mb), free: 158, total: 745, max: 745
2016-05-18 03:51:09,587 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C068E0F6FC1A4F75BBDC88A82A0D3C60, mem on close (mb), free: 158, total: 745, max: 745
2016-05-18 03:51:09,596 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:09,597 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,602 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E44F2229EBBB4212ADC681E66FD71239, ordinal: 1
2016-05-18 03:51:09,603 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,603 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-18 03:51:09,604 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E44F2229EBBB4212ADC681E66FD71239, mem on start (mb), free: 155, total: 745, max: 745
2016-05-18 03:51:09,611 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E44F2229EBBB4212ADC681E66FD71239, mem on close (mb), free: 155, total: 745, max: 745
2016-05-18 03:51:09,625 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2016-05-18 03:51:09,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.125
2016-05-18 03:51:09,640 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:09,641 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:09,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 03:51:09,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:09,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:09,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:09,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-18 03:51:09,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:09,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:09,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:09,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2016-05-18 03:51:09,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0012
2016-05-18 03:51:09,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:09,728 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:09,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:09,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D088458B9AA947F89CD780BEC46D1B6E, ordinal: 0
2016-05-18 03:51:09,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,750 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D088458B9AA947F89CD780BEC46D1B6E, mem on start (mb), free: 41, total: 745, max: 745
2016-05-18 03:51:09,755 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D088458B9AA947F89CD780BEC46D1B6E, mem on close (mb), free: 40, total: 745, max: 745
2016-05-18 03:51:09,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:09,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,775 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F12726C014344030ABFC50DBF6FB3212, ordinal: 1
2016-05-18 03:51:09,775 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,775 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-18 03:51:09,776 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F12726C014344030ABFC50DBF6FB3212, mem on start (mb), free: 38, total: 745, max: 745
2016-05-18 03:51:09,782 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F12726C014344030ABFC50DBF6FB3212, mem on close (mb), free: 38, total: 745, max: 745
2016-05-18 03:51:09,797 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2016-05-18 03:51:09,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.108
2016-05-18 03:51:09,822 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:09,823 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:09,848 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:51:09,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:09,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:09,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:09,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,861 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-18 03:51:09,861 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:09,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:09,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:09,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2016-05-18 03:51:09,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0013
2016-05-18 03:51:09,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:09,890 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:09,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:09,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B1B908E0A447468FADFBB435E1EA6D2E, ordinal: 0
2016-05-18 03:51:09,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:09,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,915 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1B908E0A447468FADFBB435E1EA6D2E, mem on start (mb), free: 148, total: 745, max: 745
2016-05-18 03:51:09,921 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1B908E0A447468FADFBB435E1EA6D2E, mem on close (mb), free: 148, total: 745, max: 745
2016-05-18 03:51:09,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:09,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:09,941 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F53BC665F085425E9B82F5CA6634E35C, ordinal: 1
2016-05-18 03:51:09,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:09,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-18 03:51:09,942 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F53BC665F085425E9B82F5CA6634E35C, mem on start (mb), free: 146, total: 745, max: 745
2016-05-18 03:51:09,950 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F53BC665F085425E9B82F5CA6634E35C, mem on close (mb), free: 145, total: 745, max: 745
2016-05-18 03:51:09,958 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2016-05-18 03:51:09,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.098
2016-05-18 03:51:09,974 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:09,974 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 03:51:10,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-18 03:51:10,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,022 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2016-05-18 03:51:10,046 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0014
2016-05-18 03:51:10,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,052 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,259 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,265 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F493BB263FAF4739B3E0D64D8488CDF5, ordinal: 0
2016-05-18 03:51:10,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,266 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F493BB263FAF4739B3E0D64D8488CDF5, mem on start (mb), free: 333, total: 439, max: 672
2016-05-18 03:51:10,270 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F493BB263FAF4739B3E0D64D8488CDF5, mem on close (mb), free: 333, total: 439, max: 672
2016-05-18 03:51:10,280 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,280 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A44F627931254D2DA025A1B7DCDA3349, ordinal: 1
2016-05-18 03:51:10,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-18 03:51:10,286 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A44F627931254D2DA025A1B7DCDA3349, mem on start (mb), free: 330, total: 439, max: 672
2016-05-18 03:51:10,292 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A44F627931254D2DA025A1B7DCDA3349, mem on close (mb), free: 330, total: 439, max: 672
2016-05-18 03:51:10,299 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2016-05-18 03:51:10,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.280
2016-05-18 03:51:10,314 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,314 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:51:10,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-18 03:51:10,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2016-05-18 03:51:10,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0015
2016-05-18 03:51:10,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,381 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,397 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1D7C5738D0541B6826D4DDDC82E39C9, ordinal: 0
2016-05-18 03:51:10,406 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,407 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,407 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1D7C5738D0541B6826D4DDDC82E39C9, mem on start (mb), free: 214, total: 439, max: 672
2016-05-18 03:51:10,413 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1D7C5738D0541B6826D4DDDC82E39C9, mem on close (mb), free: 214, total: 439, max: 672
2016-05-18 03:51:10,422 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,422 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,427 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F01ACFDDE54847719B0888EEF24E813D, ordinal: 1
2016-05-18 03:51:10,428 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,428 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-18 03:51:10,429 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F01ACFDDE54847719B0888EEF24E813D, mem on start (mb), free: 213, total: 439, max: 672
2016-05-18 03:51:10,435 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F01ACFDDE54847719B0888EEF24E813D, mem on close (mb), free: 213, total: 439, max: 672
2016-05-18 03:51:10,441 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2016-05-18 03:51:10,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.090
2016-05-18 03:51:10,456 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,457 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:51:10,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-18 03:51:10,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2016-05-18 03:51:10,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0016
2016-05-18 03:51:10,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,524 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BBDD4CCBC2404D5BA91CE516DB1C4A13, ordinal: 0
2016-05-18 03:51:10,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,547 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBDD4CCBC2404D5BA91CE516DB1C4A13, mem on start (mb), free: 232, total: 439, max: 672
2016-05-18 03:51:10,553 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBDD4CCBC2404D5BA91CE516DB1C4A13, mem on close (mb), free: 232, total: 439, max: 672
2016-05-18 03:51:10,562 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,562 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,567 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CAB5FDE01AA14482B9A800736FDA9F76, ordinal: 1
2016-05-18 03:51:10,567 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,567 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-18 03:51:10,568 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CAB5FDE01AA14482B9A800736FDA9F76, mem on start (mb), free: 229, total: 439, max: 672
2016-05-18 03:51:10,575 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CAB5FDE01AA14482B9A800736FDA9F76, mem on close (mb), free: 229, total: 439, max: 672
2016-05-18 03:51:10,582 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2016-05-18 03:51:10,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.087
2016-05-18 03:51:10,598 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,598 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 03:51:10,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-18 03:51:10,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2016-05-18 03:51:10,662 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0017
2016-05-18 03:51:10,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,666 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,680 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,680 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D171A739EF99421A89BBEB367EA894D6, ordinal: 0
2016-05-18 03:51:10,687 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,687 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,687 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D171A739EF99421A89BBEB367EA894D6, mem on start (mb), free: 114, total: 439, max: 672
2016-05-18 03:51:10,691 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D171A739EF99421A89BBEB367EA894D6, mem on close (mb), free: 114, total: 439, max: 672
2016-05-18 03:51:10,700 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,700 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,705 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CF7DE5D68ACB4ECF94B8D4572A9925EC, ordinal: 1
2016-05-18 03:51:10,705 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,705 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-18 03:51:10,705 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CF7DE5D68ACB4ECF94B8D4572A9925EC, mem on start (mb), free: 113, total: 439, max: 672
2016-05-18 03:51:10,711 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CF7DE5D68ACB4ECF94B8D4572A9925EC, mem on close (mb), free: 113, total: 439, max: 672
2016-05-18 03:51:10,725 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2016-05-18 03:51:10,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.089
2016-05-18 03:51:10,740 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,741 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 03:51:10,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-18 03:51:10,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2016-05-18 03:51:10,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0018
2016-05-18 03:51:10,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,817 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,833 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F0D5056BD9CE4F13B504CFDA998B9CB3, ordinal: 0
2016-05-18 03:51:10,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,840 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0D5056BD9CE4F13B504CFDA998B9CB3, mem on start (mb), free: 229, total: 439, max: 672
2016-05-18 03:51:10,844 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0D5056BD9CE4F13B504CFDA998B9CB3, mem on close (mb), free: 229, total: 439, max: 672
2016-05-18 03:51:10,853 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,853 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F61AA1F9FF694CA1A63B0CB70B98CAC2, ordinal: 1
2016-05-18 03:51:10,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,860 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-18 03:51:10,861 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F61AA1F9FF694CA1A63B0CB70B98CAC2, mem on start (mb), free: 228, total: 439, max: 672
2016-05-18 03:51:10,868 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F61AA1F9FF694CA1A63B0CB70B98CAC2, mem on close (mb), free: 228, total: 439, max: 672
2016-05-18 03:51:10,876 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2016-05-18 03:51:10,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.095
2016-05-18 03:51:10,892 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,892 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:10,916 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 03:51:10,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:10,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-18 03:51:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:10,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2016-05-18 03:51:10,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0019
2016-05-18 03:51:10,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:10,959 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:10,974 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:10,975 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,980 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB179ACAD9034BE0AC048E2F5B8A06C0, ordinal: 0
2016-05-18 03:51:10,980 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:10,981 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:10,981 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB179ACAD9034BE0AC048E2F5B8A06C0, mem on start (mb), free: 113, total: 439, max: 672
2016-05-18 03:51:10,986 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB179ACAD9034BE0AC048E2F5B8A06C0, mem on close (mb), free: 113, total: 439, max: 672
2016-05-18 03:51:10,994 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:10,995 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:10,999 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BF766CB2077B45919C32BD3DEC001942, ordinal: 1
2016-05-18 03:51:11,000 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,000 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-18 03:51:11,000 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BF766CB2077B45919C32BD3DEC001942, mem on start (mb), free: 111, total: 439, max: 672
2016-05-18 03:51:11,007 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BF766CB2077B45919C32BD3DEC001942, mem on close (mb), free: 111, total: 439, max: 672
2016-05-18 03:51:11,017 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2016-05-18 03:51:11,018 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.091
2016-05-18 03:51:11,033 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,033 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:51:11,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-18 03:51:11,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2016-05-18 03:51:11,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0020
2016-05-18 03:51:11,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,103 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,119 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,124 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C41F2706260B4C18A16A07633CB899FE, ordinal: 0
2016-05-18 03:51:11,125 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,125 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,125 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C41F2706260B4C18A16A07633CB899FE, mem on start (mb), free: 228, total: 439, max: 672
2016-05-18 03:51:11,129 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C41F2706260B4C18A16A07633CB899FE, mem on close (mb), free: 227, total: 439, max: 672
2016-05-18 03:51:11,144 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,144 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,150 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B188134C0B3E4C379ECB128CFA49B01A, ordinal: 1
2016-05-18 03:51:11,151 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,151 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-18 03:51:11,152 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B188134C0B3E4C379ECB128CFA49B01A, mem on start (mb), free: 225, total: 439, max: 672
2016-05-18 03:51:11,161 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B188134C0B3E4C379ECB128CFA49B01A, mem on close (mb), free: 225, total: 439, max: 672
2016-05-18 03:51:11,173 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2016-05-18 03:51:11,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.104
2016-05-18 03:51:11,188 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,188 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 03:51:11,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,237 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-18 03:51:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2016-05-18 03:51:11,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0021
2016-05-18 03:51:11,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,266 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,283 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,283 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CB5560892A4F4ECCAA9EE453A4C1C264, ordinal: 0
2016-05-18 03:51:11,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,290 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB5560892A4F4ECCAA9EE453A4C1C264, mem on start (mb), free: 112, total: 439, max: 672
2016-05-18 03:51:11,295 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB5560892A4F4ECCAA9EE453A4C1C264, mem on close (mb), free: 111, total: 439, max: 672
2016-05-18 03:51:11,305 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,305 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,310 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AF97432F30DD44DCBD0D6E57382BF191, ordinal: 1
2016-05-18 03:51:11,311 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,311 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-18 03:51:11,311 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AF97432F30DD44DCBD0D6E57382BF191, mem on start (mb), free: 109, total: 439, max: 672
2016-05-18 03:51:11,318 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AF97432F30DD44DCBD0D6E57382BF191, mem on close (mb), free: 109, total: 439, max: 672
2016-05-18 03:51:11,326 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2016-05-18 03:51:11,327 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.089
2016-05-18 03:51:11,341 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,342 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 03:51:11,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-18 03:51:11,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2016-05-18 03:51:11,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0022
2016-05-18 03:51:11,410 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,412 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,426 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,427 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,433 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A76578371BB045F4B65C1E9411D9B8D7, ordinal: 0
2016-05-18 03:51:11,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,434 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A76578371BB045F4B65C1E9411D9B8D7, mem on start (mb), free: 227, total: 439, max: 672
2016-05-18 03:51:11,439 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A76578371BB045F4B65C1E9411D9B8D7, mem on close (mb), free: 226, total: 439, max: 672
2016-05-18 03:51:11,451 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,452 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,457 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BD8BE22344FD47999A0623908238501C, ordinal: 1
2016-05-18 03:51:11,458 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,458 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-18 03:51:11,459 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD8BE22344FD47999A0623908238501C, mem on start (mb), free: 224, total: 439, max: 672
2016-05-18 03:51:11,466 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD8BE22344FD47999A0623908238501C, mem on close (mb), free: 224, total: 439, max: 672
2016-05-18 03:51:11,472 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2016-05-18 03:51:11,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.093
2016-05-18 03:51:11,487 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,488 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 03:51:11,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,523 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-18 03:51:11,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2016-05-18 03:51:11,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0023
2016-05-18 03:51:11,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,555 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E23F9E789A244B9F932C093CC3801F60, ordinal: 0
2016-05-18 03:51:11,578 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,579 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E23F9E789A244B9F932C093CC3801F60, mem on start (mb), free: 111, total: 439, max: 672
2016-05-18 03:51:11,586 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E23F9E789A244B9F932C093CC3801F60, mem on close (mb), free: 110, total: 439, max: 672
2016-05-18 03:51:11,599 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,599 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,606 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE7C2F401132423E90DF47D47C9ED4B8, ordinal: 1
2016-05-18 03:51:11,606 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,607 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-18 03:51:11,607 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE7C2F401132423E90DF47D47C9ED4B8, mem on start (mb), free: 108, total: 439, max: 672
2016-05-18 03:51:11,615 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE7C2F401132423E90DF47D47C9ED4B8, mem on close (mb), free: 107, total: 439, max: 672
2016-05-18 03:51:11,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2016-05-18 03:51:11,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.105
2016-05-18 03:51:11,650 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,651 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 03:51:11,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-18 03:51:11,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,695 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2016-05-18 03:51:11,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0024
2016-05-18 03:51:11,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,722 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2D03F750E8D41EDAAAF21549EF952D1, ordinal: 0
2016-05-18 03:51:11,742 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,742 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,742 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2D03F750E8D41EDAAAF21549EF952D1, mem on start (mb), free: 224, total: 438, max: 672
2016-05-18 03:51:11,747 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2D03F750E8D41EDAAAF21549EF952D1, mem on close (mb), free: 223, total: 438, max: 672
2016-05-18 03:51:11,755 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,756 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,759 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F2885EBF202344D694B3380A612BC2ED, ordinal: 1
2016-05-18 03:51:11,759 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,760 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-18 03:51:11,760 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2885EBF202344D694B3380A612BC2ED, mem on start (mb), free: 221, total: 438, max: 672
2016-05-18 03:51:11,765 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2885EBF202344D694B3380A612BC2ED, mem on close (mb), free: 221, total: 438, max: 672
2016-05-18 03:51:11,771 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2016-05-18 03:51:11,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.081
2016-05-18 03:51:11,786 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,786 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:51:11,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-18 03:51:11,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2016-05-18 03:51:11,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0025
2016-05-18 03:51:11,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,855 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,871 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,872 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5ED6C5DA38B42E99AEE47BB2C5F62F0, ordinal: 0
2016-05-18 03:51:11,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,878 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5ED6C5DA38B42E99AEE47BB2C5F62F0, mem on start (mb), free: 108, total: 438, max: 672
2016-05-18 03:51:11,883 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5ED6C5DA38B42E99AEE47BB2C5F62F0, mem on close (mb), free: 107, total: 438, max: 672
2016-05-18 03:51:11,894 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:11,894 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:11,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DBAA1A1B456C40D3987E50316BF2DCFC, ordinal: 1
2016-05-18 03:51:11,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:11,900 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-18 03:51:11,900 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBAA1A1B456C40D3987E50316BF2DCFC, mem on start (mb), free: 105, total: 438, max: 672
2016-05-18 03:51:11,906 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBAA1A1B456C40D3987E50316BF2DCFC, mem on close (mb), free: 105, total: 438, max: 672
2016-05-18 03:51:11,911 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2016-05-18 03:51:11,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.088
2016-05-18 03:51:11,925 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:11,925 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:51:11,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 03:51:11,949 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:11,949 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:51:11,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 03:51:11,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:11,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-18 03:51:11,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 03:51:11,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 03:51:11,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 03:51:11,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2016-05-18 03:51:11,981 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local_0026
2016-05-18 03:51:11,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 03:51:11,984 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 03:51:11,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:51:11,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:51:12,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EE907D7921C4430D836B08A96A6CD534, ordinal: 0
2016-05-18 03:51:12,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 03:51:12,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:12,003 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE907D7921C4430D836B08A96A6CD534, mem on start (mb), free: 223, total: 439, max: 672
2016-05-18 03:51:12,007 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE907D7921C4430D836B08A96A6CD534, mem on close (mb), free: 223, total: 439, max: 672
2016-05-18 03:51:12,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:51:12,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:51:12,019 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A2DEC1E70A6D4A1B99A4526783CBA87A, ordinal: 1
2016-05-18 03:51:12,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 03:51:12,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-18 03:51:12,020 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A2DEC1E70A6D4A1B99A4526783CBA87A, mem on start (mb), free: 220, total: 439, max: 672
2016-05-18 03:51:12,025 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A2DEC1E70A6D4A1B99A4526783CBA87A, mem on close (mb), free: 220, total: 439, max: 672
2016-05-18 03:51:12,033 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2016-05-18 03:51:12,034 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.074
2016-05-18 03:51:12,041 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2016-05-18 03:51:12,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2016-05-18 03:51:12,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2016-05-18 03:51:12,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2016-05-18 03:51:12,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2016-05-18 03:51:12,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2016-05-18 03:51:12,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2016-05-18 03:51:12,044 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2016-05-18 03:51:12,044 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2016-05-18 03:51:12,045 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2016-05-18 03:51:12,045 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2016-05-18 03:51:12,045 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2016-05-18 03:51:12,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2016-05-18 03:51:12,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2016-05-18 03:51:12,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true
2016-05-18 03:51:12,049 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2016-05-18 03:51:12,050 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2016-05-18 03:51:12,051 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2016-05-18 03:51:12,051 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2016-05-18 03:51:12,051 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2016-05-18 03:51:12,052 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2016-05-18 03:51:12,052 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2016-05-18 03:51:12,052 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2016-05-18 03:51:12,053 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false