Class cascading.TrapPlatformTest

14

tests

0

failures

0

ignored

9m21.46s

duration

100%

successful

Tests

Test Duration Result
testTrapDiagnostics 33.193s passed
testTrapDiagnosticsLocalConfig 39.058s passed
testTrapEachAll 39.444s passed
testTrapEachAllChained 27.429s passed
testTrapEachAllSequence 36.748s passed
testTrapEachEveryAllChained 1m29.24s passed
testTrapEveryAllAtAggregate 39.039s passed
testTrapEveryAllAtComplete 36.339s passed
testTrapEveryAllAtStart 36.711s passed
testTrapFailure 51.005s passed
testTrapNoOperation 26.184s passed
testTrapNone 38.335s passed
testTrapTapSourceSink 32.042s passed
testTrapToSequenceFile 36.692s passed

Standard output

2016-05-18 00:14:15,420 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 00:14:15,437 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.TrapPlatformTest, with platform: hadoop
2016-05-18 00:14:15,463 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-05-18 00:14:16,291 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-05-18 00:14:17,238 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 00:14:17,239 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:500)
	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:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-05-18 00:14:20,785 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 00:14:20,785 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:500)
	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:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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-05-18 00:14:20,860 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:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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-05-18 00:14:21,082 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 00:14:21,082 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:500)
	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:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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-05-18 00:14:21,163 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:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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-05-18 00:14:21,375 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 00:14:21,376 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:500)
	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:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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-05-18 00:14:21,436 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:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	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:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	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)
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-05-18 00:14:21,698 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-05-18 00:14:21,700 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:500)
	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:296)
	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:1121)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:745)
