Class cascading.TypedFieldedPipesPlatformTest

12

tests

0

failures

3.973s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparableTypes 0.200s passed
testCoGroupComparableTypesDeclared 0.083s passed
testCoGroupIncomparableTypes 0.114s passed
testCoGroupIncomparableTypesDeclared 0.057s passed
testFieldTypeCheck 2.153s passed
testGroupByComparableTypes 0.067s passed
testGroupByIncomparableTypes 0.035s passed
testHashJoinComparableTypes 0.079s passed
testHashJoinComparableTypesDeclared 0.058s passed
testHashJoinIncomparableTypes 1.038s passed
testHashJoinIncomparableTypesDeclared 0.042s passed
testMergeIncomparableTypes 0.047s passed

Standard output

2015-08-14 04:44:06,950 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 04:44:07,013 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 04:44:07,013 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.TypedFieldedPipesPlatformTest
2015-08-14 04:44:07,052 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 04:44:07,689 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:07,853 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 04:44:08,007 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:08,010 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:08,023 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 986DFCB4D8644150A6B89AB4C2547543
2015-08-14 04:44:08,087 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/typedfieldedpipesplatform/testHashJoinIncomparableTypes
2015-08-14 04:44:08,177 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:08,178 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:08,205 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/typedfieldedpipesplatform/testCoGroupIncomparableTypes
2015-08-14 04:44:08,252 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:08,253 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:08,404 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/typedfieldedpipesplatform/testCoGroupComparableTypes
2015-08-14 04:44:08,447 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:08,448 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:08,463 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/typedfieldedpipesplatform/testCoGroupIncomparableTypesDeclared
2015-08-14 04:44:08,502 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:08,503 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:08,547 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/typedfieldedpipesplatform/testCoGroupComparableTypesDeclared
2015-08-14 04:44:08,584 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:08,585 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:08,628 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/typedfieldedpipesplatform/testHashJoinComparableTypes
2015-08-14 04:44:08,661 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:08,662 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:08,696 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/typedfieldedpipesplatform/testGroupByComparableTypes
2015-08-14 04:44:08,726 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:08,727 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:08,739 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/typedfieldedpipesplatform/testHashJoinIncomparableTypesDeclared
2015-08-14 04:44:08,768 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:08,769 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:08,798 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/typedfieldedpipesplatform/testHashJoinComparableTypesDeclared
2015-08-14 04:44:08,836 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:08,837 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:08,845 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/typedfieldedpipesplatform/testMergeIncomparableTypes
2015-08-14 04:44:09,117 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:09,118 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:09,203 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 04:44:09,204 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-14 04:44:09,205 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, Long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:44:09,206 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:44:09,206 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na', 10:19 | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String, String, String, String, Long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/typedfieldedpipesplatform/testFieldTypeCheck"]
2015-08-14 04:44:09,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: false
2015-08-14 04:44:09,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 1
2015-08-14 04:44:09,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 1
2015-08-14 04:44:09,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/1) ...atform/testFieldTypeCheck
2015-08-14 04:44:09,772 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1876117024/.staging/job_local1876117024_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:44:09,775 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1876117024/.staging/job_local1876117024_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:44:09,936 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_local1876117024_0001/job_local1876117024_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:44:09,939 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_local1876117024_0001/job_local1876117024_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:44:09,948 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_local1876117024_0001
2015-08-14 04:44:09,948 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://localhost:8080/
2015-08-14 04:44:10,056 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/apache-clean.10.txt
2015-08-14 04:44:10,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:10,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:10,318 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:44:10,318 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2015-08-14 04:44:10,465 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/apache-clean.10.txt
2015-08-14 04:44:10,609 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:44:10,610 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:44:10,633 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, Long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:44:10,633 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2015-08-14 04:44:10,792 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 04:44:10,793 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 04:44:10,817 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2015-08-14 04:44:10,817 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na', 10:19 | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String, String, String, String, Long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/typedfieldedpipesplatform/testFieldTypeCheck"]
2015-08-14 04:44:10,843 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:10,843 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 04:44:10,947 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/typedfieldedpipesplatform/testFieldTypeCheck/_temporary
2015-08-14 04:44:10,999 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/typedfieldedpipesplatform/testFieldTypeCheck
2015-08-14 04:44:11,025 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:11,026 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:11,035 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/typedfieldedpipesplatform/testGroupByIncomparableTypes