Class cascading.DistanceUseCasePlatformTest

4

tests

0

failures

9.102s

duration

100%

successful

Tests

Test Duration Result
testEuclideanDistance 1.466s passed
testEuclideanDistanceComposite 4.271s passed
testEuclideanDistanceShort 1.576s passed
testPearsonDistanceComposite 1.789s passed

Standard output

2015-08-14 02:51:32,997 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 02:51:33,060 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 02:51:33,060 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.DistanceUseCasePlatformTest
2015-08-14 02:51:33,096 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 02:51:33,728 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 02:51:33,896 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 02:51:34,053 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:34,056 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 02:51:34,070 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 7DA03202BEC54D5B9516A5B929B18D41
2015-08-14 02:51:34,427 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 02:51:34,429 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 02:51:34,430 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:34,431 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite"]
2015-08-14 02:51:34,431 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  parallel execution is enabled: false
2015-08-14 02:51:34,432 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  starting jobs: 3
2015-08-14 02:51:34,432 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  allocating threads: 1
2015-08-14 02:51:34,436 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 02:51:35,119 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2009043934/.staging/job_local2009043934_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:35,120 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2009043934/.staging/job_local2009043934_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:35,292 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2009043934_0001/job_local2009043934_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:35,293 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2009043934_0001/job_local2009043934_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:35,304 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local2009043934_0001
2015-08-14 02:51:35,304 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:35,414 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt
2015-08-14 02:51:35,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:35,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:35,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:35,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 02:51:35,866 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:35,867 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:35,890 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 02:51:35,890 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][2968779634/euclidean/]
2015-08-14 02:51:35,926 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:35,927 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:36,043 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 02:51:36,177 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1403857014/.staging/job_local1403857014_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:36,179 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1403857014/.staging/job_local1403857014_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:36,274 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1403857014_0002/job_local1403857014_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:36,274 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1403857014_0002/job_local1403857014_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:36,277 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1403857014_0002
2015-08-14 02:51:36,277 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:36,286 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/2968779634_euclidean_770F0B209C8146CF80AF9ECBDEA3147E/part-00000
2015-08-14 02:51:36,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:36,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:36,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][2968779634/euclidean/]
2015-08-14 02:51:36,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:36,598 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:36,598 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:36,614 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:36,614 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][5863801951/euclidean/]
2015-08-14 02:51:36,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...tform/euclidean/composite
2015-08-14 02:51:36,849 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity884151186/.staging/job_local884151186_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:36,850 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity884151186/.staging/job_local884151186_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:36,922 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local884151186_0003/job_local884151186_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:36,923 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local884151186_0003/job_local884151186_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:36,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local884151186_0003
2015-08-14 02:51:36,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:36,937 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/5863801951_euclidean_844C3C0D12D046B080E6F575C267A345/part-00000
2015-08-14 02:51:37,114 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:37,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:37,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][5863801951/euclidean/]
2015-08-14 02:51:37,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'n1', 'n2']]
2015-08-14 02:51:37,175 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:37,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:37,189 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'n1', 'n2']]
2015-08-14 02:51:37,190 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite"]
2015-08-14 02:51:37,259 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/composite/_temporary
2015-08-14 02:51:37,363 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/composite
2015-08-14 02:51:37,409 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:37,409 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 02:51:37,495 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson] starting
2015-08-14 02:51:37,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:37,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite"]
2015-08-14 02:51:37,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson]  parallel execution is enabled: false
2015-08-14 02:51:37,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson]  starting jobs: 3
2015-08-14 02:51:37,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pearson]  allocating threads: 1
2015-08-14 02:51:37,497 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (1/3)
2015-08-14 02:51:37,591 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2132339954/.staging/job_local2132339954_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:37,591 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2132339954/.staging/job_local2132339954_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:37,664 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2132339954_0004/job_local2132339954_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:37,665 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2132339954_0004/job_local2132339954_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:37,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local2132339954_0004
2015-08-14 02:51:37,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 02:51:37,674 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt
2015-08-14 02:51:37,817 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:37,818 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:37,835 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:37,835 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(pearson)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 02:51:37,865 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:37,866 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:37,880 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(pearson)[by:[{1}:'l'][numSelfJoins:1]]
2015-08-14 02:51:37,881 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][3962209224/pearson/]
2015-08-14 02:51:37,890 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:37,891 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:37,950 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (2/3)
2015-08-14 02:51:38,063 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity441617569/.staging/job_local441617569_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:38,063 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity441617569/.staging/job_local441617569_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:38,128 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local441617569_0005/job_local441617569_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:38,129 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local441617569_0005/job_local441617569_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:38,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local441617569_0005
2015-08-14 02:51:38,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 02:51:38,141 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3962209224_pearson_DC7A81DE1A18458FB3EE6407C82CE9BC/part-00000
2015-08-14 02:51:38,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:38,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:38,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][3962209224/pearson/]
2015-08-14 02:51:38,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pearson)[by:[{?}:ALL]]
2015-08-14 02:51:38,352 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:38,353 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:38,365 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pearson)[by:[{?}:ALL]]
2015-08-14 02:51:38,365 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][9734752655/pearson/]
2015-08-14 02:51:38,436 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] starting step: (3/3) ...latform/pearson/composite
2015-08-14 02:51:38,825 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1155781270/.staging/job_local1155781270_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:38,825 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1155781270/.staging/job_local1155781270_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:38,884 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1155781270_0006/job_local1155781270_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:38,884 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1155781270_0006/job_local1155781270_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:38,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] submitted hadoop job: job_local1155781270_0006
2015-08-14 02:51:38,887 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pearson] tracking url: http://localhost:8080/
2015-08-14 02:51:38,894 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/9734752655_pearson_F68AB7EAA37944D2B77245B53D9F1FA5/part-00000
2015-08-14 02:51:38,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:38,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:38,980 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['l', 'n1', 'v1', 'n2', 'v2']]"][9734752655/pearson/]
2015-08-14 02:51:38,980 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pearson)[by:[{2}:'n1', 'n2']]
2015-08-14 02:51:39,015 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:39,016 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:39,027 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pearson)[by:[{2}:'n1', 'n2']]
2015-08-14 02:51:39,027 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite"]
2015-08-14 02:51:39,081 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/pearson/composite/_temporary
2015-08-14 02:51:39,155 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/pearson/composite
2015-08-14 02:51:39,192 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:39,193 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 02:51:39,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 02:51:39,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:39,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long"]
2015-08-14 02:51:39,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  parallel execution is enabled: false
2015-08-14 02:51:39,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  starting jobs: 3
2015-08-14 02:51:39,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  allocating threads: 1
2015-08-14 02:51:39,281 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 02:51:39,370 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity977490360/.staging/job_local977490360_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:39,370 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity977490360/.staging/job_local977490360_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:39,424 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local977490360_0007/job_local977490360_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:39,425 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local977490360_0007/job_local977490360_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:39,426 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local977490360_0007
2015-08-14 02:51:39,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:39,434 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt
2015-08-14 02:51:39,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:39,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:39,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:39,589 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 02:51:39,617 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:39,617 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:39,627 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 02:51:39,627 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][1588629318/euclidean/]
2015-08-14 02:51:39,638 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:39,638 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:39,690 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 02:51:39,786 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity754662840/.staging/job_local754662840_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:39,787 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity754662840/.staging/job_local754662840_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:39,854 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local754662840_0008/job_local754662840_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:39,854 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local754662840_0008/job_local754662840_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:39,856 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local754662840_0008
2015-08-14 02:51:39,856 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:39,863 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/1588629318_euclidean_00DB4EFC62ED43D793F433CEA468CF77/part-00000
2015-08-14 02:51:40,008 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:40,008 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:40,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][1588629318/euclidean/]
2015-08-14 02:51:40,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:40,064 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:40,065 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:40,074 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:40,074 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][6167046721/euclidean/]
2015-08-14 02:51:40,137 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...seplatform/euclidean/long
2015-08-14 02:51:40,232 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1843867795/.staging/job_local1843867795_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:40,232 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1843867795/.staging/job_local1843867795_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:40,286 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1843867795_0009/job_local1843867795_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:40,286 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1843867795_0009/job_local1843867795_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:40,287 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1843867795_0009
2015-08-14 02:51:40,288 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:40,295 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/6167046721_euclidean_82BDA4EE44F34D2C9468BB22F52C6DF2/part-00000
2015-08-14 02:51:40,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:40,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:40,453 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][6167046721/euclidean/]
2015-08-14 02:51:40,453 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 02:51:40,487 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:40,487 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:40,497 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 02:51:40,498 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long"]
2015-08-14 02:51:40,540 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/long/_temporary
2015-08-14 02:51:40,621 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/long
2015-08-14 02:51:40,660 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:40,661 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 02:51:40,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean] starting
2015-08-14 02:51:40,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:40,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short"]
2015-08-14 02:51:40,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  parallel execution is enabled: false
2015-08-14 02:51:40,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  starting jobs: 3
2015-08-14 02:51:40,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [euclidean]  allocating threads: 1
2015-08-14 02:51:40,730 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (1/3)
2015-08-14 02:51:40,817 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1270576845/.staging/job_local1270576845_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:40,817 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1270576845/.staging/job_local1270576845_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:40,870 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1270576845_0010/job_local1270576845_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:40,870 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1270576845_0010/job_local1270576845_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:40,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1270576845_0010
2015-08-14 02:51:40,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:40,879 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt
2015-08-14 02:51:41,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:41,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:41,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/critics.txt"]
2015-08-14 02:51:41,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 02:51:41,223 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:41,223 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:41,231 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(euclidean)[by:[{1}:'movie'][numSelfJoins:1]]
2015-08-14 02:51:41,232 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][9979111820/euclidean/]
2015-08-14 02:51:41,241 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:41,241 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:41,292 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (2/3)
2015-08-14 02:51:41,384 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1453861366/.staging/job_local1453861366_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:41,384 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1453861366/.staging/job_local1453861366_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:41,437 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1453861366_0011/job_local1453861366_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:41,438 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1453861366_0011/job_local1453861366_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:41,440 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local1453861366_0011
2015-08-14 02:51:41,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:41,446 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/9979111820_euclidean_EF000F50921343BC9238356B87DA98A3/part-00000
2015-08-14 02:51:41,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:41,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:41,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2']]"][9979111820/euclidean/]
2015-08-14 02:51:41,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:41,637 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:41,637 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:41,646 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{?}:ALL]]
2015-08-14 02:51:41,646 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][8967151060/euclidean/]
2015-08-14 02:51:41,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] starting step: (3/3) ...eplatform/euclidean/short
2015-08-14 02:51:41,794 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998537159/.staging/job_local998537159_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:41,794 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998537159/.staging/job_local998537159_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:41,863 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998537159_0012/job_local998537159_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 02:51:41,864 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998537159_0012/job_local998537159_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 02:51:41,865 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] submitted hadoop job: job_local998537159_0012
2015-08-14 02:51:41,867 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [euclidean] tracking url: http://localhost:8080/
2015-08-14 02:51:41,873 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/8967151060_euclidean_E7E3E3D9D4D2414DBECFBA434D95CC02/part-00000
2015-08-14 02:51:42,019 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:42,019 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:42,030 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['movie', 'name1', 'rate1', 'name2', 'rate2', 'score']]"][8967151060/euclidean/]
2015-08-14 02:51:42,030 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 02:51:42,060 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:42,061 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:42,070 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(euclidean)[by:[{2}:'name1', 'name2']]
2015-08-14 02:51:42,071 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short"]
2015-08-14 02:51:42,128 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/distanceusecaseplatform/euclidean/short/_temporary
2015-08-14 02:51:42,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/distanceusecaseplatform/euclidean/short