2016-05-18 00:14:22,682 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 00:14:22,722 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 00:14:22,933 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 00:14:23,166 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 00:14:23,362 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 00:14:26,547 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 00:14:26,632 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:14:26,633 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:14:26,707 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: FDBD081588EF4871B8AFDD9C94F3E384
2016-05-18 00:14:26,900 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.155
2016-05-18 00:14:26,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 00:14:26,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:14:27,080 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 00:14:27,081 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:14:27,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:14:27,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap"]
2016-05-18 00:14:27,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:14:27,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 2
2016-05-18 00:14:27,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 2
2016-05-18 00:14:27,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/2)
2016-05-18 00:14:27,143 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 00:14:27,365 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0001
2016-05-18 00:14:27,366 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0001
2016-05-18 00:15:05,038 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (2/2) ...hained/eacheverychain/tap
2016-05-18 00:15:05,239 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:05,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0002
2016-05-18 00:15:05,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0002
2016-05-18 00:15:05,625 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,201 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,249 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,318 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,719 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,805 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,912 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:06,923 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:44,632 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap/_temporary
2016-05-18 00:15:44,635 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap/_temporary
2016-05-18 00:15:44,636 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap/_temporary
2016-05-18 00:15:44,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 01:17.546
2016-05-18 00:15:44,683 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/trap
2016-05-18 00:15:44,692 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachEveryAllChained/eacheverychain/tap
2016-05-18 00:15:44,718 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:15:44,718 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:15:44,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-18 00:15:44,785 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:15:44,785 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:15:44,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:15:44,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:15:44,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap"]
2016-05-18 00:15:44,818 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:15:44,819 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:15:44,819 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:15:44,819 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...regate/everyaggregate/tap
2016-05-18 00:15:44,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0003
2016-05-18 00:15:44,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0003
2016-05-18 00:15:45,032 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:45,775 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:45,818 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:47,213 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:48,060 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:48,244 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:48,279 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:48,417 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:15:48,594 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:23,683 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap/_temporary
2016-05-18 00:16:23,687 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/trap/_temporary
2016-05-18 00:16:23,690 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:38.865
2016-05-18 00:16:23,723 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/tap
2016-05-18 00:16:23,730 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtAggregate/everyaggregate/trap
2016-05-18 00:16:23,754 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:16:23,754 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:16:23,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 00:16:23,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:16:23,818 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:16:23,840 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:16:23,840 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:16:23,841 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/tap"]
2016-05-18 00:16:23,841 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:16:23,841 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:16:23,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:16:23,843 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...m/testTrapEachAll/all/tap
2016-05-18 00:16:24,038 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:24,339 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0004
2016-05-18 00:16:24,340 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0004
2016-05-18 00:16:24,682 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:24,753 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:26,201 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:26,474 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:26,709 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:27,452 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:16:27,459 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:03,136 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/tap/_temporary
2016-05-18 00:17:03,137 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAll/all/trap/_temporary
2016-05-18 00:17:03,142 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:39.290
2016-05-18 00:17:03,170 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAll/all/tap
2016-05-18 00:17:03,177 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAll/all/trap
2016-05-18 00:17:03,196 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:17:03,197 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:17:03,252 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 00:17:03,253 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:17:03,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:17:03,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:17:03,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["HadoopFailScheme[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:17:03,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["HadoopFailScheme[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink"]
2016-05-18 00:17:03,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:17:03,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:17:03,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:17:03,276 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...eSink/trapsourcesink/sink
2016-05-18 00:17:03,569 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:03,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0005
2016-05-18 00:17:03,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0005
2016-05-18 00:17:04,018 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:04,511 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:05,276 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:05,471 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:05,721 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:06,067 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:06,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:06,342 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:06,372 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:35,159 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink/_temporary
2016-05-18 00:17:35,160 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/trap/_temporary
2016-05-18 00:17:35,162 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:31.883
2016-05-18 00:17:35,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/sink
2016-05-18 00:17:35,221 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapTapSourceSink/trapsourcesink/trap
2016-05-18 00:17:35,238 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:17:35,239 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:17:35,280 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 00:17:35,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:17:35,282 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:17:35,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 00:17:35,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:17:35,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/tap"]
2016-05-18 00:17:35,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 00:17:35,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 1
2016-05-18 00:17:35,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 1
2016-05-18 00:17:35,303 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/1) ...apFailure/trapFailure/tap
2016-05-18 00:17:35,305 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160518001421655_0005 being deleted.
2016-05-18 00:17:35,456 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160518001421655_0005 being deleted.
2016-05-18 00:17:35,560 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:35,590 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_20160518001421655_0006
2016-05-18 00:17:35,804 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0006
2016-05-18 00:17:36,139 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160518001421655_0005 being deleted.
2016-05-18 00:17:36,357 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:17:56,193 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000000_1/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-05-18 00:17:56,591 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000001_1/part-m-00000-00001 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00001 because destination exists
2016-05-18 00:17:57,136 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000002_1/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-05-18 00:17:58,314 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000003_1/part-m-00000-00003 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00003 because destination exists
2016-05-18 00:18:04,893 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000003_2/part-m-00000-00003 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00003 because destination exists
2016-05-18 00:18:05,386 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000000_2/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-05-18 00:18:06,189 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000001_2/part-m-00000-00001 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00001 because destination exists
2016-05-18 00:18:07,196 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000002_2/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-05-18 00:18:14,313 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000002_3/part-m-00000-00002 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00002 because destination exists
2016-05-18 00:18:14,710 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000003_3/part-m-00000-00003 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00003 because destination exists
2016-05-18 00:18:15,229 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000000_3/part-m-00000-00000 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00000 because destination exists
2016-05-18 00:18:16,448 WARN  hdfs.StateChange (FSDirectory.java:unprotectedRenameTo(416)) - DIR* FSDirectory.unprotectedRenameTo: failed to rename /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary/_attempt_20160518001421655_0006_m_000001_3/part-m-00000-00001 to /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/part-m-00000-00001 because destination exists
2016-05-18 00:18:26,209 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] hadoop job job_20160518001421655_0006 state at FAILED
2016-05-18 00:18:26,209 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] failure info: # of failed Map Tasks exceeded allowed limit. FailedCount: 1. LastFailedTask: task_20160518001421655_0006_m_000001
2016-05-18 00:18:26,210 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] task completion events identify failed tasks
2016-05-18 00:18:26,210 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] task completion events count: 10
2016-05-18 00:18:26,210 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000005_0, Status : SUCCEEDED
2016-05-18 00:18:26,210 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000000_0, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000001_0, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000002_0, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000003_0, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000003_1, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000000_1, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000001_1, Status : FAILED
2016-05-18 00:18:26,211 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000002_1, Status : FAILED
2016-05-18 00:18:26,212 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [] event = Task Id : attempt_20160518001421655_0006_m_000003_2, Status : FAILED
2016-05-18 00:18:26,213 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] stopping all jobs
2016-05-18 00:18:26,213 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] stopping: (1/1) ...apFailure/trapFailure/tap
2016-05-18 00:18:26,214 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] stopped all jobs
2016-05-18 00:18:26,216 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/tap/_temporary
2016-05-18 00:18:26,217 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapFailure/trapFailure/badTrap/_temporary
2016-05-18 00:18:26,222 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:50.919
2016-05-18 00:18:26,222 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/firstTrap
2016-05-18 00:18:26,224 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/badTrap
2016-05-18 00:18:26,231 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapFailure/trapFailure/tap
2016-05-18 00:18:26,243 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:18:26,244 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:18:26,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 00:18:26,298 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:18:26,298 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:18:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:18:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:18:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap"]
2016-05-18 00:18:26,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:18:26,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:18:26,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:18:26,319 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...omplete/everycomplete/tap
2016-05-18 00:18:26,423 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0007
2016-05-18 00:18:26,423 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0007
2016-05-18 00:18:26,653 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:18:26,690 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:02,528 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap/_temporary
2016-05-18 00:19:02,530 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/trap/_temporary
2016-05-18 00:19:02,533 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:36.211
2016-05-18 00:19:02,559 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/tap
2016-05-18 00:19:02,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtComplete/everycomplete/trap
2016-05-18 00:19:02,591 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:19:02,592 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:19:02,603 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:02,649 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 00:19:02,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:19:02,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:19:02,677 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:19:02,677 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:19:02,677 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic"]
2016-05-18 00:19:02,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:19:02,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:19:02,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:19:02,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...gdef/tap-nondeterministic
2016-05-18 00:19:02,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0008
2016-05-18 00:19:02,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0008
2016-05-18 00:19:02,891 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:02,895 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:03,776 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:03,814 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:03,918 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:05,424 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:05,497 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:06,917 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:41,569 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic/_temporary
2016-05-18 00:19:41,571 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/trap-nondeterministic/_temporary
2016-05-18 00:19:41,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:38.890
2016-05-18 00:19:41,612 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/trap-nondeterministic
2016-05-18 00:19:41,624 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapDiagnosticsLocalConfig/diagconfigdef/tap-nondeterministic
2016-05-18 00:19:41,642 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:19:41,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:19:41,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 00:19:41,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:19:41,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:19:41,712 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:19:41,713 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:19:41,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic"]
2016-05-18 00:19:41,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:19:41,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:19:41,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:19:41,716 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...hain/tap-nondeterministic
2016-05-18 00:19:41,790 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:42,047 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:42,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0009
2016-05-18 00:19:42,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0009
2016-05-18 00:19:42,308 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:42,652 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:43,372 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:44,393 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:44,769 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:44,863 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:45,061 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:19:45,674 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:09,004 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic/_temporary
2016-05-18 00:20:09,005 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllChained/allchain/trap-nondeterministic/_temporary
2016-05-18 00:20:09,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:27.289
2016-05-18 00:20:09,040 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAllChained/allchain/tap-nondeterministic
2016-05-18 00:20:09,050 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAllChained/allchain/trap-nondeterministic
2016-05-18 00:20:09,070 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:20:09,070 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:20:09,121 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 00:20:09,122 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:20:09,122 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:20:09,143 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:20:09,143 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:20:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/tap"]
2016-05-18 00:20:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:20:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:20:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:20:09,146 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...rapToSequenceFile/seq/tap
2016-05-18 00:20:09,247 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:09,267 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0010
2016-05-18 00:20:09,267 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0010
2016-05-18 00:20:10,358 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:10,400 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:11,425 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:11,545 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:45,702 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/tap/_temporary
2016-05-18 00:20:45,703 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapToSequenceFile/seq/trap/_temporary
2016-05-18 00:20:45,707 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:36.557
2016-05-18 00:20:45,735 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapToSequenceFile/seq/trap
2016-05-18 00:20:45,745 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapToSequenceFile/seq/tap
2016-05-18 00:20:45,777 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:20:45,777 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:20:45,804 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 00:20:45,805 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:20:45,805 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:20:45,815 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 00:20:45,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextDelimited[['id', 'name' | int, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/delimited-problematic.txt"]
2016-05-18 00:20:45,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextDelimited[['id', 'name' | int, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation"]
2016-05-18 00:20:45,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 00:20:45,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 1
2016-05-18 00:20:45,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 1
2016-05-18 00:20:45,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/1) ...ation/testTrapNoOperation
2016-05-18 00:20:46,300 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_20160518001421655_0011
2016-05-18 00:20:46,300 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0011
2016-05-18 00:20:46,557 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:47,081 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:47,184 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:47,442 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:47,498 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:47,692 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:48,480 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:48,666 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:48,832 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:20:49,065 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:11,870 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation/_temporary
2016-05-18 00:21:11,871 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation_trap/_temporary
2016-05-18 00:21:11,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:26.054
2016-05-18 00:21:11,924 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation
2016-05-18 00:21:11,932 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapNoOperation/testTrapNoOperation_trap
2016-05-18 00:21:11,947 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:21:11,947 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:21:11,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 00:21:11,992 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:21:11,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:21:12,012 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:21:12,013 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:21:12,013 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic"]
2016-05-18 00:21:12,013 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:21:12,013 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:21:12,014 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:21:12,014 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...diag/tap-nondeterministic
2016-05-18 00:21:12,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0012
2016-05-18 00:21:12,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0012
2016-05-18 00:21:12,545 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:12,711 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160518001421655_0011 being deleted.
2016-05-18 00:21:13,123 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:13,390 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:14,953 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:15,608 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:45,078 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic/_temporary
2016-05-18 00:21:45,080 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapDiagnostics/diag/trap-nondeterministic/_temporary
2016-05-18 00:21:45,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:33.063
2016-05-18 00:21:45,114 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapDiagnostics/diag/tap-nondeterministic
2016-05-18 00:21:45,120 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapDiagnostics/diag/trap-nondeterministic
2016-05-18 00:21:45,139 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:21:45,139 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:21:45,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 00:21:45,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:21:45,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:21:45,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:21:45,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:21:45,202 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap"]
2016-05-18 00:21:45,202 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:21:45,202 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:21:45,202 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:21:45,203 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...AllAtStart/everystart/tap
2016-05-18 00:21:45,407 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:45,483 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:46,069 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:46,095 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0013
2016-05-18 00:21:46,095 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0013
2016-05-18 00:21:46,165 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:46,202 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:46,476 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:48,042 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:48,280 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:48,392 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:21:49,222 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:21,782 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap/_temporary
2016-05-18 00:22:21,784 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEveryAllAtStart/everystart/trap/_temporary
2016-05-18 00:22:21,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:36.579
2016-05-18 00:22:21,828 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtStart/everystart/tap
2016-05-18 00:22:21,834 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEveryAllAtStart/everystart/trap
2016-05-18 00:22:21,858 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:22:21,858 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:22:21,903 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 00:22:21,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:22:21,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:22:21,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:22:21,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:22:21,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapNone/none/tap"]
2016-05-18 00:22:21,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:22:21,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:22:21,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:22:21,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...orm/testTrapNone/none/tap
2016-05-18 00:22:22,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0014
2016-05-18 00:22:22,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0014
2016-05-18 00:22:22,103 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:22,168 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:22,363 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:23,501 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:24,241 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:24,366 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:24,595 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:24,658 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:22:24,694 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:00,138 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapNone/none/tap/_temporary
2016-05-18 00:23:00,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:38.217
2016-05-18 00:23:00,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapNone/none/trap
2016-05-18 00:23:00,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapNone/none/tap
2016-05-18 00:23:00,185 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:23:00,186 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 00:23:00,227 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 00:23:00,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:23:00,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:23:00,245 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting
2016-05-18 00:23:00,245 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-05-18 00:23:00,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  sink: Hfs["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/tap"]
2016-05-18 00:23:00,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  parallel execution of steps is enabled: true
2016-05-18 00:23:00,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  executing total steps: 1
2016-05-18 00:23:00,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  allocating management threads: 1
2016-05-18 00:23:00,247 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] starting step: (1/1) ...achAllSequence/allseq/tap
2016-05-18 00:23:00,491 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:00,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] submitted hadoop job: job_20160518001421655_0015
2016-05-18 00:23:00,734 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test] tracking url: http://localhost:50442/jobdetails.jsp?jobid=job_20160518001421655_0015
2016-05-18 00:23:00,889 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:00,889 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:01,134 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:01,403 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:02,532 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:03,294 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:03,372 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:03,570 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:03,668 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-18 00:23:36,841 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/tap/_temporary
2016-05-18 00:23:36,881 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output/hadoop/trapplatform/testTrapEachAllSequence/allseq/trap/_temporary
2016-05-18 00:23:36,883 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [trap test]  completed in: 00:36.596
2016-05-18 00:23:36,909 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAllSequence/allseq/tap
2016-05-18 00:23:36,915 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.0.x/build/test/output//hadoop/trapplatform/testTrapEachAllSequence/allseq/trap