2016-05-18 05:23:42,119 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:23:42,137 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop
2016-05-18 05:23:42,168 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 05:23:42,400 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:23:42,517 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:42,519 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 05:23:42,647 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: F465FF9210234908B1038161921EB2A2
2016-05-18 05:23:42,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.198
2016-05-18 05:23:42,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:42,897 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 05:23:43,116 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 05:23:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-18 05:23:43,119 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.2.x/build/classes/test/data/apache.200.txt"]
2016-05-18 05:23:43,119 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 05:23:43,120 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.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-18 05:23:43,120 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-18 05:23:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-18 05:23:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-18 05:23:43,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2016-05-18 05:23:43,163 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 05:23:43,224 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 05:23:43,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local199536307_0001
2016-05-18 05:23:43,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-18 05:23:43,595 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.200.txt
2016-05-18 05:23:43,757 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:43,758 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:43,782 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E37D748E63F74607938593E33C18ACD9, ordinal: 0
2016-05-18 05:23:43,824 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.2.x/build/classes/test/data/apache.200.txt"]
2016-05-18 05:23:43,825 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:43,827 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E37D748E63F74607938593E33C18ACD9, mem on start (mb), free: 79, total: 223, max: 672
2016-05-18 05:23:43,898 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E37D748E63F74607938593E33C18ACD9, mem on close (mb), free: 78, total: 223, max: 672
2016-05-18 05:23:43,931 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 05:23:44,031 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:44,032 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:44,052 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E37D748E63F74607938593E33C18ACD9, ordinal: 0
2016-05-18 05:23:44,053 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 05:23:44,054 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:44,054 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E37D748E63F74607938593E33C18ACD9, mem on start (mb), free: 71, total: 318, max: 672
2016-05-18 05:23:44,059 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E37D748E63F74607938593E33C18ACD9, mem on close (mb), free: 71, total: 318, max: 672
2016-05-18 05:23:44,096 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:44,097 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:44,109 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B1F225E11116427AAAE64F37440C021C, ordinal: 1
2016-05-18 05:23:44,113 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:44,113 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.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-05-18 05:23:44,113 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1F225E11116427AAAE64F37440C021C, mem on start (mb), free: 69, total: 318, max: 672
2016-05-18 05:23:44,131 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 05:23:44,131 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 05:23:44,169 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1F225E11116427AAAE64F37440C021C, mem on close (mb), free: 68, total: 318, max: 672
2016-05-18 05:23:44,183 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2016-05-18 05:23:44,184 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:01.064
2016-05-18 05:23:44,229 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2016-05-18 05:23:44,254 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:44,255 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 05:23:44,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2016-05-18 05:23:44,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:44,388 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 05:23:44,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting
2016-05-18 05:23:44,442 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.2.x/build/classes/test/data/apache.200.txt"]
2016-05-18 05:23:44,443 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 05:23:44,444 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.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-18 05:23:44,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] parallel execution of steps is enabled: false
2016-05-18 05:23:44,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] executing total steps: 1
2016-05-18 05:23:44,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] allocating management threads: 1
2016-05-18 05:23:44,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2016-05-18 05:23:44,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] submitted hadoop job: job_local1748001282_0002
2016-05-18 05:23:44,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] tracking url: http://localhost:8080/
2016-05-18 05:23:44,579 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.200.txt
2016-05-18 05:23:44,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:44,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:44,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, ordinal: 0
2016-05-18 05:23:44,694 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.2.x/build/classes/test/data/apache.200.txt"]
2016-05-18 05:23:44,694 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:44,694 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, mem on start (mb), free: 106, total: 414, max: 672
2016-05-18 05:23:44,741 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, mem on close (mb), free: 105, total: 414, max: 672
2016-05-18 05:23:44,763 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 05:23:44,858 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:44,859 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:44,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, ordinal: 0
2016-05-18 05:23:44,879 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 05:23:44,879 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:44,880 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, mem on start (mb), free: 99, total: 509, max: 672
2016-05-18 05:23:44,883 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C459D03C21564BE7BDCE275B5CFB6443, mem on close (mb), free: 99, total: 509, max: 672
2016-05-18 05:23:44,900 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:44,900 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:44,910 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BEAF3D04879A47E1896CF8D0D0878B19, ordinal: 1
2016-05-18 05:23:44,911 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-05-18 05:23:44,911 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.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-05-18 05:23:44,911 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BEAF3D04879A47E1896CF8D0D0878B19, mem on start (mb), free: 97, total: 509, max: 672
2016-05-18 05:23:44,917 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 05:23:44,918 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 05:23:44,944 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BEAF3D04879A47E1896CF8D0D0878B19, mem on close (mb), free: 97, total: 509, max: 672
2016-05-18 05:23:44,958 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2016-05-18 05:23:44,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache*ip] completed in: 00:00.517
2016-05-18 05:23:45,005 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2016-05-18 05:23:45,033 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:45,034 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 05:23:45,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.039
2016-05-18 05:23:45,080 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:23:45,104 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:45,105 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 05:23:45,189 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2016-05-18 05:23:45,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:45,191 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 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-18 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:45,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:45,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2016-05-18 05:23:45,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local575533557_0003
2016-05-18 05:23:45,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:45,274 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:45,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:45,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:45,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B80E95D751324FF1825837CE303736F5, ordinal: 0
2016-05-18 05:23:45,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:45,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:45,383 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E95D751324FF1825837CE303736F5, mem on start (mb), free: 43, total: 572, max: 672
2016-05-18 05:23:45,390 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E95D751324FF1825837CE303736F5, mem on close (mb), free: 43, total: 572, max: 672
2016-05-18 05:23:45,405 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:45,406 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:45,413 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CB8EE801E4C64821B794ACDE23C87F44, ordinal: 1
2016-05-18 05:23:45,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:45,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-05-18 05:23:45,414 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB8EE801E4C64821B794ACDE23C87F44, mem on start (mb), free: 42, total: 572, max: 672
2016-05-18 05:23:45,424 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB8EE801E4C64821B794ACDE23C87F44, mem on close (mb), free: 41, total: 572, max: 672
2016-05-18 05:23:45,445 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2016-05-18 05:23:45,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.227
2016-05-18 05:23:45,465 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:45,466 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 05:23:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 05:23:45,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:45,510 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 05:23:45,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:45,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:45,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-18 05:23:45,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:45,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:45,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:45,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2016-05-18 05:23:45,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local808415586_0004
2016-05-18 05:23:45,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:45,592 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:45,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:45,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:45,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2B8B36F9C524F018A5C9F7A465A8AF8, ordinal: 0
2016-05-18 05:23:45,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:45,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:45,840 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B8B36F9C524F018A5C9F7A465A8AF8, mem on start (mb), free: 144, total: 251, max: 672
2016-05-18 05:23:45,846 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B8B36F9C524F018A5C9F7A465A8AF8, mem on close (mb), free: 144, total: 251, max: 672
2016-05-18 05:23:45,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:45,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:45,865 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DA2ADFE5ABF64C8FA42FF6BD68577511, ordinal: 1
2016-05-18 05:23:45,866 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:45,866 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-05-18 05:23:45,866 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DA2ADFE5ABF64C8FA42FF6BD68577511, mem on start (mb), free: 142, total: 251, max: 672
2016-05-18 05:23:45,873 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DA2ADFE5ABF64C8FA42FF6BD68577511, mem on close (mb), free: 142, total: 251, max: 672
2016-05-18 05:23:45,889 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2016-05-18 05:23:45,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.354
2016-05-18 05:23:45,914 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:45,915 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 05:23:45,965 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 05:23:45,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:45,968 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 05:23:45,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-18 05:23:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:45,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2016-05-18 05:23:46,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1156879517_0005
2016-05-18 05:23:46,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:46,030 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:46,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:46,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A2440216436C4D49B13246D47E991D64, ordinal: 0
2016-05-18 05:23:46,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,137 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2440216436C4D49B13246D47E991D64, mem on start (mb), free: 125, total: 346, max: 672
2016-05-18 05:23:46,142 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2440216436C4D49B13246D47E991D64, mem on close (mb), free: 125, total: 346, max: 672
2016-05-18 05:23:46,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:46,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,160 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D51EAC8D13F0454A965634F8171FCAA9, ordinal: 1
2016-05-18 05:23:46,160 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,160 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-05-18 05:23:46,161 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D51EAC8D13F0454A965634F8171FCAA9, mem on start (mb), free: 124, total: 346, max: 672
2016-05-18 05:23:46,168 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D51EAC8D13F0454A965634F8171FCAA9, mem on close (mb), free: 124, total: 346, max: 672
2016-05-18 05:23:46,191 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2016-05-18 05:23:46,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.206
2016-05-18 05:23:46,215 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:46,215 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 05:23:46,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 05:23:46,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:46,259 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 05:23:46,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:46,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-18 05:23:46,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:46,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:46,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:46,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2016-05-18 05:23:46,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local115195661_0006
2016-05-18 05:23:46,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:46,321 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:46,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:46,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,423 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF210A0887A24E5B95273477EEDADEE6, ordinal: 0
2016-05-18 05:23:46,424 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,424 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,425 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF210A0887A24E5B95273477EEDADEE6, mem on start (mb), free: 107, total: 442, max: 672
2016-05-18 05:23:46,431 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF210A0887A24E5B95273477EEDADEE6, mem on close (mb), free: 107, total: 442, max: 672
2016-05-18 05:23:46,445 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:46,445 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,455 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EBA54DBFBFF74459A8E3E1D479A97FEF, ordinal: 1
2016-05-18 05:23:46,455 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,455 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-05-18 05:23:46,455 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBA54DBFBFF74459A8E3E1D479A97FEF, mem on start (mb), free: 106, total: 442, max: 672
2016-05-18 05:23:46,463 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBA54DBFBFF74459A8E3E1D479A97FEF, mem on close (mb), free: 106, total: 442, max: 672
2016-05-18 05:23:46,477 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2016-05-18 05:23:46,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.201
2016-05-18 05:23:46,496 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:46,497 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 05:23:46,541 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 05:23:46,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:46,542 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 05:23:46,569 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:46,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-18 05:23:46,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:46,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:46,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:46,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2016-05-18 05:23:46,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1656804139_0007
2016-05-18 05:23:46,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:46,629 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:46,752 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:46,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,759 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBBB480E6AC9435B9600371F46E10F79, ordinal: 0
2016-05-18 05:23:46,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,761 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBBB480E6AC9435B9600371F46E10F79, mem on start (mb), free: 139, total: 537, max: 672
2016-05-18 05:23:46,766 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBBB480E6AC9435B9600371F46E10F79, mem on close (mb), free: 139, total: 537, max: 672
2016-05-18 05:23:46,777 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:46,777 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:46,786 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C7EEE7F117E446B4A8703EBEEB7876F6, ordinal: 1
2016-05-18 05:23:46,786 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:46,787 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-05-18 05:23:46,787 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7EEE7F117E446B4A8703EBEEB7876F6, mem on start (mb), free: 138, total: 537, max: 672
2016-05-18 05:23:46,799 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7EEE7F117E446B4A8703EBEEB7876F6, mem on close (mb), free: 137, total: 537, max: 672
2016-05-18 05:23:46,817 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2016-05-18 05:23:46,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.248
2016-05-18 05:23:46,836 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:46,836 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 05:23:46,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 05:23:46,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:46,879 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 05:23:46,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:46,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:46,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-18 05:23:46,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:46,895 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:46,895 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:46,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2016-05-18 05:23:46,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local862833327_0008
2016-05-18 05:23:46,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:46,942 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:47,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:47,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F63F57243ADB4E7791EB5E1607BA1984, ordinal: 0
2016-05-18 05:23:47,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,051 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F63F57243ADB4E7791EB5E1607BA1984, mem on start (mb), free: 60, total: 572, max: 672
2016-05-18 05:23:47,056 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F63F57243ADB4E7791EB5E1607BA1984, mem on close (mb), free: 59, total: 572, max: 672
2016-05-18 05:23:47,071 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:47,071 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,077 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CDBC766BC21641D3B2470D1D4318CA16, ordinal: 1
2016-05-18 05:23:47,077 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,078 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-05-18 05:23:47,078 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CDBC766BC21641D3B2470D1D4318CA16, mem on start (mb), free: 58, total: 572, max: 672
2016-05-18 05:23:47,085 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CDBC766BC21641D3B2470D1D4318CA16, mem on close (mb), free: 58, total: 572, max: 672
2016-05-18 05:23:47,099 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2016-05-18 05:23:47,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.205
2016-05-18 05:23:47,121 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:47,121 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 05:23:47,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 05:23:47,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:47,159 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 05:23:47,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:47,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-18 05:23:47,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:47,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:47,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:47,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2016-05-18 05:23:47,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1112546412_0009
2016-05-18 05:23:47,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:47,207 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:47,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:47,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,259 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4A037775DD84C239FA49492B16E59AB, ordinal: 0
2016-05-18 05:23:47,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,261 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4A037775DD84C239FA49492B16E59AB, mem on start (mb), free: 34, total: 622, max: 672
2016-05-18 05:23:47,267 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4A037775DD84C239FA49492B16E59AB, mem on close (mb), free: 34, total: 622, max: 672
2016-05-18 05:23:47,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:47,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BBD8D2198EA14329BFD4E6C59450A983, ordinal: 1
2016-05-18 05:23:47,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-05-18 05:23:47,288 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BBD8D2198EA14329BFD4E6C59450A983, mem on start (mb), free: 32, total: 622, max: 672
2016-05-18 05:23:47,295 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BBD8D2198EA14329BFD4E6C59450A983, mem on close (mb), free: 32, total: 622, max: 672
2016-05-18 05:23:47,309 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2016-05-18 05:23:47,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.134
2016-05-18 05:23:47,340 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:47,341 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 05:23:47,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 05:23:47,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:47,380 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 05:23:47,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:47,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-18 05:23:47,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:47,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:47,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:47,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2016-05-18 05:23:47,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1413760146_0010
2016-05-18 05:23:47,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:47,459 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:47,476 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:47,476 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,481 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C03DA20E1B8A495EAEE081B68B882499, ordinal: 0
2016-05-18 05:23:47,482 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,482 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,482 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C03DA20E1B8A495EAEE081B68B882499, mem on start (mb), free: 31, total: 624, max: 672
2016-05-18 05:23:47,487 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C03DA20E1B8A495EAEE081B68B882499, mem on close (mb), free: 31, total: 624, max: 672
2016-05-18 05:23:47,502 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:47,503 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,512 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B5E49292236D4B9C8365193C92932786, ordinal: 1
2016-05-18 05:23:47,513 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,513 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-05-18 05:23:47,515 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B5E49292236D4B9C8365193C92932786, mem on start (mb), free: 30, total: 624, max: 672
2016-05-18 05:23:47,525 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B5E49292236D4B9C8365193C92932786, mem on close (mb), free: 30, total: 624, max: 672
2016-05-18 05:23:47,536 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2016-05-18 05:23:47,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.135
2016-05-18 05:23:47,570 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:47,571 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 05:23:47,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:23:47,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:47,602 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 05:23:47,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:47,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-18 05:23:47,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:47,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:47,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:47,623 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2016-05-18 05:23:47,650 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local493991605_0011
2016-05-18 05:23:47,651 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:47,656 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:47,671 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:47,671 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,677 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE4352D8C3994D6EB6B5741984106C3C, ordinal: 0
2016-05-18 05:23:47,678 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,679 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4352D8C3994D6EB6B5741984106C3C, mem on start (mb), free: 118, total: 716, max: 716
2016-05-18 05:23:47,683 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4352D8C3994D6EB6B5741984106C3C, mem on close (mb), free: 118, total: 716, max: 716
2016-05-18 05:23:47,696 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:47,697 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,707 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C68B4A4A56D34C95A052FB2028C97BA5, ordinal: 1
2016-05-18 05:23:47,707 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,708 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-05-18 05:23:47,708 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C68B4A4A56D34C95A052FB2028C97BA5, mem on start (mb), free: 117, total: 716, max: 716
2016-05-18 05:23:47,715 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C68B4A4A56D34C95A052FB2028C97BA5, mem on close (mb), free: 116, total: 716, max: 716
2016-05-18 05:23:47,724 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2016-05-18 05:23:47,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.105
2016-05-18 05:23:47,743 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:47,743 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 05:23:47,778 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:23:47,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:47,779 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 05:23:47,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:47,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-18 05:23:47,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:47,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:47,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:47,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2016-05-18 05:23:47,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1173633516_0012
2016-05-18 05:23:47,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:47,831 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:47,986 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:47,986 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:47,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F3251860507E486ABAB1ECEEA5CBE6E4, ordinal: 0
2016-05-18 05:23:47,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:47,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:47,992 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3251860507E486ABAB1ECEEA5CBE6E4, mem on start (mb), free: 206, total: 314, max: 672
2016-05-18 05:23:47,997 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3251860507E486ABAB1ECEEA5CBE6E4, mem on close (mb), free: 206, total: 314, max: 672
2016-05-18 05:23:48,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,009 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EDC5A5E0E1804E5DB41BF5DB11C6A1D3, ordinal: 1
2016-05-18 05:23:48,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,017 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-05-18 05:23:48,017 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EDC5A5E0E1804E5DB41BF5DB11C6A1D3, mem on start (mb), free: 203, total: 314, max: 672
2016-05-18 05:23:48,024 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EDC5A5E0E1804E5DB41BF5DB11C6A1D3, mem on close (mb), free: 203, total: 314, max: 672
2016-05-18 05:23:48,034 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2016-05-18 05:23:48,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.239
2016-05-18 05:23:48,050 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,051 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 05:23:48,078 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:23:48,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,079 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 05:23:48,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-18 05:23:48,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2016-05-18 05:23:48,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local798239846_0013
2016-05-18 05:23:48,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:48,123 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:48,146 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:48,146 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,151 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E073E61B786547EC90C72B237A86AB01, ordinal: 0
2016-05-18 05:23:48,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,152 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E073E61B786547EC90C72B237A86AB01, mem on start (mb), free: 228, total: 342, max: 672
2016-05-18 05:23:48,158 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E073E61B786547EC90C72B237A86AB01, mem on close (mb), free: 228, total: 342, max: 672
2016-05-18 05:23:48,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,170 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A066B1B650AC47E5A0D8871B975120F7, ordinal: 1
2016-05-18 05:23:48,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,176 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-05-18 05:23:48,176 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A066B1B650AC47E5A0D8871B975120F7, mem on start (mb), free: 225, total: 342, max: 672
2016-05-18 05:23:48,182 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A066B1B650AC47E5A0D8871B975120F7, mem on close (mb), free: 225, total: 342, max: 672
2016-05-18 05:23:48,194 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2016-05-18 05:23:48,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.104
2016-05-18 05:23:48,217 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,217 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 05:23:48,245 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 05:23:48,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,246 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 05:23:48,262 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-18 05:23:48,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,264 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,264 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2016-05-18 05:23:48,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1886796982_0014
2016-05-18 05:23:48,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:48,297 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:48,388 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:48,389 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,394 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F62C1425AACA4F67839C35042A3E4311, ordinal: 0
2016-05-18 05:23:48,395 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,396 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,396 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F62C1425AACA4F67839C35042A3E4311, mem on start (mb), free: 109, total: 342, max: 672
2016-05-18 05:23:48,401 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F62C1425AACA4F67839C35042A3E4311, mem on close (mb), free: 109, total: 342, max: 672
2016-05-18 05:23:48,413 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,418 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BA62291CE5374C4D8F7FC968F945F6D4, ordinal: 1
2016-05-18 05:23:48,418 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,418 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-05-18 05:23:48,418 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA62291CE5374C4D8F7FC968F945F6D4, mem on start (mb), free: 105, total: 342, max: 672
2016-05-18 05:23:48,425 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA62291CE5374C4D8F7FC968F945F6D4, mem on close (mb), free: 105, total: 342, max: 672
2016-05-18 05:23:48,436 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2016-05-18 05:23:48,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.174
2016-05-18 05:23:48,455 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,455 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 05:23:48,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:23:48,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,483 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 05:23:48,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-18 05:23:48,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2016-05-18 05:23:48,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local264381324_0015
2016-05-18 05:23:48,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:48,532 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:48,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:48,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,555 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE8C1CA7C7B64CA98C3AD53A22002593, ordinal: 0
2016-05-18 05:23:48,556 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,556 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,557 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE8C1CA7C7B64CA98C3AD53A22002593, mem on start (mb), free: 224, total: 342, max: 672
2016-05-18 05:23:48,563 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE8C1CA7C7B64CA98C3AD53A22002593, mem on close (mb), free: 224, total: 342, max: 672
2016-05-18 05:23:48,572 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,572 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,577 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F748B098C76B493697CC5F3D89A2322F, ordinal: 1
2016-05-18 05:23:48,577 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-05-18 05:23:48,578 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F748B098C76B493697CC5F3D89A2322F, mem on start (mb), free: 222, total: 342, max: 672
2016-05-18 05:23:48,584 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F748B098C76B493697CC5F3D89A2322F, mem on close (mb), free: 222, total: 342, max: 672
2016-05-18 05:23:48,592 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2016-05-18 05:23:48,592 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.098
2016-05-18 05:23:48,607 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,607 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 05:23:48,633 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:23:48,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,634 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 05:23:48,644 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,644 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-18 05:23:48,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2016-05-18 05:23:48,675 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1134505057_0016
2016-05-18 05:23:48,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:48,679 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:48,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:48,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB613F6245C34950BF8E9D30FD5B5880, ordinal: 0
2016-05-18 05:23:48,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,699 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB613F6245C34950BF8E9D30FD5B5880, mem on start (mb), free: 108, total: 342, max: 672
2016-05-18 05:23:48,702 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB613F6245C34950BF8E9D30FD5B5880, mem on close (mb), free: 108, total: 342, max: 672
2016-05-18 05:23:48,711 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,712 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,716 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D9B131FA569B491E8E13B7EFC249E86D, ordinal: 1
2016-05-18 05:23:48,716 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,716 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-05-18 05:23:48,716 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D9B131FA569B491E8E13B7EFC249E86D, mem on start (mb), free: 106, total: 342, max: 672
2016-05-18 05:23:48,724 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D9B131FA569B491E8E13B7EFC249E86D, mem on close (mb), free: 106, total: 342, max: 672
2016-05-18 05:23:48,738 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2016-05-18 05:23:48,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.094
2016-05-18 05:23:48,753 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,753 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 05:23:48,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 05:23:48,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,783 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 05:23:48,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-18 05:23:48,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2016-05-18 05:23:48,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1367935636_0017
2016-05-18 05:23:48,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:48,836 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:48,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:48,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA13CE53F82542108FF602722B5A09CA, ordinal: 0
2016-05-18 05:23:48,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,857 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA13CE53F82542108FF602722B5A09CA, mem on start (mb), free: 224, total: 341, max: 672
2016-05-18 05:23:48,861 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA13CE53F82542108FF602722B5A09CA, mem on close (mb), free: 224, total: 341, max: 672
2016-05-18 05:23:48,868 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:48,869 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:48,873 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C38C86BD6DE64C549A8CE217EFC55DBA, ordinal: 1
2016-05-18 05:23:48,873 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:48,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-05-18 05:23:48,874 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C38C86BD6DE64C549A8CE217EFC55DBA, mem on start (mb), free: 222, total: 341, max: 672
2016-05-18 05:23:48,882 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C38C86BD6DE64C549A8CE217EFC55DBA, mem on close (mb), free: 222, total: 341, max: 672
2016-05-18 05:23:48,897 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2016-05-18 05:23:48,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.103
2016-05-18 05:23:48,915 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:48,916 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 05:23:48,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 05:23:48,945 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:48,945 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 05:23:48,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:48,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:48,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-18 05:23:48,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:48,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:48,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:48,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2016-05-18 05:23:48,996 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1667029177_0018
2016-05-18 05:23:48,997 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,003 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,028 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBF8E6B6D296410DBD8344F619C21DBF, ordinal: 0
2016-05-18 05:23:49,029 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,029 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,030 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBF8E6B6D296410DBD8344F619C21DBF, mem on start (mb), free: 108, total: 341, max: 672
2016-05-18 05:23:49,036 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBF8E6B6D296410DBD8344F619C21DBF, mem on close (mb), free: 108, total: 341, max: 672
2016-05-18 05:23:49,049 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,049 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,056 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E340602EFBF4449A9B153AD7203E307D, ordinal: 1
2016-05-18 05:23:49,057 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,057 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-05-18 05:23:49,058 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E340602EFBF4449A9B153AD7203E307D, mem on start (mb), free: 107, total: 341, max: 672
2016-05-18 05:23:49,066 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E340602EFBF4449A9B153AD7203E307D, mem on close (mb), free: 106, total: 341, max: 672
2016-05-18 05:23:49,081 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2016-05-18 05:23:49,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.123
2016-05-18 05:23:49,104 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,104 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 05:23:49,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 05:23:49,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,141 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 05:23:49,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-18 05:23:49,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2016-05-18 05:23:49,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1390372027_0019
2016-05-18 05:23:49,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,203 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,218 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,218 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D6249D679A2841D5ABC229137F398A97, ordinal: 0
2016-05-18 05:23:49,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,224 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6249D679A2841D5ABC229137F398A97, mem on start (mb), free: 225, total: 341, max: 672
2016-05-18 05:23:49,228 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6249D679A2841D5ABC229137F398A97, mem on close (mb), free: 225, total: 341, max: 672
2016-05-18 05:23:49,237 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,237 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,241 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D443D8CBB390438A9D41CEE315243283, ordinal: 1
2016-05-18 05:23:49,242 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,242 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-05-18 05:23:49,242 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D443D8CBB390438A9D41CEE315243283, mem on start (mb), free: 223, total: 341, max: 672
2016-05-18 05:23:49,248 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D443D8CBB390438A9D41CEE315243283, mem on close (mb), free: 222, total: 341, max: 672
2016-05-18 05:23:49,261 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2016-05-18 05:23:49,262 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.103
2016-05-18 05:23:49,275 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,275 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 05:23:49,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:23:49,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,297 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 05:23:49,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-18 05:23:49,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2016-05-18 05:23:49,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1796789614_0020
2016-05-18 05:23:49,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,332 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,347 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,347 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,352 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A74CD869A4354D20AA2D59A0BA8AF88D, ordinal: 0
2016-05-18 05:23:49,353 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,353 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,353 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A74CD869A4354D20AA2D59A0BA8AF88D, mem on start (mb), free: 109, total: 341, max: 672
2016-05-18 05:23:49,357 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A74CD869A4354D20AA2D59A0BA8AF88D, mem on close (mb), free: 109, total: 341, max: 672
2016-05-18 05:23:49,367 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,367 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,371 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A94F3302D02F43CC85BAA158FF03F16C, ordinal: 1
2016-05-18 05:23:49,371 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,371 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-05-18 05:23:49,372 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A94F3302D02F43CC85BAA158FF03F16C, mem on start (mb), free: 107, total: 341, max: 672
2016-05-18 05:23:49,377 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A94F3302D02F43CC85BAA158FF03F16C, mem on close (mb), free: 106, total: 341, max: 672
2016-05-18 05:23:49,390 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2016-05-18 05:23:49,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.085
2016-05-18 05:23:49,405 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,405 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 05:23:49,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:23:49,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,427 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 05:23:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-18 05:23:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,438 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2016-05-18 05:23:49,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local657188495_0021
2016-05-18 05:23:49,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,471 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,487 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,487 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC5F5D74707C40679D337A53ADD05926, ordinal: 0
2016-05-18 05:23:49,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,492 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC5F5D74707C40679D337A53ADD05926, mem on start (mb), free: 224, total: 341, max: 672
2016-05-18 05:23:49,496 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC5F5D74707C40679D337A53ADD05926, mem on close (mb), free: 224, total: 341, max: 672
2016-05-18 05:23:49,505 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,505 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,510 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C7332D34E269468A85BF77FD74B0F2B1, ordinal: 1
2016-05-18 05:23:49,510 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,511 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-05-18 05:23:49,511 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7332D34E269468A85BF77FD74B0F2B1, mem on start (mb), free: 222, total: 341, max: 672
2016-05-18 05:23:49,516 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7332D34E269468A85BF77FD74B0F2B1, mem on close (mb), free: 221, total: 341, max: 672
2016-05-18 05:23:49,530 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2016-05-18 05:23:49,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.094
2016-05-18 05:23:49,544 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,545 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 05:23:49,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:23:49,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,566 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 05:23:49,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-18 05:23:49,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2016-05-18 05:23:49,596 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local360766151_0022
2016-05-18 05:23:49,596 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,603 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,617 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,617 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C56F7C79621E4810B80FD856F7B853DE, ordinal: 0
2016-05-18 05:23:49,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,622 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56F7C79621E4810B80FD856F7B853DE, mem on start (mb), free: 105, total: 341, max: 672
2016-05-18 05:23:49,626 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56F7C79621E4810B80FD856F7B853DE, mem on close (mb), free: 105, total: 341, max: 672
2016-05-18 05:23:49,636 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,636 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,640 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C0F76E97549F4FD1AD92539625DA8C25, ordinal: 1
2016-05-18 05:23:49,641 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,641 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-05-18 05:23:49,641 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0F76E97549F4FD1AD92539625DA8C25, mem on start (mb), free: 104, total: 341, max: 672
2016-05-18 05:23:49,647 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0F76E97549F4FD1AD92539625DA8C25, mem on close (mb), free: 103, total: 341, max: 672
2016-05-18 05:23:49,657 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2016-05-18 05:23:49,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.083
2016-05-18 05:23:49,672 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,672 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 05:23:49,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:23:49,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,694 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 05:23:49,701 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-18 05:23:49,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,703 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,704 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2016-05-18 05:23:49,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1410688830_0023
2016-05-18 05:23:49,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,734 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC6DEB9B5FA948829C5D16C89ABA1C51, ordinal: 0
2016-05-18 05:23:49,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,753 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC6DEB9B5FA948829C5D16C89ABA1C51, mem on start (mb), free: 220, total: 341, max: 672
2016-05-18 05:23:49,757 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC6DEB9B5FA948829C5D16C89ABA1C51, mem on close (mb), free: 220, total: 341, max: 672
2016-05-18 05:23:49,765 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,765 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BCABA2328A984E32AED976F65357874D, ordinal: 1
2016-05-18 05:23:49,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-05-18 05:23:49,770 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BCABA2328A984E32AED976F65357874D, mem on start (mb), free: 219, total: 341, max: 672
2016-05-18 05:23:49,775 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BCABA2328A984E32AED976F65357874D, mem on close (mb), free: 218, total: 341, max: 672
2016-05-18 05:23:49,784 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2016-05-18 05:23:49,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.082
2016-05-18 05:23:49,798 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,799 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 05:23:49,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 05:23:49,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,819 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 05:23:49,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-18 05:23:49,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2016-05-18 05:23:49,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1614801901_0024
2016-05-18 05:23:49,851 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,854 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,870 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,871 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,875 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1A83EA19C8F412AA64124F0DC04073F, ordinal: 0
2016-05-18 05:23:49,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,876 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1A83EA19C8F412AA64124F0DC04073F, mem on start (mb), free: 104, total: 341, max: 672
2016-05-18 05:23:49,880 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1A83EA19C8F412AA64124F0DC04073F, mem on close (mb), free: 104, total: 341, max: 672
2016-05-18 05:23:49,889 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:49,889 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:49,892 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C5C1AE4B0B7E47F790DA17E1AFB28092, ordinal: 1
2016-05-18 05:23:49,893 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:49,893 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-05-18 05:23:49,893 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C5C1AE4B0B7E47F790DA17E1AFB28092, mem on start (mb), free: 102, total: 341, max: 672
2016-05-18 05:23:49,899 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C5C1AE4B0B7E47F790DA17E1AFB28092, mem on close (mb), free: 102, total: 341, max: 672
2016-05-18 05:23:49,913 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2016-05-18 05:23:49,913 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.085
2016-05-18 05:23:49,927 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:49,928 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 05:23:49,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 05:23:49,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:49,948 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 05:23:49,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:49,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:49,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-18 05:23:49,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:49,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:49,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:49,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2016-05-18 05:23:49,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local89436147_0025
2016-05-18 05:23:49,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:49,982 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:49,997 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:49,997 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:50,001 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC3D98463E7A4555BCBE635AA1ACC83E, ordinal: 0
2016-05-18 05:23:50,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:50,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:50,003 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC3D98463E7A4555BCBE635AA1ACC83E, mem on start (mb), free: 219, total: 341, max: 672
2016-05-18 05:23:50,007 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC3D98463E7A4555BCBE635AA1ACC83E, mem on close (mb), free: 219, total: 341, max: 672
2016-05-18 05:23:50,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:50,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:50,019 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FE2F1F8ECBA047FBABC9E9E048077F19, ordinal: 1
2016-05-18 05:23:50,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:50,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.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-05-18 05:23:50,020 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE2F1F8ECBA047FBABC9E9E048077F19, mem on start (mb), free: 217, total: 341, max: 672
2016-05-18 05:23:50,025 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE2F1F8ECBA047FBABC9E9E048077F19, mem on close (mb), free: 216, total: 341, max: 672
2016-05-18 05:23:50,031 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2016-05-18 05:23:50,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.076
2016-05-18 05:23:50,045 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:23:50,046 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 05:23:50,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:23:50,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:23:50,069 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 05:23:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting
2016-05-18 05:23:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:50,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-18 05:23:50,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-05-18 05:23:50,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] executing total steps: 1
2016-05-18 05:23:50,078 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] allocating management threads: 1
2016-05-18 05:23:50,078 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2016-05-18 05:23:50,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] submitted hadoop job: job_local1965683982_0026
2016-05-18 05:23:50,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-05-18 05:23:50,101 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt
2016-05-18 05:23:50,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:23:50,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:23:50,120 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B95955A07B62447E8324BB3F4D136172, ordinal: 0
2016-05-18 05:23:50,121 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-05-18 05:23:50,121 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:50,121 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B95955A07B62447E8324BB3F4D136172, mem on start (mb), free: 102, total: 341, max: 672
2016-05-18 05:23:50,125 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B95955A07B62447E8324BB3F4D136172, mem on close (mb), free: 102, total: 341, max: 672
2016-05-18 05:23:50,135 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 05:23:50,135 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 05:23:50,139 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A2255DB303174C9986598D25D779C807, ordinal: 1
2016-05-18 05:23:50,140 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-05-18 05:23:50,140 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-05-18 05:23:50,140 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A2255DB303174C9986598D25D779C807, mem on start (mb), free: 100, total: 341, max: 672
2016-05-18 05:23:50,146 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A2255DB303174C9986598D25D779C807, mem on close (mb), free: 99, total: 341, max: 672
2016-05-18 05:23:50,160 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2016-05-18 05:23:50,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [comprehensivesort] completed in: 00:00.084
2016-05-18 05:23:50,168 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2016-05-18 05:23:50,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2016-05-18 05:23:50,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true
2016-05-18 05:23:50,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2016-05-18 05:23:50,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2016-05-18 05:23:50,170 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2016-05-18 05:23:50,170 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2016-05-18 05:23:50,171 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2016-05-18 05:23:50,171 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2016-05-18 05:23:50,171 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2016-05-18 05:23:50,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2016-05-18 05:23:50,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2016-05-18 05:23:50,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2016-05-18 05:23:50,173 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2016-05-18 05:23:50,173 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2016-05-18 05:23:50,173 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2016-05-18 05:23:50,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2016-05-18 05:23:50,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2016-05-18 05:23:50,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2016-05-18 05:23:50,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2016-05-18 05:23:50,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2016-05-18 05:23:50,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2016-05-18 05:23:50,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true
2016-05-18 05:23:50,176 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false