2015-08-14 07:56:58,987 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 07:56:59,058 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 07:56:59,059 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.function.FunctionPlatformTest
2015-08-14 07:56:59,093 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 07:56:59,756 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 07:56:59,935 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 07:56:59,995 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-08-14 07:56:59,996 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 80, total: 102, max: 672
2015-08-14 07:56:59,996 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 15% of max mem, to better utilize unused memory consider increasing the cache size
2015-08-14 07:56:59,996 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-08-14 07:56:59,997 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 80, total: 102, max: 672
2015-08-14 07:56:59,997 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 15% of max mem, to better utilize unused memory consider increasing the cache size
2015-08-14 07:57:00,137 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:57:00,141 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 07:57:00,156 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 846F1ABAB7EB4EC98B412EB365607577
2015-08-14 07:57:00,422 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 07:57:00,426 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] starting
2015-08-14 07:57:00,426 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 07:57:00,427 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/formatter"]
2015-08-14 07:57:00,427 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] parallel execution is enabled: false
2015-08-14 07:57:00,427 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] starting jobs: 1
2015-08-14 07:57:00,428 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [formatter] allocating threads: 1
2015-08-14 07:57:00,430 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [formatter] starting step: (1/1) ...unctionplatform/formatter
2015-08-14 07:57:01,158 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity718866104/.staging/job_local718866104_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:01,173 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity718866104/.staging/job_local718866104_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:01,313 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local718866104_0001/job_local718866104_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:01,321 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local718866104_0001/job_local718866104_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:01,332 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [formatter] submitted hadoop job: job_local718866104_0001
2015-08-14 07:57:01,332 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [formatter] tracking url: http://localhost:8080/
2015-08-14 07:57:01,432 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt
2015-08-14 07:57:01,461 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:57:01,461 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:57:01,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 07:57:01,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/formatter"]
2015-08-14 07:57:01,580 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/formatter/_temporary
2015-08-14 07:57:01,672 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/functionplatform/formatter
2015-08-14 07:57:01,675 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-08-14 07:57:01,675 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 87, total: 102, max: 672
2015-08-14 07:57:01,676 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 15% of max mem, to better utilize unused memory consider increasing the cache size
2015-08-14 07:57:01,676 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-08-14 07:57:01,677 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 87, total: 102, max: 672
2015-08-14 07:57:01,677 INFO cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 15% of max mem, to better utilize unused memory consider increasing the cache size
2015-08-14 07:57:01,716 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:57:01,717 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 07:57:01,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] starting
2015-08-14 07:57:01,767 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/apache.200.txt"]
2015-08-14 07:57:01,767 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/insert"]
2015-08-14 07:57:01,768 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] parallel execution is enabled: false
2015-08-14 07:57:01,768 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] starting jobs: 1
2015-08-14 07:57:01,768 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [apache] allocating threads: 1
2015-08-14 07:57:01,769 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache] starting step: (1/1) ...1/functionplatform/insert
2015-08-14 07:57:01,901 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity963550386/.staging/job_local963550386_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:01,903 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity963550386/.staging/job_local963550386_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:01,986 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local963550386_0002/job_local963550386_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:01,988 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local963550386_0002/job_local963550386_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:01,989 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache] submitted hadoop job: job_local963550386_0002
2015-08-14 07:57:01,989 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [apache] tracking url: http://localhost:8080/
2015-08-14 07:57:01,999 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/apache.200.txt
2015-08-14 07:57:02,174 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:57:02,175 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:57:02,194 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/apache.200.txt"]
2015-08-14 07:57:02,194 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(apache)[by:[{1}:'A']]
2015-08-14 07:57:02,389 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 07:57:02,389 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 07:57:02,403 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(apache)[by:[{1}:'A']]
2015-08-14 07:57:02,403 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/insert"]
2015-08-14 07:57:02,491 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/insert/_temporary
2015-08-14 07:57:02,610 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/functionplatform/insert
2015-08-14 07:57:02,646 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:57:02,648 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 07:57:02,682 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] starting
2015-08-14 07:57:02,682 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 07:57:02,683 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/setvalue"]
2015-08-14 07:57:02,684 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] parallel execution is enabled: false
2015-08-14 07:57:02,684 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] starting jobs: 1
2015-08-14 07:57:02,684 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [setvalue] allocating threads: 1
2015-08-14 07:57:02,685 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [setvalue] starting step: (1/1) ...functionplatform/setvalue
2015-08-14 07:57:02,849 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1716356417/.staging/job_local1716356417_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:02,851 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1716356417/.staging/job_local1716356417_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:02,945 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1716356417_0003/job_local1716356417_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 07:57:02,948 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1716356417_0003/job_local1716356417_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 07:57:02,949 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [setvalue] submitted hadoop job: job_local1716356417_0003
2015-08-14 07:57:02,949 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [setvalue] tracking url: http://localhost:8080/
2015-08-14 07:57:02,959 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt
2015-08-14 07:57:02,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:57:02,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:57:02,983 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 07:57:02,984 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/setvalue"]
2015-08-14 07:57:03,018 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/functionplatform/setvalue/_temporary
2015-08-14 07:57:03,095 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/functionplatform/setvalue