Class cascading.tuple.hadoop.SerializedPipesPlatformTest

13

tests

0

failures

5m40.61s

duration

100%

successful

Tests

Test Duration Result
testBigDecimal 17.875s passed
testCoGroupBytesWritableAsKeyValue 15.960s passed
testCoGroupRawAsKeyValue 31.447s passed
testCoGroupRawAsKeyValueDefault 32.633s passed
testCoGroupRawAsKeyValueDefaultIgnoreToken 31.738s passed
testCoGroupRawAsKeyValueDefaultIgnoreTokenCompositeGrouping 30.574s passed
testCoGroupRawAsKeyValueDefaultNoSecondary 33.602s passed
testCoGroupRawAsKeyValueDefaultNoSecondaryCompositeGrouping 32.928s passed
testCoGroupRawAsKeyValueNoSecondary 33.935s passed
testCoGroupSpillCustomWritable 16.014s passed
testCoGroupWritableAsKeyValue 16.909s passed
testSimpleGroup 29.217s passed
testSimpleGroupOnBytes 17.779s passed

Standard output

2015-08-14 00:15:44,414 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 00:15:44,462 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-14 00:15:44,462 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tuple.hadoop.SerializedPipesPlatformTest
2015-08-14 00:15:44,500 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-14 00:15:45,599 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2015-08-14 00:15:46,743 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:15:46,745 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:15:46,896 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2015-08-14 00:15:51,108 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:15:51,109 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:15:51,188 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2015-08-14 00:15:51,522 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:15:51,524 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:15:51,614 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2015-08-14 00:15:51,943 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:15:51,943 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:15:52,023 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2015-08-14 00:15:52,422 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2015-08-14 00:15:52,422 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:316)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:311)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:396)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:15:53,493 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:15:53,849 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:15:54,175 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:15:54,499 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:15:55,881 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 00:15:55,984 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:15:55,986 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:15:55,997 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 562A775F29B84DE697817568A3DDC71A
2015-08-14 00:15:56,175 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 00:15:56,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 00:15:56,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-08-14 00:15:56,178 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["SequenceFile[[UNKNOWN]->['ip', 'count', 'boolean']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/serialization"]
2015-08-14 00:15:56,178 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-14 00:15:56,178 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-14 00:15:56,178 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-14 00:15:56,180 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/serialization
2015-08-14 00:15:56,289 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-14 00:15:56,587 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_20150814001552369_0001
2015-08-14 00:15:56,588 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0001
2015-08-14 00:16:13,623 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/serialization/_temporary
2015-08-14 00:16:13,705 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/serialization
2015-08-14 00:16:13,782 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:16:13,783 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:16:13,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:16:13,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:16:13,829 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:16:13,829 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[[UNKNOWN]->[0:7]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/writablekeyvalue"]
2015-08-14 00:16:13,830 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:16:13,830 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 00:16:13,830 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 00:16:13,832 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...platform/writablekeyvalue
2015-08-14 00:16:14,508 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:14,629 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:14,652 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:14,783 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:14,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0002
2015-08-14 00:16:14,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0002
2015-08-14 00:16:14,961 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:15,219 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:16,416 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:30,590 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/writablekeyvalue/_temporary
2015-08-14 00:16:30,616 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/writablekeyvalue
2015-08-14 00:16:30,649 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:16:30,650 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:16:30,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:16:30,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:16:30,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:16:30,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false"]
2015-08-14 00:16:30,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:16:30,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:16:30,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:16:30,707 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:16:30,846 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0002 being deleted.
2015-08-14 00:16:31,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0003
2015-08-14 00:16:31,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0003
2015-08-14 00:16:31,697 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:32,269 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:32,618 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:32,644 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:32,938 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:33,563 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:33,655 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:47,509 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...ue/true/false/false/false
2015-08-14 00:16:47,963 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:48,092 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0004
2015-08-14 00:16:48,092 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0004
2015-08-14 00:16:48,460 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0003 being deleted.
2015-08-14 00:16:48,847 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0003 being deleted.
2015-08-14 00:16:48,894 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:49,137 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:16:49,288 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:04,181 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false/_temporary
2015-08-14 00:17:04,219 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false
2015-08-14 00:17:04,246 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:17:04,247 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:17:04,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:17:04,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:17:04,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:17:04,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/byteswritablekeyvalue"]
2015-08-14 00:17:04,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:17:04,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 00:17:04,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 00:17:04,280 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...orm/byteswritablekeyvalue
2015-08-14 00:17:04,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0005
2015-08-14 00:17:04,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0005
2015-08-14 00:17:04,461 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0004 being deleted.
2015-08-14 00:17:05,091 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:05,774 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:05,809 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0004 being deleted.
2015-08-14 00:17:06,019 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:06,138 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0004 being deleted.
2015-08-14 00:17:20,133 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/byteswritablekeyvalue/_temporary
2015-08-14 00:17:20,181 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/byteswritablekeyvalue
2015-08-14 00:17:20,205 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:17:20,206 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:17:20,231 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 00:17:20,231 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line' | cascading.tuple.coerce.BigDecimalCoerce@7d56b386, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-08-14 00:17:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["SequenceFile[['offset', 'count' | cascading.tuple.coerce.BigDecimalCoerce@7d56b386, long]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/bigdecimal"]
2015-08-14 00:17:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-14 00:17:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-14 00:17:20,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-14 00:17:20,234 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...dpipesplatform/bigdecimal
2015-08-14 00:17:20,349 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:20,397 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:20,462 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0005 being deleted.
2015-08-14 00:17:20,793 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_20150814001552369_0006
2015-08-14 00:17:20,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0006
2015-08-14 00:17:21,917 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:22,038 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:22,120 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:22,594 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:23,138 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:38,036 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/bigdecimal/_temporary
2015-08-14 00:17:38,056 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/bigdecimal
2015-08-14 00:17:38,084 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:17:38,085 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:17:38,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:17:38,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:17:38,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:17:38,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false"]
2015-08-14 00:17:38,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:17:38,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:17:38,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:17:38,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:17:38,649 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:38,957 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:39,033 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:39,037 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:39,087 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0007
2015-08-14 00:17:39,087 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0007
2015-08-14 00:17:39,206 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:40,700 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:53,780 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...alue/true/true/true/false
2015-08-14 00:17:54,142 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0007 being deleted.
2015-08-14 00:17:54,328 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0008
2015-08-14 00:17:54,328 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0008
2015-08-14 00:17:54,750 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:54,808 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:54,853 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0007 being deleted.
2015-08-14 00:17:55,382 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:17:56,592 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:09,762 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false/_temporary
2015-08-14 00:18:09,795 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false
2015-08-14 00:18:09,826 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:18:09,827 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:18:09,866 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:09,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:18:09,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:18:09,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:18:09,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false"]
2015-08-14 00:18:09,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:18:09,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:18:09,883 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:18:09,884 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:18:10,036 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0009
2015-08-14 00:18:10,036 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0009
2015-08-14 00:18:10,143 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0008 being deleted.
2015-08-14 00:18:10,277 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:10,466 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0008 being deleted.
2015-08-14 00:18:10,610 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:10,854 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0008 being deleted.
2015-08-14 00:18:24,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...ue/false/true/false/false
2015-08-14 00:18:25,821 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0010
2015-08-14 00:18:25,822 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0010
2015-08-14 00:18:26,144 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0009 being deleted.
2015-08-14 00:18:26,261 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:26,393 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:26,407 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:26,855 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0009 being deleted.
2015-08-14 00:18:27,693 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:41,210 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false/_temporary
2015-08-14 00:18:41,243 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false
2015-08-14 00:18:41,267 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:18:41,268 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:18:41,307 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:18:41,308 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:18:41,308 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:18:41,309 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true"]
2015-08-14 00:18:41,309 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:18:41,310 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:18:41,310 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:18:41,312 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:18:41,852 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0011
2015-08-14 00:18:41,852 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0011
2015-08-14 00:18:41,985 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:42,015 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:42,145 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0010 being deleted.
2015-08-14 00:18:42,469 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0010 being deleted.
2015-08-14 00:18:42,856 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0010 being deleted.
2015-08-14 00:18:43,266 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:56,574 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...value/true/true/true/true
2015-08-14 00:18:56,707 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0012
2015-08-14 00:18:56,708 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0012
2015-08-14 00:18:56,857 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0011 being deleted.
2015-08-14 00:18:57,059 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:58,147 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0011 being deleted.
2015-08-14 00:18:59,460 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:18:59,499 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:00,088 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:11,786 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true/_temporary
2015-08-14 00:19:11,818 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true
2015-08-14 00:19:11,822 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0012 being deleted.
2015-08-14 00:19:11,842 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:19:11,842 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:19:11,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:19:11,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:19:11,883 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:19:11,883 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false"]
2015-08-14 00:19:11,884 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:19:11,884 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:19:11,884 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:19:11,888 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:19:12,148 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0012 being deleted.
2015-08-14 00:19:12,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0013
2015-08-14 00:19:12,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0013
2015-08-14 00:19:12,858 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0012 being deleted.
2015-08-14 00:19:12,881 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:12,918 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:13,156 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:28,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...e/false/false/false/false
2015-08-14 00:19:28,859 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0013 being deleted.
2015-08-14 00:19:29,823 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0013 being deleted.
2015-08-14 00:19:30,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0014
2015-08-14 00:19:30,053 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0014
2015-08-14 00:19:30,382 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:30,669 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:31,588 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:31,735 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:45,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false/_temporary
2015-08-14 00:19:45,753 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false
2015-08-14 00:19:45,778 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:19:45,778 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:19:45,814 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:19:45,814 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:19:45,814 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:19:45,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false"]
2015-08-14 00:19:45,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:19:45,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:19:45,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:19:45,817 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:19:45,824 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0014 being deleted.
2015-08-14 00:19:46,150 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0014 being deleted.
2015-08-14 00:19:46,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0015
2015-08-14 00:19:46,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0015
2015-08-14 00:19:46,656 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:46,860 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0014 being deleted.
2015-08-14 00:19:47,307 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:19:47,686 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:01,132 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...lue/true/true/false/false
2015-08-14 00:20:01,685 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0016
2015-08-14 00:20:01,686 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0016
2015-08-14 00:20:01,912 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:02,151 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0015 being deleted.
2015-08-14 00:20:02,480 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:02,647 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:02,685 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:02,861 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0015 being deleted.
2015-08-14 00:20:18,354 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false/_temporary
2015-08-14 00:20:18,387 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false
2015-08-14 00:20:18,406 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:20:18,406 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:20:18,425 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 00:20:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-08-14 00:20:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["SequenceFile[[UNKNOWN]->['bytes', 'count']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/grouponbytes"]
2015-08-14 00:20:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-14 00:20:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-14 00:20:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-14 00:20:18,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/grouponbytes
2015-08-14 00:20:18,684 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:18,826 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:18,862 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0016 being deleted.
2015-08-14 00:20:19,375 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_20150814001552369_0017
2015-08-14 00:20:19,375 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0017
2015-08-14 00:20:19,493 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:19,827 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0016 being deleted.
2015-08-14 00:20:20,152 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0016 being deleted.
2015-08-14 00:20:36,150 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/grouponbytes/_temporary
2015-08-14 00:20:36,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/grouponbytes
2015-08-14 00:20:36,190 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:20:36,191 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:20:36,228 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:20:36,228 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:20:36,229 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:20:36,229 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true"]
2015-08-14 00:20:36,230 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:20:36,230 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 00:20:36,230 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 00:20:36,233 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-14 00:20:36,624 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:37,173 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0018
2015-08-14 00:20:37,173 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0018
2015-08-14 00:20:37,405 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:37,425 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:37,621 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:37,661 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:39,036 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:52,493 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...lue/true/false/false/true
2015-08-14 00:20:52,864 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0018 being deleted.
2015-08-14 00:20:53,829 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0018 being deleted.
2015-08-14 00:20:53,840 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0019
2015-08-14 00:20:53,840 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0019
2015-08-14 00:20:54,615 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:54,819 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:54,981 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:20:55,176 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:09,065 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true/_temporary
2015-08-14 00:21:09,095 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true
2015-08-14 00:21: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 00:21: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-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:09,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 00:21:09,143 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:21:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:21:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["SequenceFile[[UNKNOWN]->[0:9]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/customerwritable"]
2015-08-14 00:21:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 00:21:09,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 00:21:09,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 00:21:09,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...platform/customerwritable
2015-08-14 00:21:09,295 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_20150814001552369_0020
2015-08-14 00:21:09,295 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:50644/jobdetails.jsp?jobid=job_20150814001552369_0020
2015-08-14 00:21:09,830 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0019 being deleted.
2015-08-14 00:21:10,156 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0019 being deleted.
2015-08-14 00:21:10,157 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:10,865 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814001552369_0019 being deleted.
2015-08-14 00:21:10,898 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:11,435 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:25,092 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/serializedpipesplatform/customerwritable/_temporary
2015-08-14 00:21:25,110 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/serializedpipesplatform/customerwritable