Class cascading.TrapPlatformTest

14

tests

0

failures

0

ignored

5m33.45s

duration

100%

successful

Tests

Test Duration Result
testTrapDiagnostics 24.253s passed
testTrapDiagnosticsLocalConfig 22.712s passed
testTrapEachAll 23.587s passed
testTrapEachAllChained 11.167s passed
testTrapEachAllSequence 22.626s passed
testTrapEachEveryAllChained 54.589s passed
testTrapEveryAllAtAggregate 23.177s passed
testTrapEveryAllAtComplete 22.993s passed
testTrapEveryAllAtStart 23.180s passed
testTrapFailure 34.137s passed
testTrapNoOperation 10.478s passed
testTrapNone 22.729s passed
testTrapTapSourceSink 15.457s passed
testTrapToSequenceFile 22.361s passed

Standard output

2016-01-14 22:43:41,547 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 22:43:41,564 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.TrapPlatformTest, with platform: hadoop
2016-01-14 22:43:41,591 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-01-14 22:43:42,446 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
2016-01-14 22:43:43,439 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 22:43:43,441 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:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 22:43:43,576 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
2016-01-14 22:43:43,925 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 22:43:43,926 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:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 22:43:44,018 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:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-01-14 22:43:44,270 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 22:43:44,271 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:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 22:43:44,352 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:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-01-14 22:43:44,593 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 22:43:44,594 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:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 22:43:44,663 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:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	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:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	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:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-01-14 22:43:44,980 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-01-14 22:43:44,981 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:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	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:415)
	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:745)
