Class cascading.TypedFieldedPipesPlatformTest

12

tests

0

failures

0

ignored

2.986s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparableTypes 0.305s passed
testCoGroupComparableTypesDeclared 0.162s passed
testCoGroupIncomparableTypes 0.098s passed
testCoGroupIncomparableTypesDeclared 0.081s passed
testFieldTypeCheck 1.370s passed
testGroupByComparableTypes 0.103s passed
testGroupByIncomparableTypes 0.031s passed
testHashJoinComparableTypes 0.106s passed
testHashJoinComparableTypesDeclared 0.088s passed
testHashJoinIncomparableTypes 0.558s passed
testHashJoinIncomparableTypesDeclared 0.043s passed
testMergeIncomparableTypes 0.041s passed

Standard output

2016-05-18 03:13:09,792 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 03:13:09,810 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.TypedFieldedPipesPlatformTest, with platform: hadoop
2016-05-18 03:13:09,837 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 03:13:10,064 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 03:13:10,170 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:10,172 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:10,273 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4571DD7DF17E47D1B58DF45F5DF140D8
2016-05-18 03:13:10,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.072
2016-05-18 03:13:10,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:10,392 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testHashJoinIncomparableTypes/testHashJoinIncomparableTypes
2016-05-18 03:13:10,442 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:10,443 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:10,491 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.039
2016-05-18 03:13:10,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:10,493 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testCoGroupIncomparableTypes/testCoGroupIncomparableTypes
2016-05-18 03:13:10,528 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:10,529 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:10,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2016-05-18 03:13:10,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:13:10,642 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:10,713 WARN  flow.Flow (BaseFlow.java:logWarn(1528)) - [lhs*rhs] unable to perform: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num1']], on mismatched join types and optimize serialization with type exclusion, fields: 'num' | long & 'num1' | short
2016-05-18 03:13:10,800 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testCoGroupComparableTypes/testCoGroupComparableTypes
2016-05-18 03:13:10,834 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:10,836 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:10,879 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.033
2016-05-18 03:13:10,880 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:10,881 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testCoGroupIncomparableTypesDeclared/testCoGroupIncomparableTypesDeclared
2016-05-18 03:13:10,914 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:10,915 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,006 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 03:13:11,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:13:11,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:11,022 WARN  flow.Flow (BaseFlow.java:logWarn(1528)) - [lhs*rhs] unable to perform: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']], on mismatched join types and optimize serialization with type exclusion, fields: 'num' | long & 'num' | short
2016-05-18 03:13:11,043 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testCoGroupComparableTypesDeclared/testCoGroupComparableTypesDeclared
2016-05-18 03:13:11,072 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,073 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,132 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 03:13:11,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:13:11,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:11,151 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testHashJoinComparableTypes/testHashJoinComparableTypes
2016-05-18 03:13:11,171 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,172 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,226 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 03:13:11,227 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:13:11,227 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:11,254 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testGroupByComparableTypes/testGroupByComparableTypes
2016-05-18 03:13:11,272 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,273 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.018
2016-05-18 03:13:11,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:11,297 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testHashJoinIncomparableTypesDeclared/testHashJoinIncomparableTypesDeclared
2016-05-18 03:13:11,324 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,325 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,367 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 03:13:11,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:13:11,369 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:11,385 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testHashJoinComparableTypesDeclared/testHashJoinComparableTypesDeclared
2016-05-18 03:13:11,404 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,405 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.016
2016-05-18 03:13:11,426 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:11,427 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testMergeIncomparableTypes/testMergeIncomparableTypes
2016-05-18 03:13:11,646 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:11,647 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:11,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.119
2016-05-18 03:13:11,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:13:11,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:13:11,850 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 03:13:11,851 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 03:13:11,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, String, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 03:13:11,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 03:13:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  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',canonicalType='long'}, String, int, long, String, String, String, String, String, String, long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck/testFieldTypeCheck"]
2016-05-18 03:13:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: false
2016-05-18 03:13:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 1
2016-05-18 03:13:11,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 1
2016-05-18 03:13:11,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/1) ...eCheck/testFieldTypeCheck
2016-05-18 03:13:11,900 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 03:13:11,954 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 03:13:12,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_local_0001
2016-05-18 03:13:12,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://localhost:8080/
2016-05-18 03:13:12,229 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt
2016-05-18 03:13:12,358 INFO  hadoop.TupleSerialization (TupleSerialization.java:areTypesRequired(287)) - types are being enforced during serialization
2016-05-18 03:13:12,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:13:12,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:13:12,401 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B7B47EA37739425D98DD32CB143EE549, ordinal: 0
2016-05-18 03:13:12,439 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - 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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 03:13:12,439 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2016-05-18 03:13:12,440 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B7B47EA37739425D98DD32CB143EE549, mem on start (mb), free: 93, total: 223, max: 672
2016-05-18 03:13:12,532 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B7B47EA37739425D98DD32CB143EE549, mem on close (mb), free: 89, total: 223, max: 672
2016-05-18 03:13:12,540 INFO  hadoop.TupleSerialization (TupleSerialization.java:areTypesRequired(287)) - types are being enforced during serialization
2016-05-18 03:13:12,552 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt
2016-05-18 03:13:12,650 INFO  hadoop.TupleSerialization (TupleSerialization.java:areTypesRequired(287)) - types are being enforced during serialization
2016-05-18 03:13:12,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 03:13:12,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 03:13:12,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B7B47EA37739425D98DD32CB143EE549, ordinal: 0
2016-05-18 03:13:12,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, String, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 03:13:12,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2016-05-18 03:13:12,673 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B7B47EA37739425D98DD32CB143EE549, mem on start (mb), free: 82, total: 318, max: 672
2016-05-18 03:13:12,682 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B7B47EA37739425D98DD32CB143EE549, mem on close (mb), free: 82, total: 318, max: 672
2016-05-18 03:13:12,685 INFO  hadoop.TupleSerialization (TupleSerialization.java:areTypesRequired(287)) - types are being enforced during serialization
2016-05-18 03:13:12,712 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 03:13:12,712 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 03:13:12,724 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E428B22A9B92428C97D850FB101F46F5, ordinal: 1
2016-05-18 03:13:12,726 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2016-05-18 03:13:12,727 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - 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',canonicalType='long'}, String, int, long, String, String, String, String, String, String, long, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck/testFieldTypeCheck"]
2016-05-18 03:13:12,727 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E428B22A9B92428C97D850FB101F46F5, mem on start (mb), free: 80, total: 318, max: 672
2016-05-18 03:13:12,739 INFO  hadoop.TupleSerialization (TupleSerialization.java:areTypesRequired(287)) - types are being enforced during serialization
2016-05-18 03:13:12,748 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:13:12,748 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 03:13:12,763 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E428B22A9B92428C97D850FB101F46F5, mem on close (mb), free: 78, total: 318, max: 672
2016-05-18 03:13:12,780 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck/testFieldTypeCheck/_temporary
2016-05-18 03:13:12,781 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:00.927
2016-05-18 03:13:12,797 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testFieldTypeCheck/testFieldTypeCheck
2016-05-18 03:13:12,811 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:13:12,812 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:13:12,827 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-05-18 03:13:12,828 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:13:12,828 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/typedfieldedpipesplatform/testGroupByIncomparableTypes/testGroupByIncomparableTypes