2015-08-14 04:44:24,978 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 04:44:25,049 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 04:44:25,050 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.DistanceUseCasePlatformTest
2015-08-14 04:44:25,090 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 04:44:25,732 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 04:44:25,896 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 04:44:26,049 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:44:26,051 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 04:44:26,064 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 743433A1B3EB4102B28C85A5491494D0
2015-08-14 04:44:26,404 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 04:44:26,406 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 04:44:26,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:26,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite"]
2015-08-14 04:44:26,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] parallel execution is enabled: false
2015-08-14 04:44:26,409 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting jobs: 3
2015-08-14 04:44:26,409 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] allocating threads: 1
2015-08-14 04:44:26,413 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 04:44:27,123 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1100792721/.staging/job_local1100792721_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:27,132 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1100792721/.staging/job_local1100792721_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:27,293 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1100792721_0001/job_local1100792721_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:27,297 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1100792721_0001/job_local1100792721_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:27,307 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1100792721_0001
2015-08-14 04:44:27,307 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:27,424 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt
2015-08-14 04:44:27,625 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:27,626 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:27,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:27,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 04:44:27,883 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:27,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:27,906 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 04:44:27,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][3690108461/euclidean/]
2015-08-14 04:44:27,943 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:27,943 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:28,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 04:44:28,221 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2141509650/.staging/job_local2141509650_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:28,225 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2141509650/.staging/job_local2141509650_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:28,303 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2141509650_0002/job_local2141509650_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:28,306 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2141509650_0002/job_local2141509650_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:28,307 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local2141509650_0002
2015-08-14 04:44:28,307 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:28,316 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3690108461_euclidean_803239753D57427EB77A685CA26F95AD/part-00000
2015-08-14 04:44:28,480 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:28,480 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:28,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][3690108461/euclidean/]
2015-08-14 04:44:28,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:28,637 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:28,638 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:28,654 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:28,654 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][8257867347/euclidean/]
2015-08-14 04:44:28,734 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...tform/euclidean/composite
2015-08-14 04:44:28,895 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1714439312/.staging/job_local1714439312_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:28,898 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1714439312/.staging/job_local1714439312_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:28,970 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1714439312_0003/job_local1714439312_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:28,972 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1714439312_0003/job_local1714439312_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:28,973 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1714439312_0003
2015-08-14 04:44:28,974 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:28,986 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/8257867347_euclidean_CF8E584420204678A6E723014BA64797/part-00000
2015-08-14 04:44:29,149 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:29,149 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:29,163 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][8257867347/euclidean/]
2015-08-14 04:44:29,163 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'n1', 'n2']]
2015-08-14 04:44:29,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:29,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:29,226 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'n1', 'n2']]
2015-08-14 04:44:29,227 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite"]
2015-08-14 04:44:29,296 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite/_temporary
2015-08-14 04:44:29,409 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/composite
2015-08-14 04:44:29,454 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:44:29,455 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 04:44:29,541 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] starting
2015-08-14 04:44:29,541 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:29,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite"]
2015-08-14 04:44:29,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] parallel execution is enabled: false
2015-08-14 04:44:29,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] starting jobs: 3
2015-08-14 04:44:29,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] allocating threads: 1
2015-08-14 04:44:29,543 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (1/3)
2015-08-14 04:44:29,640 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity794910993/.staging/job_local794910993_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:29,641 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity794910993/.staging/job_local794910993_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:29,716 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local794910993_0004/job_local794910993_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:29,718 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local794910993_0004/job_local794910993_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:29,718 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local794910993_0004
2015-08-14 04:44:29,719 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 04:44:29,726 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt
2015-08-14 04:44:29,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:29,877 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:29,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:29,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(pearson)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 04:44:29,923 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:29,923 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:29,937 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(pearson)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 04:44:29,937 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][549114749/pearson/]
2015-08-14 04:44:29,947 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:29,947 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:30,012 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (2/3)
2015-08-14 04:44:30,127 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity416886259/.staging/job_local416886259_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:30,128 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity416886259/.staging/job_local416886259_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:30,198 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local416886259_0005/job_local416886259_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:30,200 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local416886259_0005/job_local416886259_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:30,201 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local416886259_0005
2015-08-14 04:44:30,201 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 04:44:30,209 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/549114749_pearson_C56602EE795F4FB2A9E5226F18B5DBF9/part-00000
2015-08-14 04:44:30,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:30,362 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:30,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][549114749/pearson/]
2015-08-14 04:44:30,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pearson)[by:[{?}:ALL]]
2015-08-14 04:44:30,432 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:30,433 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:30,444 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pearson)[by:[{?}:ALL]]
2015-08-14 04:44:30,445 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][131265810/pearson/]
2015-08-14 04:44:30,813 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (3/3) ...latform/pearson/composite
2015-08-14 04:44:30,912 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity104160432/.staging/job_local104160432_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:30,913 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity104160432/.staging/job_local104160432_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:30,969 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local104160432_0006/job_local104160432_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:30,970 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local104160432_0006/job_local104160432_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:30,972 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local104160432_0006
2015-08-14 04:44:30,972 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 04:44:30,980 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/131265810_pearson_E8E9591EE2D34D9FAAA2E25144038877/part-00000
2015-08-14 04:44:31,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:31,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:31,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][131265810/pearson/]
2015-08-14 04:44:31,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pearson)[by:[{2}:'n1', 'n2']]
2015-08-14 04:44:31,098 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:31,098 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:31,109 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pearson)[by:[{2}:'n1', 'n2']]
2015-08-14 04:44:31,110 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite"]
2015-08-14 04:44:31,166 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite/_temporary
2015-08-14 04:44:31,244 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/pearson/composite
2015-08-14 04:44:31,282 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:44:31,282 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 04:44:31,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 04:44:31,369 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:31,369 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long"]
2015-08-14 04:44:31,369 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] parallel execution is enabled: false
2015-08-14 04:44:31,369 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting jobs: 3
2015-08-14 04:44:31,370 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] allocating threads: 1
2015-08-14 04:44:31,371 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 04:44:31,461 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1545440769/.staging/job_local1545440769_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:31,462 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1545440769/.staging/job_local1545440769_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:31,519 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1545440769_0007/job_local1545440769_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:31,520 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1545440769_0007/job_local1545440769_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:31,521 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1545440769_0007
2015-08-14 04:44:31,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:31,528 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt
2015-08-14 04:44:31,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:31,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:31,685 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:31,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 04:44:31,714 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:31,714 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:31,724 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 04:44:31,724 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][946231214/euclidean/]
2015-08-14 04:44:31,733 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:31,733 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:31,784 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 04:44:31,882 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1572755837/.staging/job_local1572755837_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:31,883 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1572755837/.staging/job_local1572755837_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:31,945 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1572755837_0008/job_local1572755837_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:31,946 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1572755837_0008/job_local1572755837_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:31,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1572755837_0008
2015-08-14 04:44:31,947 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:31,954 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/946231214_euclidean_1803DFE7EA29445784D601009425FD51/part-00000
2015-08-14 04:44:32,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:32,099 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:32,109 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][946231214/euclidean/]
2015-08-14 04:44:32,109 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:32,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:32,157 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:32,167 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:32,167 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][5270672403/euclidean/]
2015-08-14 04:44:32,228 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...seplatform/euclidean/long
2015-08-14 04:44:32,325 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1536425240/.staging/job_local1536425240_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:32,326 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1536425240/.staging/job_local1536425240_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:32,381 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1536425240_0009/job_local1536425240_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:32,382 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1536425240_0009/job_local1536425240_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:32,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1536425240_0009
2015-08-14 04:44:32,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:32,391 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/5270672403_euclidean_3EEF564458BF4F33A396502C7E0F0DAB/part-00000
2015-08-14 04:44:32,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:32,542 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:32,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][5270672403/euclidean/]
2015-08-14 04:44:32,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 04:44:32,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:32,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:32,595 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 04:44:32,596 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long"]
2015-08-14 04:44:32,645 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long/_temporary
2015-08-14 04:44:32,723 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/long
2015-08-14 04:44:32,762 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:44:32,763 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 04:44:32,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 04:44:32,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:32,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short"]
2015-08-14 04:44:32,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] parallel execution is enabled: false
2015-08-14 04:44:32,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting jobs: 3
2015-08-14 04:44:32,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] allocating threads: 1
2015-08-14 04:44:32,838 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 04:44:32,924 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1986959409/.staging/job_local1986959409_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:32,925 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1986959409/.staging/job_local1986959409_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:32,977 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1986959409_0010/job_local1986959409_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:32,979 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1986959409_0010/job_local1986959409_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:32,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1986959409_0010
2015-08-14 04:44:32,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:32,986 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt
2015-08-14 04:44:33,298 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:33,299 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:33,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/critics.txt"]
2015-08-14 04:44:33,309 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 04:44:33,335 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:33,336 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:33,345 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 04:44:33,345 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][3022539810/euclidean/]
2015-08-14 04:44:33,354 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:33,354 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:33,404 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 04:44:33,498 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1239050047/.staging/job_local1239050047_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:33,500 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1239050047/.staging/job_local1239050047_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:33,551 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1239050047_0011/job_local1239050047_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:33,553 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1239050047_0011/job_local1239050047_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:33,554 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1239050047_0011
2015-08-14 04:44:33,554 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:33,560 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3022539810_euclidean_2F94406479094163B275FC563C313B9B/part-00000
2015-08-14 04:44:33,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:33,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:33,717 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][3022539810/euclidean/]
2015-08-14 04:44:33,717 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:33,755 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:33,755 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:33,763 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 04:44:33,764 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][5643275811/euclidean/]
2015-08-14 04:44:33,815 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...eplatform/euclidean/short
2015-08-14 04:44:33,908 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1539482007/.staging/job_local1539482007_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:33,909 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1539482007/.staging/job_local1539482007_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:33,969 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1539482007_0012/job_local1539482007_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:44:33,971 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1539482007_0012/job_local1539482007_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:44:33,972 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1539482007_0012
2015-08-14 04:44:33,973 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 04:44:33,979 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/5643275811_euclidean_21B21421A2704B29AE81536D6362DDA2/part-00000
2015-08-14 04:44:34,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:34,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:34,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][5643275811/euclidean/]
2015-08-14 04:44:34,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 04:44:34,165 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:34,166 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:34,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 04:44:34,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short"]
2015-08-14 04:44:34,226 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short/_temporary
2015-08-14 04:44:34,308 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/short