2016-01-14 18:43:48,816 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 18:43:48,846 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.SortedValuesPlatformTest, with platform: hadoop2-mr1
2016-01-14 18:43:48,886 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-14 18:43:49,524 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 18:43:49,722 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 18:43:49,871 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:49,873 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:43:49,982 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: F234FF1ACC5143F3A32CC1413494B5A9
2016-01-14 18:43:50,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.177
2016-01-14 18:43:50,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:50,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:43:50,420 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 18:43:50,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2016-01-14 18:43:50,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt"]
2016-01-14 18:43:50,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2016-01-14 18:43:50,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-01-14 18:43:50,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] parallel execution of steps is enabled: false
2016-01-14 18:43:50,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executing total steps: 1
2016-01-14 18:43:50,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] allocating management threads: 1
2016-01-14 18:43:50,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ed/cogroupcomparereversed
2016-01-14 18:43:50,979 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity2091857795/.staging/job_local2091857795_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:50,980 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity2091857795/.staging/job_local2091857795_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:51,130 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2091857795_0001/job_local2091857795_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:51,130 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2091857795_0001/job_local2091857795_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:51,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local2091857795_0001
2016-01-14 18:43:51,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2016-01-14 18:43:51,226 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt
2016-01-14 18:43:51,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:51,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:51,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F57892D6853446F187326490708BC05C, ordinal: 0
2016-01-14 18:43:51,421 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt"]
2016-01-14 18:43:51,421 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:43:51,422 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F57892D6853446F187326490708BC05C, mem on start (mb), free: 86, total: 223, max: 672
2016-01-14 18:43:51,467 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F57892D6853446F187326490708BC05C, mem on close (mb), free: 85, total: 223, max: 672
2016-01-14 18:44:05,456 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt
2016-01-14 18:44:05,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:05,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:05,499 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F57892D6853446F187326490708BC05C, ordinal: 0
2016-01-14 18:44:05,500 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2016-01-14 18:44:05,500 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:44:05,501 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F57892D6853446F187326490708BC05C, mem on start (mb), free: 147, total: 386, max: 672
2016-01-14 18:44:05,505 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F57892D6853446F187326490708BC05C, mem on close (mb), free: 147, total: 386, max: 672
2016-01-14 18:44:09,819 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:09,819 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:09,833 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BA17FF7069DA450A9D3A44E928533F7A, ordinal: 1
2016-01-14 18:44:09,836 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:44:09,836 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed"]
2016-01-14 18:44:09,836 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA17FF7069DA450A9D3A44E928533F7A, mem on start (mb), free: 154, total: 426, max: 672
2016-01-14 18:44:09,853 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:44:09,853 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:44:09,886 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA17FF7069DA450A9D3A44E928533F7A, mem on close (mb), free: 152, total: 426, max: 672
2016-01-14 18:44:09,926 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed/_temporary
2016-01-14 18:44:09,926 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] completed in: 00:19.503
2016-01-14 18:44:09,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValuesReversed/cogroupcomparereversed
2016-01-14 18:44:09,998 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:09,999 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:10,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.102
2016-01-14 18:44:10,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:10,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:10,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting
2016-01-14 18:44:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt"]
2016-01-14 18:44:10,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2016-01-14 18:44:10,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-01-14 18:44:10,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] parallel execution of steps is enabled: false
2016-01-14 18:44:10,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] executing total steps: 1
2016-01-14 18:44:10,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] allocating management threads: 1
2016-01-14 18:44:10,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] starting step: (1/1) ...ues/cogroupcompareforward
2016-01-14 18:44:10,234 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1907966265/.staging/job_local1907966265_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:10,235 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1907966265/.staging/job_local1907966265_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:10,285 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1907966265_0002/job_local1907966265_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:10,286 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1907966265_0002/job_local1907966265_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:10,287 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] submitted hadoop job: job_local1907966265_0002
2016-01-14 18:44:10,288 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] tracking url: http://localhost:8080/
2016-01-14 18:44:10,295 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt
2016-01-14 18:44:10,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:10,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:10,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E59EE68AEE644B19919AA8779F02314B, ordinal: 0
2016-01-14 18:44:10,328 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/apache.200.txt"]
2016-01-14 18:44:10,329 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:44:10,329 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E59EE68AEE644B19919AA8779F02314B, mem on start (mb), free: 190, total: 425, max: 672
2016-01-14 18:44:10,359 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E59EE68AEE644B19919AA8779F02314B, mem on close (mb), free: 188, total: 425, max: 672
2016-01-14 18:44:21,529 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt
2016-01-14 18:44:21,545 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:21,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:21,558 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E59EE68AEE644B19919AA8779F02314B, ordinal: 0
2016-01-14 18:44:21,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2016-01-14 18:44:21,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:44:21,559 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E59EE68AEE644B19919AA8779F02314B, mem on start (mb), free: 91, total: 432, max: 672
2016-01-14 18:44:21,562 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E59EE68AEE644B19919AA8779F02314B, mem on close (mb), free: 91, total: 432, max: 672
2016-01-14 18:44:25,463 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:25,463 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:25,473 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BD55974A1F0B4153BBF0B76FB0764D10, ordinal: 1
2016-01-14 18:44:25,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2016-01-14 18:44:25,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward"]
2016-01-14 18:44:25,475 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD55974A1F0B4153BBF0B76FB0764D10, mem on start (mb), free: 120, total: 433, max: 672
2016-01-14 18:44:25,484 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:44:25,484 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:44:25,510 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD55974A1F0B4153BBF0B76FB0764D10, mem on close (mb), free: 118, total: 433, max: 672
2016-01-14 18:44:25,538 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward/_temporary
2016-01-14 18:44:25,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache*ip] completed in: 00:15.387
2016-01-14 18:44:25,599 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testCoGroupComparatorValues/cogroupcompareforward
2016-01-14 18:44:25,619 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:25,619 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:25,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2016-01-14 18:44:25,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [apache] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 18:44:25,661 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:25,661 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:25,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 18:44:25,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:25,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:25,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:25,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:25,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-01-14 18:44:25,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:25,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:25,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:25,742 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2016-01-14 18:44:25,840 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity562824869/.staging/job_local562824869_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:25,841 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity562824869/.staging/job_local562824869_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:25,880 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local562824869_0003/job_local562824869_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:25,880 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local562824869_0003/job_local562824869_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:25,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local562824869_0003
2016-01-14 18:44:25,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:25,888 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:25,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:25,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:25,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB8A19FC476C444A805E3D69CBD8EE7C, ordinal: 0
2016-01-14 18:44:25,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:25,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:25,915 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB8A19FC476C444A805E3D69CBD8EE7C, mem on start (mb), free: 161, total: 433, max: 672
2016-01-14 18:44:25,920 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB8A19FC476C444A805E3D69CBD8EE7C, mem on close (mb), free: 161, total: 433, max: 672
2016-01-14 18:44:25,938 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:25,938 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:25,946 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E27695F5743F408D8DBE222AD4BBFCE0, ordinal: 1
2016-01-14 18:44:25,947 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:25,947 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false"]
2016-01-14 18:44:25,947 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E27695F5743F408D8DBE222AD4BBFCE0, mem on start (mb), free: 151, total: 433, max: 672
2016-01-14 18:44:25,962 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E27695F5743F408D8DBE222AD4BBFCE0, mem on close (mb), free: 150, total: 433, max: 672
2016-01-14 18:44:25,980 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false/_temporary
2016-01-14 18:44:25,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.247
2016-01-14 18:44:26,018 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:26,019 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:26,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 18:44:26,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:26,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:26,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:26,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:26,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-01-14 18:44:26,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:26,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:26,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:26,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2016-01-14 18:44:26,146 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1924284280/.staging/job_local1924284280_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:26,146 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1924284280/.staging/job_local1924284280_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:26,175 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1924284280_0004/job_local1924284280_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:26,176 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1924284280_0004/job_local1924284280_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:26,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1924284280_0004
2016-01-14 18:44:26,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:26,185 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:26,205 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:26,206 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:26,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB4AACFC29F542DBB6B84C8545653F3F, ordinal: 0
2016-01-14 18:44:26,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:26,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:26,216 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB4AACFC29F542DBB6B84C8545653F3F, mem on start (mb), free: 208, total: 430, max: 672
2016-01-14 18:44:26,220 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB4AACFC29F542DBB6B84C8545653F3F, mem on close (mb), free: 208, total: 430, max: 672
2016-01-14 18:44:27,792 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:27,792 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:27,798 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EDE0D4E78C3848ACBD7EC8F167089F9B, ordinal: 1
2016-01-14 18:44:27,799 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:27,799 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false"]
2016-01-14 18:44:27,800 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EDE0D4E78C3848ACBD7EC8F167089F9B, mem on start (mb), free: 133, total: 441, max: 672
2016-01-14 18:44:27,812 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EDE0D4E78C3848ACBD7EC8F167089F9B, mem on close (mb), free: 132, total: 441, max: 672
2016-01-14 18:44:27,836 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false/_temporary
2016-01-14 18:44:27,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:01.750
2016-01-14 18:44:27,868 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:27,868 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:27,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 18:44:27,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:27,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:27,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-01-14 18:44:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:27,931 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2016-01-14 18:44:28,010 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity213170962/.staging/job_local213170962_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:28,010 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity213170962/.staging/job_local213170962_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:28,040 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local213170962_0005/job_local213170962_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:28,040 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local213170962_0005/job_local213170962_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:28,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local213170962_0005
2016-01-14 18:44:28,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:28,047 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:28,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:28,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:28,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D1E76AC9F46248078C6B8FF4EE0EBB2A, ordinal: 0
2016-01-14 18:44:28,073 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:28,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:28,075 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D1E76AC9F46248078C6B8FF4EE0EBB2A, mem on start (mb), free: 188, total: 441, max: 672
2016-01-14 18:44:28,082 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D1E76AC9F46248078C6B8FF4EE0EBB2A, mem on close (mb), free: 188, total: 441, max: 672
2016-01-14 18:44:28,099 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:28,099 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:28,106 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E7228C5A81774BB0A6B028B8BFE058EC, ordinal: 1
2016-01-14 18:44:28,107 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:28,107 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false"]
2016-01-14 18:44:28,107 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7228C5A81774BB0A6B028B8BFE058EC, mem on start (mb), free: 178, total: 441, max: 672
2016-01-14 18:44:28,119 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7228C5A81774BB0A6B028B8BFE058EC, mem on close (mb), free: 176, total: 441, max: 672
2016-01-14 18:44:28,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false/_temporary
2016-01-14 18:44:28,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.212
2016-01-14 18:44:28,172 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:28,173 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:28,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 18:44:28,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:28,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:28,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:28,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:28,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-01-14 18:44:28,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:28,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:28,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:28,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2016-01-14 18:44:28,288 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity401088810/.staging/job_local401088810_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:28,288 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity401088810/.staging/job_local401088810_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:28,315 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local401088810_0006/job_local401088810_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:28,315 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local401088810_0006/job_local401088810_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:28,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local401088810_0006
2016-01-14 18:44:28,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:28,323 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:28,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:28,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:28,349 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9779B2181234453AB4178FD5F7A6B24, ordinal: 0
2016-01-14 18:44:28,349 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:28,350 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:28,350 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9779B2181234453AB4178FD5F7A6B24, mem on start (mb), free: 203, total: 424, max: 672
2016-01-14 18:44:28,354 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9779B2181234453AB4178FD5F7A6B24, mem on close (mb), free: 203, total: 424, max: 672
2016-01-14 18:44:29,930 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:29,930 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:29,936 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CA758DE1AD554643B574B857F2DB36C0, ordinal: 1
2016-01-14 18:44:29,937 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:29,937 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false"]
2016-01-14 18:44:29,937 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA758DE1AD554643B574B857F2DB36C0, mem on start (mb), free: 134, total: 441, max: 672
2016-01-14 18:44:29,949 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA758DE1AD554643B574B857F2DB36C0, mem on close (mb), free: 132, total: 441, max: 672
2016-01-14 18:44:29,967 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false/_temporary
2016-01-14 18:44:29,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:01.733
2016-01-14 18:44:30,006 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:30,007 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:30,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 18:44:30,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:30,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:30,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:30,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:30,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-01-14 18:44:30,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:30,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:30,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:30,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2016-01-14 18:44:30,137 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity2090722814/.staging/job_local2090722814_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:30,138 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity2090722814/.staging/job_local2090722814_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:30,165 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2090722814_0007/job_local2090722814_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:30,166 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2090722814_0007/job_local2090722814_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:30,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local2090722814_0007
2016-01-14 18:44:30,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:30,172 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:30,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:30,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:30,195 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BCD43E7E22084844BB835D99B39BA2E8, ordinal: 0
2016-01-14 18:44:30,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:30,197 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:30,197 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCD43E7E22084844BB835D99B39BA2E8, mem on start (mb), free: 177, total: 433, max: 672
2016-01-14 18:44:30,202 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCD43E7E22084844BB835D99B39BA2E8, mem on close (mb), free: 177, total: 433, max: 672
2016-01-14 18:44:30,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:30,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:30,225 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A8039CF41A204F44A656CDAD702072B5, ordinal: 1
2016-01-14 18:44:30,226 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:30,226 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false"]
2016-01-14 18:44:30,226 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8039CF41A204F44A656CDAD702072B5, mem on start (mb), free: 168, total: 433, max: 672
2016-01-14 18:44:30,239 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8039CF41A204F44A656CDAD702072B5, mem on close (mb), free: 166, total: 433, max: 672
2016-01-14 18:44:30,256 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false/_temporary
2016-01-14 18:44:30,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.185
2016-01-14 18:44:30,291 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:30,291 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:30,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 18:44:30,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:30,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2016-01-14 18:44:30,405 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity80338147/.staging/job_local80338147_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:30,406 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity80338147/.staging/job_local80338147_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:30,432 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local80338147_0008/job_local80338147_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:30,433 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local80338147_0008/job_local80338147_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:30,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local80338147_0008
2016-01-14 18:44:30,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:30,439 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:30,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:30,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:30,467 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C916251334CC49A88C54A134EF42B94E, ordinal: 0
2016-01-14 18:44:30,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:30,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:30,469 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C916251334CC49A88C54A134EF42B94E, mem on start (mb), free: 218, total: 439, max: 672
2016-01-14 18:44:30,474 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C916251334CC49A88C54A134EF42B94E, mem on close (mb), free: 218, total: 439, max: 672
2016-01-14 18:44:32,657 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:32,658 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:32,666 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB84562041F94A94984674DF85FB40B6, ordinal: 1
2016-01-14 18:44:32,667 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:32,667 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false"]
2016-01-14 18:44:32,667 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB84562041F94A94984674DF85FB40B6, mem on start (mb), free: 260, total: 442, max: 672
2016-01-14 18:44:32,680 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB84562041F94A94984674DF85FB40B6, mem on close (mb), free: 259, total: 442, max: 672
2016-01-14 18:44:32,702 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false/_temporary
2016-01-14 18:44:32,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:02.353
2016-01-14 18:44:32,735 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:32,735 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:32,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 18:44:32,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:32,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:32,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:32,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-01-14 18:44:32,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:32,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:32,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:32,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2016-01-14 18:44:32,845 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1816861835/.staging/job_local1816861835_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:32,846 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1816861835/.staging/job_local1816861835_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:32,873 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1816861835_0009/job_local1816861835_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:32,873 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1816861835_0009/job_local1816861835_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:32,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1816861835_0009
2016-01-14 18:44:32,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:32,880 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:32,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:32,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:32,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB1B4404181946DDB88DCB1050E89D1B, ordinal: 0
2016-01-14 18:44:32,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:32,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:32,905 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB1B4404181946DDB88DCB1050E89D1B, mem on start (mb), free: 218, total: 441, max: 672
2016-01-14 18:44:32,909 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB1B4404181946DDB88DCB1050E89D1B, mem on close (mb), free: 218, total: 441, max: 672
2016-01-14 18:44:35,635 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:35,635 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:35,641 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DFF02A023F6146E88E922F8268770BDC, ordinal: 1
2016-01-14 18:44:35,642 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:35,642 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false"]
2016-01-14 18:44:35,642 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFF02A023F6146E88E922F8268770BDC, mem on start (mb), free: 228, total: 442, max: 672
2016-01-14 18:44:35,653 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFF02A023F6146E88E922F8268770BDC, mem on close (mb), free: 226, total: 442, max: 672
2016-01-14 18:44:35,676 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false/_temporary
2016-01-14 18:44:35,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:02.886
2016-01-14 18:44:35,707 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:35,707 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:35,753 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 18:44:35,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:35,755 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:35,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:35,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2016-01-14 18:44:35,854 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1934808129/.staging/job_local1934808129_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:35,855 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1934808129/.staging/job_local1934808129_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:35,896 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1934808129_0010/job_local1934808129_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:35,896 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1934808129_0010/job_local1934808129_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:35,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1934808129_0010
2016-01-14 18:44:35,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:35,905 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:35,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:35,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:35,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D110189E4BD94DFC83A2DC12C1A9643D, ordinal: 0
2016-01-14 18:44:35,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:35,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:35,940 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D110189E4BD94DFC83A2DC12C1A9643D, mem on start (mb), free: 216, total: 442, max: 672
2016-01-14 18:44:35,946 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D110189E4BD94DFC83A2DC12C1A9643D, mem on close (mb), free: 216, total: 442, max: 672
2016-01-14 18:44:37,320 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:37,321 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:37,327 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DB19237CB1D74A208AB857ED16649F47, ordinal: 1
2016-01-14 18:44:37,327 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:37,327 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false"]
2016-01-14 18:44:37,328 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB19237CB1D74A208AB857ED16649F47, mem on start (mb), free: 155, total: 441, max: 672
2016-01-14 18:44:37,338 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB19237CB1D74A208AB857ED16649F47, mem on close (mb), free: 154, total: 441, max: 672
2016-01-14 18:44:37,354 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false/_temporary
2016-01-14 18:44:37,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:01.576
2016-01-14 18:44:37,385 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:37,386 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:37,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 18:44:37,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:37,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:37,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:37,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:37,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-01-14 18:44:37,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:37,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:37,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:37,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2016-01-14 18:44:37,500 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity635989619/.staging/job_local635989619_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:37,501 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity635989619/.staging/job_local635989619_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:37,533 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local635989619_0011/job_local635989619_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:37,533 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local635989619_0011/job_local635989619_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:37,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local635989619_0011
2016-01-14 18:44:37,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:37,540 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:37,555 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:37,555 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:37,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F1823FC724724797B91C70A686B8E581, ordinal: 0
2016-01-14 18:44:37,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:37,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:37,564 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F1823FC724724797B91C70A686B8E581, mem on start (mb), free: 194, total: 431, max: 672
2016-01-14 18:44:37,568 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F1823FC724724797B91C70A686B8E581, mem on close (mb), free: 194, total: 431, max: 672
2016-01-14 18:44:37,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:37,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:37,594 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B54535030ABB4BEBB401FB0466C01582, ordinal: 1
2016-01-14 18:44:37,594 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:37,595 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false"]
2016-01-14 18:44:37,595 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B54535030ABB4BEBB401FB0466C01582, mem on start (mb), free: 184, total: 431, max: 672
2016-01-14 18:44:37,608 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B54535030ABB4BEBB401FB0466C01582, mem on close (mb), free: 183, total: 431, max: 672
2016-01-14 18:44:37,633 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false/_temporary
2016-01-14 18:44:37,633 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.187
2016-01-14 18:44:37,662 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:37,663 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:37,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 18:44:37,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:37,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:37,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:37,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:37,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-01-14 18:44:37,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:37,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:37,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:37,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2016-01-14 18:44:37,763 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity102654746/.staging/job_local102654746_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:37,764 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity102654746/.staging/job_local102654746_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:37,789 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local102654746_0012/job_local102654746_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:37,790 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local102654746_0012/job_local102654746_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:37,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local102654746_0012
2016-01-14 18:44:37,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:37,796 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:37,814 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:37,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:37,821 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADDC3AA214054EFC816B0320B30A4265, ordinal: 0
2016-01-14 18:44:37,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:37,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:37,823 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADDC3AA214054EFC816B0320B30A4265, mem on start (mb), free: 218, total: 438, max: 672
2016-01-14 18:44:37,827 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADDC3AA214054EFC816B0320B30A4265, mem on close (mb), free: 218, total: 438, max: 672
2016-01-14 18:44:39,918 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:39,918 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:39,923 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C25A8741FD0540159281C6B7E8BCDD34, ordinal: 1
2016-01-14 18:44:39,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:39,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false"]
2016-01-14 18:44:39,924 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C25A8741FD0540159281C6B7E8BCDD34, mem on start (mb), free: 245, total: 440, max: 672
2016-01-14 18:44:39,934 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C25A8741FD0540159281C6B7E8BCDD34, mem on close (mb), free: 243, total: 440, max: 672
2016-01-14 18:44:39,949 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false/_temporary
2016-01-14 18:44:39,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:02.236
2016-01-14 18:44:39,981 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:39,982 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:40,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 18:44:40,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:40,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:40,032 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:40,032 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:40,033 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-01-14 18:44:40,033 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:40,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:40,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:40,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2016-01-14 18:44:40,095 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity154090836/.staging/job_local154090836_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:40,096 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity154090836/.staging/job_local154090836_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:40,123 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local154090836_0013/job_local154090836_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:40,123 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local154090836_0013/job_local154090836_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:40,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local154090836_0013
2016-01-14 18:44:40,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:40,129 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:40,148 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:40,148 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:40,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F3047CA777504674B18FDD5F7D83DE9F, ordinal: 0
2016-01-14 18:44:40,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:40,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:40,154 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3047CA777504674B18FDD5F7D83DE9F, mem on start (mb), free: 215, total: 440, max: 672
2016-01-14 18:44:40,159 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3047CA777504674B18FDD5F7D83DE9F, mem on close (mb), free: 215, total: 440, max: 672
2016-01-14 18:44:42,779 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:42,779 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:42,785 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F0C78CA20AF940239894BAEE95F5CA5A, ordinal: 1
2016-01-14 18:44:42,785 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:42,785 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false"]
2016-01-14 18:44:42,786 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0C78CA20AF940239894BAEE95F5CA5A, mem on start (mb), free: 219, total: 441, max: 672
2016-01-14 18:44:42,796 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0C78CA20AF940239894BAEE95F5CA5A, mem on close (mb), free: 217, total: 441, max: 672
2016-01-14 18:44:42,814 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false/_temporary
2016-01-14 18:44:42,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:02.782
2016-01-14 18:44:42,842 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:42,843 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:42,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 18:44:42,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:42,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:42,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:42,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2016-01-14 18:44:42,942 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1545225809/.staging/job_local1545225809_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:42,943 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1545225809/.staging/job_local1545225809_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:42,969 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1545225809_0014/job_local1545225809_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:42,970 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1545225809_0014/job_local1545225809_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:42,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1545225809_0014
2016-01-14 18:44:42,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:42,976 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:42,995 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:42,995 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:43,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5CC3E71081F49A2866CA7450E76DE2F, ordinal: 0
2016-01-14 18:44:43,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:43,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:43,003 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5CC3E71081F49A2866CA7450E76DE2F, mem on start (mb), free: 214, total: 441, max: 672
2016-01-14 18:44:43,009 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5CC3E71081F49A2866CA7450E76DE2F, mem on close (mb), free: 214, total: 441, max: 672
2016-01-14 18:44:44,400 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:44,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:44,406 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C9432A2FA8ED4C85B42DDAD6D16CD70F, ordinal: 1
2016-01-14 18:44:44,407 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:44,407 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false"]
2016-01-14 18:44:44,407 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9432A2FA8ED4C85B42DDAD6D16CD70F, mem on start (mb), free: 154, total: 441, max: 672
2016-01-14 18:44:44,417 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9432A2FA8ED4C85B42DDAD6D16CD70F, mem on close (mb), free: 153, total: 441, max: 672
2016-01-14 18:44:44,436 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false/_temporary
2016-01-14 18:44:44,437 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:01.542
2016-01-14 18:44:44,464 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:44,464 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:44,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 18:44:44,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:44,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:44,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:44,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:44,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-01-14 18:44:44,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:44,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:44,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:44,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2016-01-14 18:44:44,558 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1232699695/.staging/job_local1232699695_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:44,558 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1232699695/.staging/job_local1232699695_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:44,590 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1232699695_0015/job_local1232699695_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:44,590 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1232699695_0015/job_local1232699695_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:44,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1232699695_0015
2016-01-14 18:44:44,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:44,596 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:44,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:44,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:44,615 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC3EC530659347FA921BD0B4CD36B7F1, ordinal: 0
2016-01-14 18:44:44,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:44,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:44,616 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC3EC530659347FA921BD0B4CD36B7F1, mem on start (mb), free: 197, total: 431, max: 672
2016-01-14 18:44:44,620 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC3EC530659347FA921BD0B4CD36B7F1, mem on close (mb), free: 197, total: 431, max: 672
2016-01-14 18:44:44,637 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:44,637 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:44,642 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B6D3293214C44E5095804261791AA5DA, ordinal: 1
2016-01-14 18:44:44,642 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:44,642 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true"]
2016-01-14 18:44:44,642 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6D3293214C44E5095804261791AA5DA, mem on start (mb), free: 190, total: 431, max: 672
2016-01-14 18:44:44,655 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6D3293214C44E5095804261791AA5DA, mem on close (mb), free: 189, total: 431, max: 672
2016-01-14 18:44:44,670 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true/_temporary
2016-01-14 18:44:44,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.162
2016-01-14 18:44:44,698 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:44,699 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:44,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 18:44:44,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:44,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:44,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:44,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:44,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-01-14 18:44:44,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:44,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:44,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:44,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2016-01-14 18:44:44,790 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1824502157/.staging/job_local1824502157_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:44,790 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1824502157/.staging/job_local1824502157_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:44,815 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1824502157_0016/job_local1824502157_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:44,815 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1824502157_0016/job_local1824502157_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:44,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1824502157_0016
2016-01-14 18:44:44,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:44,821 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:44,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:44,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:44,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3AE7FBBEE034D5CA14CEDA20E4774A5, ordinal: 0
2016-01-14 18:44:44,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:44,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:44,856 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3AE7FBBEE034D5CA14CEDA20E4774A5, mem on start (mb), free: 219, total: 439, max: 672
2016-01-14 18:44:44,863 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3AE7FBBEE034D5CA14CEDA20E4774A5, mem on close (mb), free: 219, total: 439, max: 672
2016-01-14 18:44:44,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:44,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:44,890 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CCC03977856D4A7E886B4F9473A9F86C, ordinal: 1
2016-01-14 18:44:44,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:44,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true"]
2016-01-14 18:44:44,891 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CCC03977856D4A7E886B4F9473A9F86C, mem on start (mb), free: 213, total: 439, max: 672
2016-01-14 18:44:44,902 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CCC03977856D4A7E886B4F9473A9F86C, mem on close (mb), free: 211, total: 439, max: 672
2016-01-14 18:44:44,917 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true/_temporary
2016-01-14 18:44:44,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.179
2016-01-14 18:44:44,948 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:44,949 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:44,977 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 18:44:44,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:44,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:44,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:44,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:44,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-01-14 18:44:44,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:44,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:44,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:44,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2016-01-14 18:44:45,038 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity88716320/.staging/job_local88716320_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,039 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity88716320/.staging/job_local88716320_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,063 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local88716320_0017/job_local88716320_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,064 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local88716320_0017/job_local88716320_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local88716320_0017
2016-01-14 18:44:45,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:45,069 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:45,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:45,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,096 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F24DCF16F0644065AF5FBE142ECF576B, ordinal: 0
2016-01-14 18:44:45,097 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,097 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,098 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F24DCF16F0644065AF5FBE142ECF576B, mem on start (mb), free: 220, total: 440, max: 672
2016-01-14 18:44:45,103 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F24DCF16F0644065AF5FBE142ECF576B, mem on close (mb), free: 220, total: 440, max: 672
2016-01-14 18:44:45,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:45,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,122 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB04C3A17C69433B93703B6E30B841BF, ordinal: 1
2016-01-14 18:44:45,123 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,123 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true"]
2016-01-14 18:44:45,124 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB04C3A17C69433B93703B6E30B841BF, mem on start (mb), free: 215, total: 440, max: 672
2016-01-14 18:44:45,134 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB04C3A17C69433B93703B6E30B841BF, mem on close (mb), free: 213, total: 440, max: 672
2016-01-14 18:44:45,152 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true/_temporary
2016-01-14 18:44:45,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.163
2016-01-14 18:44:45,180 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:45,180 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:45,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 18:44:45,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:45,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:45,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:45,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2016-01-14 18:44:45,267 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1606036399/.staging/job_local1606036399_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,267 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1606036399/.staging/job_local1606036399_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,293 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1606036399_0018/job_local1606036399_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,293 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1606036399_0018/job_local1606036399_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1606036399_0018
2016-01-14 18:44:45,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:45,299 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:45,316 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:45,316 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD875C0D2ACA492FBEA7B7B7A23E2225, ordinal: 0
2016-01-14 18:44:45,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,322 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD875C0D2ACA492FBEA7B7B7A23E2225, mem on start (mb), free: 219, total: 440, max: 672
2016-01-14 18:44:45,325 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD875C0D2ACA492FBEA7B7B7A23E2225, mem on close (mb), free: 219, total: 440, max: 672
2016-01-14 18:44:45,339 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:45,340 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,344 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EE3165A17F714689ABBADC499CA252B3, ordinal: 1
2016-01-14 18:44:45,345 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,345 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true"]
2016-01-14 18:44:45,346 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE3165A17F714689ABBADC499CA252B3, mem on start (mb), free: 214, total: 440, max: 672
2016-01-14 18:44:45,356 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE3165A17F714689ABBADC499CA252B3, mem on close (mb), free: 213, total: 440, max: 672
2016-01-14 18:44:45,372 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true/_temporary
2016-01-14 18:44:45,373 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.155
2016-01-14 18:44:45,401 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:45,402 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:45,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 18:44:45,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:45,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:45,459 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:45,459 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-01-14 18:44:45,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:45,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:45,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:45,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2016-01-14 18:44:45,518 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity347410541/.staging/job_local347410541_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,518 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity347410541/.staging/job_local347410541_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,557 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local347410541_0019/job_local347410541_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,558 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local347410541_0019/job_local347410541_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local347410541_0019
2016-01-14 18:44:45,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:45,564 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:45,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:45,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,586 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DBBEDB5E13C34E8D92FDCC3B2C776464, ordinal: 0
2016-01-14 18:44:45,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,587 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBBEDB5E13C34E8D92FDCC3B2C776464, mem on start (mb), free: 219, total: 440, max: 672
2016-01-14 18:44:45,591 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBBEDB5E13C34E8D92FDCC3B2C776464, mem on close (mb), free: 219, total: 440, max: 672
2016-01-14 18:44:45,607 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:45,607 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,615 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AD1BFFDA468B4122B95606A723E19E71, ordinal: 1
2016-01-14 18:44:45,616 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,616 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true"]
2016-01-14 18:44:45,616 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AD1BFFDA468B4122B95606A723E19E71, mem on start (mb), free: 214, total: 440, max: 672
2016-01-14 18:44:45,629 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AD1BFFDA468B4122B95606A723E19E71, mem on close (mb), free: 213, total: 440, max: 672
2016-01-14 18:44:45,646 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true/_temporary
2016-01-14 18:44:45,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.187
2016-01-14 18:44:45,687 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:45,688 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:45,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 18:44:45,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:45,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:45,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:45,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2016-01-14 18:44:45,793 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity588327824/.staging/job_local588327824_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,794 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity588327824/.staging/job_local588327824_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,831 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local588327824_0020/job_local588327824_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:45,831 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local588327824_0020/job_local588327824_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:45,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local588327824_0020
2016-01-14 18:44:45,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:45,838 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:45,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:45,858 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,865 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4380657AC934537ACFF8C8C9A7D693C, ordinal: 0
2016-01-14 18:44:45,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,866 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4380657AC934537ACFF8C8C9A7D693C, mem on start (mb), free: 218, total: 439, max: 672
2016-01-14 18:44:45,871 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4380657AC934537ACFF8C8C9A7D693C, mem on close (mb), free: 218, total: 439, max: 672
2016-01-14 18:44:45,887 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:45,888 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:45,894 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DD7ECE74226A46E2A173A943B11D927C, ordinal: 1
2016-01-14 18:44:45,895 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:45,895 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true"]
2016-01-14 18:44:45,895 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DD7ECE74226A46E2A173A943B11D927C, mem on start (mb), free: 213, total: 439, max: 672
2016-01-14 18:44:45,905 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DD7ECE74226A46E2A173A943B11D927C, mem on close (mb), free: 212, total: 439, max: 672
2016-01-14 18:44:45,922 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true/_temporary
2016-01-14 18:44:45,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.183
2016-01-14 18:44:45,950 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:45,950 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:45,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 18:44:45,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:45,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:45,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:45,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:45,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-01-14 18:44:45,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:45,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:45,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:45,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2016-01-14 18:44:46,048 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1701272722/.staging/job_local1701272722_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,049 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1701272722/.staging/job_local1701272722_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,074 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1701272722_0021/job_local1701272722_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,075 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1701272722_0021/job_local1701272722_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1701272722_0021
2016-01-14 18:44:46,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:46,081 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:46,101 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:46,101 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B13642EF756F46508E760DEED51C85B1, ordinal: 0
2016-01-14 18:44:46,107 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,107 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,107 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B13642EF756F46508E760DEED51C85B1, mem on start (mb), free: 218, total: 440, max: 672
2016-01-14 18:44:46,111 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B13642EF756F46508E760DEED51C85B1, mem on close (mb), free: 218, total: 440, max: 672
2016-01-14 18:44:46,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:46,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,130 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E76EA89DAC9A413594EAD9FE3F1C4F4E, ordinal: 1
2016-01-14 18:44:46,130 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,131 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true"]
2016-01-14 18:44:46,131 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E76EA89DAC9A413594EAD9FE3F1C4F4E, mem on start (mb), free: 212, total: 440, max: 672
2016-01-14 18:44:46,143 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E76EA89DAC9A413594EAD9FE3F1C4F4E, mem on close (mb), free: 212, total: 440, max: 672
2016-01-14 18:44:46,164 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true/_temporary
2016-01-14 18:44:46,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.170
2016-01-14 18:44:46,198 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:46,198 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:46,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 18:44:46,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:46,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:46,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:46,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-01-14 18:44:46,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:46,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:46,238 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:46,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2016-01-14 18:44:46,309 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity346014069/.staging/job_local346014069_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,310 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity346014069/.staging/job_local346014069_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,339 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local346014069_0022/job_local346014069_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,339 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local346014069_0022/job_local346014069_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local346014069_0022
2016-01-14 18:44:46,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:46,344 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:46,363 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:46,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF3FA67742E8472DA0A21032553E36B2, ordinal: 0
2016-01-14 18:44:46,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,372 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF3FA67742E8472DA0A21032553E36B2, mem on start (mb), free: 217, total: 440, max: 672
2016-01-14 18:44:46,376 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF3FA67742E8472DA0A21032553E36B2, mem on close (mb), free: 217, total: 440, max: 672
2016-01-14 18:44:46,390 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:46,391 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,395 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D38BE703727C420194EBB93E516A6045, ordinal: 1
2016-01-14 18:44:46,395 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,395 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true"]
2016-01-14 18:44:46,395 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D38BE703727C420194EBB93E516A6045, mem on start (mb), free: 212, total: 440, max: 672
2016-01-14 18:44:46,405 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D38BE703727C420194EBB93E516A6045, mem on close (mb), free: 211, total: 440, max: 672
2016-01-14 18:44:46,427 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true/_temporary
2016-01-14 18:44:46,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.191
2016-01-14 18:44:46,455 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:46,455 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:46,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 18:44:46,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:46,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:46,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2016-01-14 18:44:46,542 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1988604177/.staging/job_local1988604177_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,543 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1988604177/.staging/job_local1988604177_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,569 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1988604177_0023/job_local1988604177_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,570 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1988604177_0023/job_local1988604177_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local1988604177_0023
2016-01-14 18:44:46,572 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:46,575 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:46,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:46,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,598 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCB2D7F8C79D45628A7CC51A461690EA, ordinal: 0
2016-01-14 18:44:46,598 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,599 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCB2D7F8C79D45628A7CC51A461690EA, mem on start (mb), free: 217, total: 440, max: 672
2016-01-14 18:44:46,602 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCB2D7F8C79D45628A7CC51A461690EA, mem on close (mb), free: 217, total: 440, max: 672
2016-01-14 18:44:46,617 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:46,617 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,621 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB2BA76B423B48009A7B4565ED479A31, ordinal: 1
2016-01-14 18:44:46,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true"]
2016-01-14 18:44:46,622 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB2BA76B423B48009A7B4565ED479A31, mem on start (mb), free: 212, total: 440, max: 672
2016-01-14 18:44:46,632 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB2BA76B423B48009A7B4565ED479A31, mem on close (mb), free: 211, total: 440, max: 672
2016-01-14 18:44:46,647 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true/_temporary
2016-01-14 18:44:46,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.154
2016-01-14 18:44:46,683 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:46,684 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:46,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 18:44:46,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:46,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:46,718 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:46,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-01-14 18:44:46,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:46,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:46,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:46,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2016-01-14 18:44:46,776 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity134155439/.staging/job_local134155439_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,777 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity134155439/.staging/job_local134155439_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,804 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local134155439_0024/job_local134155439_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,804 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local134155439_0024/job_local134155439_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:46,804 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local134155439_0024
2016-01-14 18:44:46,805 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:46,809 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:46,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:46,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AD150ECB025D49E296B8DDFB01703EFE, ordinal: 0
2016-01-14 18:44:46,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,833 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD150ECB025D49E296B8DDFB01703EFE, mem on start (mb), free: 216, total: 440, max: 672
2016-01-14 18:44:46,837 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD150ECB025D49E296B8DDFB01703EFE, mem on close (mb), free: 216, total: 440, max: 672
2016-01-14 18:44:46,850 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:46,850 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:46,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FAC0D71A929D402293E372BA616B42C7, ordinal: 1
2016-01-14 18:44:46,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:46,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true"]
2016-01-14 18:44:46,855 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FAC0D71A929D402293E372BA616B42C7, mem on start (mb), free: 211, total: 440, max: 672
2016-01-14 18:44:46,865 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FAC0D71A929D402293E372BA616B42C7, mem on close (mb), free: 210, total: 440, max: 672
2016-01-14 18:44:46,880 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true/_temporary
2016-01-14 18:44:46,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.162
2016-01-14 18:44:46,908 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:46,909 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:46,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 18:44:46,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:46,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:46,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:46,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:46,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-01-14 18:44:46,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:46,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:46,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:46,944 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2016-01-14 18:44:46,995 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity385954813/.staging/job_local385954813_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:46,996 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity385954813/.staging/job_local385954813_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:47,021 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local385954813_0025/job_local385954813_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:47,021 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local385954813_0025/job_local385954813_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:47,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local385954813_0025
2016-01-14 18:44:47,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:47,025 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:47,045 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:47,045 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:47,058 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B821C4BB1AF841B0A28DEB2039C15CA1, ordinal: 0
2016-01-14 18:44:47,058 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:47,059 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:47,059 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B821C4BB1AF841B0A28DEB2039C15CA1, mem on start (mb), free: 217, total: 441, max: 672
2016-01-14 18:44:47,064 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B821C4BB1AF841B0A28DEB2039C15CA1, mem on close (mb), free: 217, total: 441, max: 672
2016-01-14 18:44:47,079 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:47,079 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:47,085 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AA861B2BC4894199B5797725AAAC5C02, ordinal: 1
2016-01-14 18:44:47,086 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:47,086 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true"]
2016-01-14 18:44:47,087 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA861B2BC4894199B5797725AAAC5C02, mem on start (mb), free: 211, total: 441, max: 672
2016-01-14 18:44:47,096 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA861B2BC4894199B5797725AAAC5C02, mem on close (mb), free: 211, total: 441, max: 672
2016-01-14 18:44:47,109 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true/_temporary
2016-01-14 18:44:47,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.167
2016-01-14 18:44:47,146 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:44:47,146 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 18:44:47,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 18:44:47,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:44:47,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:44:47,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting
2016-01-14 18:44:47,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:47,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-01-14 18:44:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] parallel execution of steps is enabled: false
2016-01-14 18:44:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] executing total steps: 1
2016-01-14 18:44:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] allocating management threads: 1
2016-01-14 18:44:47,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2016-01-14 18:44:47,232 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity436422889/.staging/job_local436422889_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:47,232 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity436422889/.staging/job_local436422889_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:47,255 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local436422889_0026/job_local436422889_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:44:47,255 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local436422889_0026/job_local436422889_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:44:47,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] submitted hadoop job: job_local436422889_0026
2016-01-14 18:44:47,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] tracking url: http://localhost:8080/
2016-01-14 18:44:47,263 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt
2016-01-14 18:44:47,283 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:44:47,283 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:44:47,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3DCD9F5DB28472E8AAF1DBEDD66DC91, ordinal: 0
2016-01-14 18:44:47,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs+rhs-cross.txt"]
2016-01-14 18:44:47,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:47,289 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3DCD9F5DB28472E8AAF1DBEDD66DC91, mem on start (mb), free: 216, total: 441, max: 672
2016-01-14 18:44:47,294 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3DCD9F5DB28472E8AAF1DBEDD66DC91, mem on close (mb), free: 216, total: 441, max: 672
2016-01-14 18:44:47,308 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:44:47,308 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:44:47,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F878322DE64B47A9B14A45BF1C821634, ordinal: 1
2016-01-14 18:44:47,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2016-01-14 18:44:47,313 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true"]
2016-01-14 18:44:47,313 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F878322DE64B47A9B14A45BF1C821634, mem on start (mb), free: 211, total: 441, max: 672
2016-01-14 18:44:47,323 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F878322DE64B47A9B14A45BF1C821634, mem on close (mb), free: 210, total: 441, max: 672
2016-01-14 18:44:47,338 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true/_temporary
2016-01-14 18:44:47,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [comprehensivesort] completed in: 00:00.156
2016-01-14 18:44:47,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_false
2016-01-14 18:44:47,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_true
2016-01-14 18:44:47,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_false
2016-01-14 18:44:47,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_true
2016-01-14 18:44:47,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_false
2016-01-14 18:44:47,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_true
2016-01-14 18:44:47,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_false_false
2016-01-14 18:44:47,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_true
2016-01-14 18:44:47,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_true_true
2016-01-14 18:44:47,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_true
2016-01-14 18:44:47,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_false
2016-01-14 18:44:47,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_true_true_true
2016-01-14 18:44:47,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_true
2016-01-14 18:44:47,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_false_false
2016-01-14 18:44:47,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_false_false
2016-01-14 18:44:47,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_true
2016-01-14 18:44:47,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_null_false_true
2016-01-14 18:44:47,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_false_false
2016-01-14 18:44:47,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_false
2016-01-14 18:44:47,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/true_false_true_false
2016-01-14 18:44:47,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_true_false
2016-01-14 18:44:47,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_null_true_false
2016-01-14 18:44:47,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_true_true_true
2016-01-14 18:44:47,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/sortedvaluesplatform/testComprehensiveGroupBy/comprehensive/false_false_false_true