2016-05-17 23:34:45,628 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 23:34:45,639 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.tap.hadoop.HadoopTapPlatformTest, with platform: hadoop
2016-05-17 23:34:45,664 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-05-17 23:34:46,321 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-17 23:34:47,071 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 23:34:47,072 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:1483)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,234 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 23:34:52,236 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:1483)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,313 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:500)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,517 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 23:34:52,518 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:1483)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,608 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:500)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,850 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 23:34:52,851 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:1483)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:52,912 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:500)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
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-17 23:34:53,173 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-05-17 23:34:53,175 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:1059)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
at java.lang.Thread.run(Thread.java:745)
2016-05-17 23:34:54,181 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 23:34:54,227 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 23:34:54,514 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 23:34:54,779 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 23:34:54,971 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 23:34:55,209 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 23:34:55,299 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:34:55,300 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-17 23:34:55,383 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 8D1F063A468E499DB86E2846F70EC3DF
2016-05-17 23:34:55,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-05-17 23:34:55,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:34:55,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:34:55,632 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 23:34:55,633 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:34:55,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["CommentScheme[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/comments+lower.txt"]
2016-05-17 23:34:55,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNullsFromScheme/testnulls"]
2016-05-17 23:34:55,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:34:55,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:34:55,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:34:55,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...NullsFromScheme/testnulls
2016-05-17 23:34:55,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0001
2016-05-17 23:34:55,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0001
2016-05-17 23:35:15,575 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNullsFromScheme/testnulls/_temporary
2016-05-17 23:35:15,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.939
2016-05-17 23:35:15,664 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testNullsFromScheme/testnulls
2016-05-17 23:35:15,750 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:35:15,751 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-17 23:35:15,774 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0001 being deleted.
2016-05-17 23:35:15,864 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.104
2016-05-17 23:35:15,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:35:15,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:35:15,873 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testMissingInputFormat/missinginputformat
2016-05-17 23:35:15,981 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0001 being deleted.
2016-05-17 23:35:16,017 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 23:35:16,049 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:16,078 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 23:35:16,115 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 23:35:16,134 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 23:35:16,152 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:35:16,153 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-17 23:35:16,170 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0001 being deleted.
2016-05-17 23:35:16,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-17 23:35:16,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:35:16,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:35:16,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:35:16,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 23:35:16,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["ResolvedScheme[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testResolvedSinkFields/resolvedfields"]
2016-05-17 23:35:16,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:35:16,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:35:16,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:35:16,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...SinkFields/resolvedfields
2016-05-17 23:35:16,562 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:16,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0002
2016-05-17 23:35:16,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0002
2016-05-17 23:35:43,426 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0002 being deleted.
2016-05-17 23:35:43,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testResolvedSinkFields/resolvedfields/_temporary
2016-05-17 23:35:43,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:27.213
2016-05-17 23:35:43,468 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testResolvedSinkFields/resolvedfields
2016-05-17 23:35:43,516 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:35:43,517 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-17 23:35:43,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 23:35:43,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:35:43,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:35:43,570 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 23:35:43,592 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:35:43,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-17 23:35:43,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 23:35:43,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:35:43,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:35:43,676 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting
2016-05-17 23:35:43,679 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] parallel execution of flows is enabled: true
2016-05-17 23:35:43,679 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] executing total flows: 2
2016-05-17 23:35:43,680 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] allocating management threads: 2
2016-05-17 23:35:43,680 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: first
2016-05-17 23:35:43,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 23:35:43,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 23:35:43,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 23:35:43,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] source: GlobHfs[/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/?{ppe[_r],owe?}.txt]
2016-05-17 23:35:43,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob"]
2016-05-17 23:35:43,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] parallel execution of steps is enabled: true
2016-05-17 23:35:43,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executing total steps: 1
2016-05-17 23:35:43,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] allocating management threads: 1
2016-05-17 23:35:43,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...platform/testGlobHfs/glob
2016-05-17 23:35:43,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_local_0001
2016-05-17 23:35:43,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://localhost:8080/
2016-05-17 23:35:43,759 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 23:35:43,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:35:43,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx512m
2016-05-17 23:35:43,789 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, ordinal: 0
2016-05-17 23:35:43,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: GlobHfs[/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/?{ppe[_r],owe?}.txt]
2016-05-17 23:35:43,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob"]
2016-05-17 23:35:43,823 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, mem on start (mb), free: 179, total: 397, max: 672
2016-05-17 23:35:43,827 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, mem on close (mb), free: 179, total: 397, max: 672
2016-05-17 23:35:44,152 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:44,839 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:46,010 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:46,757 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-05-17 23:35:46,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:35:46,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx512m
2016-05-17 23:35:46,768 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:46,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, ordinal: 0
2016-05-17 23:35:46,780 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: GlobHfs[/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/?{ppe[_r],owe?}.txt]
2016-05-17 23:35:46,780 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob"]
2016-05-17 23:35:46,781 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, mem on start (mb), free: 171, total: 397, max: 672
2016-05-17 23:35:46,782 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC315FF49AFA4163A2AE8A5611BA3814, mem on close (mb), free: 171, total: 397, max: 672
2016-05-17 23:35:47,292 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:47,307 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:35:49,769 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob/_temporary
2016-05-17 23:35:49,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] completed in: 00:06.077
2016-05-17 23:35:49,770 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: first
2016-05-17 23:35:49,771 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: second
2016-05-17 23:35:49,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] at least one sink is marked for delete
2016-05-17 23:35:49,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 23:35:49,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 23:35:49,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob"]
2016-05-17 23:35:49,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob2"]
2016-05-17 23:35:49,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] parallel execution of steps is enabled: true
2016-05-17 23:35:49,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executing total steps: 1
2016-05-17 23:35:49,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] allocating management threads: 1
2016-05-17 23:35:49,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...latform/testGlobHfs/glob2
2016-05-17 23:35:49,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_20160517233453131_0003
2016-05-17 23:35:49,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0003
2016-05-17 23:36:16,485 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testGlobHfs/glob2/_temporary
2016-05-17 23:36:16,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] completed in: 00:26.708
2016-05-17 23:36:16,486 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: second
2016-05-17 23:36:16,501 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testGlobHfs/glob
2016-05-17 23:36:16,509 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testGlobHfs/glob2
2016-05-17 23:36:16,530 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:36:16,530 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-17 23:36:16,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-17 23:36:16,591 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:36:16,591 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:36:16,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:36:16,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 23:36:16,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testPrepareResource/preparetap"]
2016-05-17 23:36:16,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:36:16,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:36:16,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:36:16,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...repareResource/preparetap
2016-05-17 23:36:16,787 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:17,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0004
2016-05-17 23:36:17,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0004
2016-05-17 23:36:17,257 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:18,762 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:19,149 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:19,601 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:20,576 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:54,673 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testPrepareResource/preparetap/_temporary
2016-05-17 23:36:54,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:38.045
2016-05-17 23:36:54,686 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testPrepareResource/preparetap
2016-05-17 23:36:54,892 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:55,115 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:36:55,116 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-17 23:36:55,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-17 23:36:55,148 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:55,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:36:55,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:36:55,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:36:55,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextDelimited[['a', 'b']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:36:55,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: PartitionTap["Hfs["TextDelimited[['a']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testTemporarySinkPathIsDeleted/partition-tap-sink"]"]["cascading.tap.partition.DelimitedPartition@66e9ffc2"]["[]"]
2016-05-17 23:36:55,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:36:55,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:36:55,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:36:55,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...eleted/partition-tap-sink
2016-05-17 23:36:55,291 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:55,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0005
2016-05-17 23:36:55,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0005
2016-05-17 23:36:55,372 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:56,259 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:36:56,504 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:16,542 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testTemporarySinkPathIsDeleted/partition-tap-sink/_temporary
2016-05-17 23:37:16,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:21.370
2016-05-17 23:37:16,546 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testTemporarySinkPathIsDeleted/partition-tap-sink
2016-05-17 23:37:16,571 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:37:16,571 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-17 23:37:16,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-17 23:37:16,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:37:16,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:37:16,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-17 23:37:16,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["DupeConfigScheme[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 23:37:16,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 23:37:16,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testDupeConfigFromScheme/dupeconfig"]
2016-05-17 23:37:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-17 23:37:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-17 23:37:16,650 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-17 23:37:16,651 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...nfigFromScheme/dupeconfig
2016-05-17 23:37:17,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_20160517233453131_0006
2016-05-17 23:37:17,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0006
2016-05-17 23:37:17,286 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:17,788 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:18,845 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0005 being deleted.
2016-05-17 23:37:19,041 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:19,890 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:20,802 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:42,881 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testDupeConfigFromScheme/dupeconfig/_temporary
2016-05-17 23:37:42,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.235
2016-05-17 23:37:42,918 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testDupeConfigFromScheme/dupeconfig
2016-05-17 23:37:42,972 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:37:42,972 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-17 23:37:43,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 23:37:43,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:37:43,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:37:43,034 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:37:43,035 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-17 23:37:43,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 23:37:43,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:37:43,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:37:43,100 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting
2016-05-17 23:37:43,102 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] parallel execution of flows is enabled: true
2016-05-17 23:37:43,102 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] executing total flows: 2
2016-05-17 23:37:43,102 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] allocating management threads: 2
2016-05-17 23:37:43,103 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: first
2016-05-17 23:37:43,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 23:37:43,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 23:37:43,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 23:37:43,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] source: MultiSourceTap[2:[GlobHfs[/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/?{ppe[_r]}.txt], GlobHfs[/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/?{owe?}.txt]]]
2016-05-17 23:37:43,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource"]
2016-05-17 23:37:43,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] parallel execution of steps is enabled: true
2016-05-17 23:37:43,109 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executing total steps: 1
2016-05-17 23:37:43,109 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] allocating management threads: 1
2016-05-17 23:37:43,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...ceGlobHfs/globmultisource
2016-05-17 23:37:43,546 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0006 being deleted.
2016-05-17 23:37:43,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_20160517233453131_0007
2016-05-17 23:37:43,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0007
2016-05-17 23:37:43,906 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:44,419 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:45,015 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:45,841 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:37:45,990 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:10,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource/_temporary
2016-05-17 23:38:10,143 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] completed in: 00:27.033
2016-05-17 23:38:10,143 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: first
2016-05-17 23:38:10,145 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: second
2016-05-17 23:38:10,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] at least one sink is marked for delete
2016-05-17 23:38:10,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 23:38:10,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 23:38:10,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource"]
2016-05-17 23:38:10,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2"]
2016-05-17 23:38:10,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] parallel execution of steps is enabled: true
2016-05-17 23:38:10,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executing total steps: 1
2016-05-17 23:38:10,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] allocating management threads: 1
2016-05-17 23:38:10,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...ceGlobHfs/globmultiource2
2016-05-17 23:38:10,558 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517233453131_0007 being deleted.
2016-05-17 23:38:10,562 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:10,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_20160517233453131_0008
2016-05-17 23:38:10,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0008
2016-05-17 23:38:10,874 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:10,980 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:11,162 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:11,484 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:11,670 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:40,561 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2/_temporary
2016-05-17 23:38:40,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] completed in: 00:30.410
2016-05-17 23:38:40,563 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: second
2016-05-17 23:38:40,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2
2016-05-17 23:38:40,600 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource
2016-05-17 23:38:40,645 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:38:40,645 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-17 23:38:40,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 23:38:40,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:38:40,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:38:40,714 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:38:40,715 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 23:38:40,715 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail"]
2016-05-17 23:38:40,715 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:38:40,715 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:38:40,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:38:40,717 ERROR flow.Flow (BaseFlow.java:logError(1540)) - [test] unable to prepare tap for write: hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:777)
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:773)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:614)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:596)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:582)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:221)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:180)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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-17 23:38:40,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping all jobs
2016-05-17 23:38:40,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping: (1/1) ...Fails/preparewritetapfail
2016-05-17 23:38:40,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopped all jobs
2016-05-17 23:38:40,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.004
2016-05-17 23:38:40,720 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail
2016-05-17 23:38:40,730 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:38:40,730 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-17 23:38:40,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-17 23:38:40,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:38:40,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:38:40,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:38:40,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 23:38:40,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testPrepareResourceForReadFails/preparereadtapfail"]
2016-05-17 23:38:40,804 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:40,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:38:40,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:38:40,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:38:40,806 ERROR flow.Flow (BaseFlow.java:logError(1540)) - [test] unable to prepare tap for read: hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:729)
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:725)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:616)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:596)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:579)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:221)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:180)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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-17 23:38:40,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping all jobs
2016-05-17 23:38:40,810 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping: (1/1) ...dFails/preparereadtapfail
2016-05-17 23:38:40,810 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopped all jobs
2016-05-17 23:38:40,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.008
2016-05-17 23:38:40,811 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testPrepareResourceForReadFails/preparereadtapfail
2016-05-17 23:38:40,825 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:38:40,825 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-17 23:38:40,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 23:38:40,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:38:40,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:38:40,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:38:40,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 23:38:40,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testCommitResourceFails/committapfail"]
2016-05-17 23:38:40,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:38:40,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:38:40,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:38:40,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...sourceFails/committapfail
2016-05-17 23:38:41,137 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:41,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0009
2016-05-17 23:38:41,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0009
2016-05-17 23:38:41,782 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:43,303 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:43,748 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:43,843 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:38:44,213 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:13,211 ERROR flow.Flow (BaseFlow.java:logError(1540)) - [test] unable to commit sink: hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testCommitResourceFails/committapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:403)
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:399)
at cascading.flow.planner.BaseFlowStep.commitResource(BaseFlowStep.java:660)
at cascading.flow.planner.BaseFlowStep.commitSinks(BaseFlowStep.java:648)
at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:301)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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-17 23:39:13,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping all jobs
2016-05-17 23:39:13,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping: (1/1) ...sourceFails/committapfail
2016-05-17 23:39:13,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopped all jobs
2016-05-17 23:39:13,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testCommitResourceFails/committapfail/_temporary
2016-05-17 23:39:13,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:32.326
2016-05-17 23:39:13,222 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testCommitResourceFails/committapfail
2016-05-17 23:39:13,241 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:39:13,242 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-17 23:39:13,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-17 23:39:13,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:39:13,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:39:13,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 23:39:13,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 23:39:13,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testCommitResource/committap"]
2016-05-17 23:39:13,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 23:39:13,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 23:39:13,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 23:39:13,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tCommitResource/committap
2016-05-17 23:39:13,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_20160517233453131_0010
2016-05-17 23:39:13,425 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:60230/jobdetails.jsp?jobid=job_20160517233453131_0010
2016-05-17 23:39:13,607 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:13,822 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:14,043 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:14,449 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:14,457 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:46,257 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testCommitResource/committap/_temporary
2016-05-17 23:39:46,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:32.938
2016-05-17 23:39:46,271 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testCommitResource/committap
2016-05-17 23:39:46,298 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,298 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 23:39:46,309 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A/part-00000
2016-05-17 23:39:46,317 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A
2016-05-17 23:39:46,324 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary
2016-05-17 23:39:46,330 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,330 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 23:39:46,335 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B/part-00000
2016-05-17 23:39:46,586 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:46,745 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,751 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B
2016-05-17 23:39:46,752 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary
2016-05-17 23:39:46,780 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:46,783 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,784 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 23:39:46,796 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/part-00000
2016-05-17 23:39:46,804 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,811 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A
2016-05-17 23:39:46,811 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary
2016-05-17 23:39:46,817 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,817 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 23:39:46,823 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/part-00000
2016-05-17 23:39:46,833 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,838 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B
2016-05-17 23:39:46,839 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary
2016-05-17 23:39:46,844 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,845 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 23:39:46,854 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/part-00000
2016-05-17 23:39:46,866 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2016-05-17 23:39:46,882 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 23:39:46,883 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden
2016-05-17 23:39:46,883 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:53273/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary
2016-05-17 23:39:46,897 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/A
2016-05-17 23:39:46,902 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/multifiles/A
2016-05-17 23:39:46,906 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/multifiles/B
2016-05-17 23:39:46,910 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/B
2016-05-17 23:39:46,913 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles
2016-05-17 23:39:46,921 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden
2016-05-17 23:39:46,925 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/hadooptapplatform/testChildIdentifiers/multifiles