2016-01-14 22:43:47,016 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 22:43:47,266 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 22:43:47,531 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 22:43:47,740 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 22:43:48,961 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 22:43:49,061 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:43:49,063 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:43:49,142 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: F59E1D80478F4024A3E5D38792F6FA20
2016-01-14 22:43:49,356 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.172
2016-01-14 22:43:49,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 22:43:49,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:43:49,538 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 22:43:49,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:43:49,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:43:49,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap"]
2016-01-14 22:43:49,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:43:49,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 2
2016-01-14 22:43:49,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 2
2016-01-14 22:43:49,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/2)
2016-01-14 22:43:49,628 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 22:43:49,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0001
2016-01-14 22:43:49,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0001
2016-01-14 22:44:12,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (2/2) ...hained/eacheverychain/tap
2016-01-14 22:44:13,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0002
2016-01-14 22:44:13,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0002
2016-01-14 22:44:13,608 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:13,767 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,291 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,328 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,394 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,456 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,777 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:14,862 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:15,034 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:36,095 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap/_temporary
2016-01-14 22:44:36,099 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap/_temporary
2016-01-14 22:44:36,100 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap/_temporary
2016-01-14 22:44:36,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:46.551
2016-01-14 22:44:36,155 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap
2016-01-14 22:44:36,166 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap
2016-01-14 22:44:36,195 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:44:36,195 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:44:36,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-01-14 22:44:36,261 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:44:36,261 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:44:36,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:44:36,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:44:36,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap"]
2016-01-14 22:44:36,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:44:36,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:44:36,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:44:36,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...regate/everyaggregate/tap
2016-01-14 22:44:36,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0003
2016-01-14 22:44:36,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0003
2016-01-14 22:44:37,144 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,464 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,665 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,705 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,816 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,829 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,855 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,868 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:38,898 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:39,176 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:59,308 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap/_temporary
2016-01-14 22:44:59,311 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/trap/_temporary
2016-01-14 22:44:59,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:23.020
2016-01-14 22:44:59,343 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap
2016-01-14 22:44:59,349 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/trap
2016-01-14 22:44:59,373 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:44:59,373 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:44:59,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 22:44:59,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:44:59,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:44:59,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:44:59,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:44:59,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/tap"]
2016-01-14 22:44:59,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:44:59,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:44:59,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:44:59,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...m/testTrapEachAll/all/tap
2016-01-14 22:44:59,798 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:44:59,829 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:00,311 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:00,353 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:00,450 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:00,638 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:01,170 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:01,178 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:01,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0004
2016-01-14 22:45:01,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0004
2016-01-14 22:45:01,910 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:02,588 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:22,883 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/tap/_temporary
2016-01-14 22:45:22,884 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/trap/_temporary
2016-01-14 22:45:22,887 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:23.405
2016-01-14 22:45:22,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAll/all/trap
2016-01-14 22:45:22,937 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAll/all/tap
2016-01-14 22:45:22,954 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:45:22,954 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:45:23,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-14 22:45:23,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:45:23,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:45:23,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:45:23,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["HadoopFailScheme[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:45:23,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["HadoopFailScheme[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink"]
2016-01-14 22:45:23,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:45:23,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:45:23,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:45:23,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...eSink/trapsourcesink/sink
2016-01-14 22:45:23,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0005
2016-01-14 22:45:23,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0005
2016-01-14 22:45:23,562 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:23,589 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:23,921 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:24,031 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:24,708 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:24,745 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:25,261 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:38,356 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink/_temporary
2016-01-14 22:45:38,357 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/trap/_temporary
2016-01-14 22:45:38,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:15.319
2016-01-14 22:45:38,389 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink
2016-01-14 22:45:38,394 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/trap
2016-01-14 22:45:38,416 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:45:38,417 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:45:38,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 22:45:38,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:45:38,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:45:38,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 22:45:38,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:45:38,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/tap"]
2016-01-14 22:45:38,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2016-01-14 22:45:38,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 1
2016-01-14 22:45:38,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 1
2016-01-14 22:45:38,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/1) ...apFailure/trapFailure/tap
2016-01-14 22:45:38,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114224344920_0006
2016-01-14 22:45:38,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0006
2016-01-14 22:45:39,239 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114224344920_0005 being deleted.
2016-01-14 22:45:39,524 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114224344920_0005 being deleted.
2016-01-14 22:45:39,697 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:39,726 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114224344920_0005 being deleted.
2016-01-14 22:45:40,655 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:41,334 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:45:52,448 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000000_1/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-01-14 22:45:52,793 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000002_1/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-01-14 22:45:52,976 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000003_1/part-m-00000-00003 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00003 because destination exists
2016-01-14 22:45:59,044 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000001_1/part-m-00000-00001 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00001 because destination exists
2016-01-14 22:45:59,429 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000000_2/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-01-14 22:45:59,549 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000002_2/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-01-14 22:46:06,910 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000003_2/part-m-00000-00003 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00003 because destination exists
2016-01-14 22:46:07,134 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000002_3/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-01-14 22:46:07,224 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000000_3/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-01-14 22:46:07,248 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160114224344920_0006_m_000001_2/part-m-00000-00001 to /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00001 because destination exists
2016-01-14 22:46:12,518 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] hadoop job job_20160114224344920_0006 state at FAILED
2016-01-14 22:46:12,519 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] failure info: # of failed Map Tasks exceeded allowed limit. FailedCount: 1. LastFailedTask: task_20160114224344920_0006_m_000000
2016-01-14 22:46:12,519 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] task completion events identify failed tasks
2016-01-14 22:46:12,519 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] task completion events count: 10
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000005_0, Status : SUCCEEDED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000000_0, Status : FAILED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000002_0, Status : FAILED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000003_0, Status : FAILED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000001_0, Status : FAILED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000000_1, Status : FAILED
2016-01-14 22:46:12,520 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000002_1, Status : FAILED
2016-01-14 22:46:12,521 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000003_1, Status : FAILED
2016-01-14 22:46:12,521 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000001_1, Status : FAILED
2016-01-14 22:46:12,521 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_20160114224344920_0006_m_000000_2, Status : FAILED
2016-01-14 22:46:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopping all jobs
2016-01-14 22:46:12,523 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopping: (1/1) ...apFailure/trapFailure/tap
2016-01-14 22:46:12,523 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopped all jobs
2016-01-14 22:46:12,525 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/tap/_temporary
2016-01-14 22:46:12,526 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary
2016-01-14 22:46:12,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 00:34.054
2016-01-14 22:46:12,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/badTrap
2016-01-14 22:46:12,536 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/tap
2016-01-14 22:46:12,538 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/firstTrap
2016-01-14 22:46:12,548 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:46:12,549 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:46:12,600 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 22:46:12,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:46:12,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:46:12,622 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:46:12,622 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:46:12,622 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap"]
2016-01-14 22:46:12,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:46:12,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:46:12,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:46:12,624 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...omplete/everycomplete/tap
2016-01-14 22:46:13,388 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:13,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0007
2016-01-14 22:46:13,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0007
2016-01-14 22:46:14,861 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:35,479 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap/_temporary
2016-01-14 22:46:35,480 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/trap/_temporary
2016-01-14 22:46:35,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:22.856
2016-01-14 22:46:35,517 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap
2016-01-14 22:46:35,524 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/trap
2016-01-14 22:46:35,545 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:46:35,545 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:46:35,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 22:46:35,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:46:35,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:46:35,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:46:35,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:46:35,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic"]
2016-01-14 22:46:35,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:46:35,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:46:35,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:46:35,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...gdef/tap-nondeterministic
2016-01-14 22:46:35,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0008
2016-01-14 22:46:35,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0008
2016-01-14 22:46:36,179 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:36,231 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:36,913 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:37,227 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:37,266 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:37,518 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:38,255 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:58,187 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic/_temporary
2016-01-14 22:46:58,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/trap-nondeterministic/_temporary
2016-01-14 22:46:58,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:22.555
2016-01-14 22:46:58,227 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic
2016-01-14 22:46:58,234 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/trap-nondeterministic
2016-01-14 22:46:58,255 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:46:58,255 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:46:58,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 22:46:58,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:46:58,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:46:58,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:46:58,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:46:58,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic"]
2016-01-14 22:46:58,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:46:58,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:46:58,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:46:58,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...hain/tap-nondeterministic
2016-01-14 22:46:58,826 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0009
2016-01-14 22:46:58,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0009
2016-01-14 22:46:59,531 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:59,572 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:59,587 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:46:59,613 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:00,550 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:00,656 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:00,729 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:01,008 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:01,116 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:01,245 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:09,356 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic/_temporary
2016-01-14 22:47:09,357 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/trap-nondeterministic/_temporary
2016-01-14 22:47:09,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:11.039
2016-01-14 22:47:09,392 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic
2016-01-14 22:47:09,402 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAllChained/allchain/trap-nondeterministic
2016-01-14 22:47:09,421 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:47:09,422 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:47:09,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 22:47:09,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:47:09,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:47:09,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:47:09,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:47:09,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/tap"]
2016-01-14 22:47:09,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:47:09,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:47:09,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:47:09,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...rapToSequenceFile/seq/tap
2016-01-14 22:47:09,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0010
2016-01-14 22:47:09,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0010
2016-01-14 22:47:10,190 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:10,263 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:10,598 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:10,752 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:11,353 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:31,720 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/tap/_temporary
2016-01-14 22:47:31,721 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/trap/_temporary
2016-01-14 22:47:31,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:22.232
2016-01-14 22:47:31,756 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapToSequenceFile/seq/trap
2016-01-14 22:47:31,766 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapToSequenceFile/seq/tap
2016-01-14 22:47:31,798 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:47:31,798 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:47:31,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 22:47:31,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:47:31,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:47:31,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 22:47:31,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextDelimited[['id', 'name' | int, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/delimited-problematic.txt"]
2016-01-14 22:47:31,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextDelimited[['id', 'name' | int, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation"]
2016-01-14 22:47:31,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2016-01-14 22:47:31,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 1
2016-01-14 22:47:31,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 1
2016-01-14 22:47:31,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/1) ...ation/testTrapNoOperation
2016-01-14 22:47:32,246 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:32,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114224344920_0011
2016-01-14 22:47:32,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0011
2016-01-14 22:47:32,861 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:32,947 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:33,060 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:33,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:33,134 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:33,850 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:34,158 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:34,576 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:34,677 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:42,224 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation/_temporary
2016-01-14 22:47:42,225 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation_trap/_temporary
2016-01-14 22:47:42,228 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 00:10.386
2016-01-14 22:47:42,238 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation
2016-01-14 22:47:42,247 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation_trap
2016-01-14 22:47:42,262 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:47:42,263 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:47:42,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 22:47:42,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:47:42,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:47:42,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:47:42,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:47:42,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic"]
2016-01-14 22:47:42,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:47:42,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:47:42,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:47:42,325 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...diag/tap-nondeterministic
2016-01-14 22:47:43,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0012
2016-01-14 22:47:43,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0012
2016-01-14 22:47:43,738 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114224344920_0011 being deleted.
2016-01-14 22:47:43,877 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:44,385 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:44,553 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:44,588 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:47:44,732 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:06,454 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic/_temporary
2016-01-14 22:48:06,455 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/trap-nondeterministic/_temporary
2016-01-14 22:48:06,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:24.130
2016-01-14 22:48:06,488 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic
2016-01-14 22:48:06,495 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapDiagnostics/diag/trap-nondeterministic
2016-01-14 22:48:06,514 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:48:06,515 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:48:06,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 22:48:06,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:48:06,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:48:06,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:48:06,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:48:06,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap"]
2016-01-14 22:48:06,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:48:06,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:48:06,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:48:06,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...AllAtStart/everystart/tap
2016-01-14 22:48:07,426 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:07,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0013
2016-01-14 22:48:07,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0013
2016-01-14 22:48:07,829 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:07,900 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:07,902 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:07,962 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:08,018 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:08,791 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:08,866 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:09,016 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:29,643 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap/_temporary
2016-01-14 22:48:29,644 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/trap/_temporary
2016-01-14 22:48:29,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:23.061
2016-01-14 22:48:29,672 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtStart/everystart/trap
2016-01-14 22:48:29,679 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap
2016-01-14 22:48:29,701 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:48:29,702 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:48:29,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 22:48:29,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:48:29,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:48:29,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:48:29,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:48:29,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapNone/none/tap"]
2016-01-14 22:48:29,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:48:29,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:48:29,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:48:29,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...orm/testTrapNone/none/tap
2016-01-14 22:48:30,053 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:30,374 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:30,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0014
2016-01-14 22:48:30,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0014
2016-01-14 22:48:30,729 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:31,205 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:31,240 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:31,667 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:32,265 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:32,526 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:32,537 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:32,704 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:52,383 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapNone/none/tap/_temporary
2016-01-14 22:48:52,384 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:22.616
2016-01-14 22:48:52,405 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapNone/none/trap
2016-01-14 22:48:52,405 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapNone/none/tap
2016-01-14 22:48:52,424 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:48:52,424 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:48:52,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 22:48:52,466 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:48:52,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:48:52,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting
2016-01-14 22:48:52,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:48:52,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  sink: Hfs["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/tap"]
2016-01-14 22:48:52,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  parallel execution of steps is enabled: true
2016-01-14 22:48:52,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  executing total steps: 1
2016-01-14 22:48:52,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  allocating management threads: 1
2016-01-14 22:48:52,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] starting step: (1/1) ...achAllSequence/allseq/tap
2016-01-14 22:48:53,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] submitted hadoop job: job_20160114224344920_0015
2016-01-14 22:48:53,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test] tracking url: http://localhost:36878/jobdetails.jsp?jobid=job_20160114224344920_0015
2016-01-14 22:48:53,277 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:53,628 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:53,937 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:54,012 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:54,062 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:54,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:54,760 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:55,014 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:55,053 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:48:55,511 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 22:49:14,982 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/tap/_temporary
2016-01-14 22:49:14,984 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/trap/_temporary
2016-01-14 22:49:14,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [trap test]  completed in: 00:22.494
2016-01-14 22:49:15,020 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAllSequence/allseq/trap
2016-01-14 22:49:15,034 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/trapplatform/testTrapEachAllSequence/allseq/tap