2015-08-13 23:58:35,032 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 23:58:35,080 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 23:58:35,080 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-08-13 23:58:35,118 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-13 23:58:36,213 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2015-08-13 23:58:37,342 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:58:37,343 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:58:37,496 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2015-08-13 23:58:37,880 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:58:37,881 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:58:37,959 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2015-08-13 23:58:38,292 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:58:38,293 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:58:38,376 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2015-08-13 23:58:38,696 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:58:38,697 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1650)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:58:38,779 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:581)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2015-08-13 23:58:39,173 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2015-08-13 23:58:39,174 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:518)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:316)
at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:311)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:58:40,206 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:58:40,536 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:58:40,830 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:58:41,124 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:58:42,490 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 23:58:42,608 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:58:42,610 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 23:58:42,621 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 257B3316A85543569D47EBBB04BAC2EB
2015-08-13 23:58:42,805 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 23:58:42,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-13 23:58:42,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-13 23:58:42,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-13 23:58:42,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemerge"]
2015-08-13 23:58:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-13 23:58:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-13 23:58:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-13 23:58:42,810 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-13 23:58:42,912 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 23:58:43,220 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813235839115_0001
2015-08-13 23:58:43,221 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0001
2015-08-13 23:58:51,642 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemerge/_temporary
2015-08-13 23:58:51,741 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemerge
2015-08-13 23:58:51,819 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:58:51,820 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 23:58:51,975 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-13 23:58:51,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-13 23:58:51,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-13 23:58:51,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 23:58:51,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-08-13 23:58:51,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-08-13 23:58:51,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-08-13 23:58:51,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-08-13 23:58:51,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-13 23:58:52,170 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0002
2015-08-13 23:58:52,170 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0002
2015-08-13 23:58:52,444 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:52,803 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0001 being deleted.
2015-08-13 23:58:53,603 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:53,696 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:53,825 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:53,939 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:54,674 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:58:59,588 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-13 23:59:00,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0003
2015-08-13 23:59:00,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0003
2015-08-13 23:59:00,622 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:00,643 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:00,655 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:00,804 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0002 being deleted.
2015-08-13 23:59:01,617 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:02,023 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:02,403 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:08,054 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-13 23:59:08,612 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:09,060 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0004
2015-08-13 23:59:09,060 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:09,060 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0004
2015-08-13 23:59:09,235 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:09,280 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:09,482 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0003 being deleted.
2015-08-13 23:59:10,259 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:10,329 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:16,257 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-08-13 23:59:16,287 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-08-13 23:59:16,329 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:59:16,330 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 23:59:16,456 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-13 23:59:16,457 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-13 23:59:16,457 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-13 23:59:16,457 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 23:59:16,457 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-08-13 23:59:16,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-08-13 23:59:16,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-08-13 23:59:16,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-08-13 23:59:16,461 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-13 23:59:16,699 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:16,802 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:16,806 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0004 being deleted.
2015-08-13 23:59:17,026 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0005
2015-08-13 23:59:17,027 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0005
2015-08-13 23:59:17,318 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:17,643 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:18,930 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:24,740 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-13 23:59:24,807 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0005 being deleted.
2015-08-13 23:59:25,300 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0006
2015-08-13 23:59:25,300 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0006
2015-08-13 23:59:25,362 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:25,393 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:25,527 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:25,671 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:27,317 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:27,487 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:34,803 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-13 23:59:35,028 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:35,130 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:35,300 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:35,451 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:35,560 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:35,749 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0007
2015-08-13 23:59:35,749 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0007
2015-08-13 23:59:36,347 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:37,144 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:37,782 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:45,896 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-08-13 23:59:45,932 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-08-13 23:59:45,978 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:59:45,979 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 23:59:46,003 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-13 23:59:46,003 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethree"]
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-13 23:59:46,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-13 23:59:46,006 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-13 23:59:46,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813235839115_0008
2015-08-13 23:59:46,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0008
2015-08-13 23:59:47,403 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,497 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,522 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,590 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,621 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,854 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:47,932 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:48,401 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:56,187 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethree/_temporary
2015-08-13 23:59:56,222 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemergethree
2015-08-13 23:59:56,268 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:59:56,268 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 23:59:56,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-08-13 23:59:56,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-13 23:59:56,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-13 23:59:56,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 23:59:56,326 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-08-13 23:59:56,326 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] parallel execution is enabled: true
2015-08-13 23:59:56,327 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting jobs: 2
2015-08-13 23:59:56,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] allocating threads: 2
2015-08-13 23:59:56,331 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-08-13 23:59:56,782 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,039 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,266 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813235839115_0009
2015-08-13 23:59:57,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0009
2015-08-13 23:59:57,502 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,530 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,562 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:57,583 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:59:58,879 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:05,378 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-08-14 00:00:05,661 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:06,050 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:06,325 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813235839115_0010
2015-08-14 00:00:06,325 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0010
2015-08-14 00:00:06,497 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0009 being deleted.
2015-08-14 00:00:06,765 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:07,104 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:07,693 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:07,916 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:14,208 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-08-14 00:00:14,235 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-08-14 00:00:14,273 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:00:14,274 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:00:14,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 00:00:14,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:00:14,300 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:00:14,300 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:00:14,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechain"]
2015-08-14 00:00:14,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 00:00:14,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-08-14 00:00:14,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-08-14 00:00:14,303 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-08-14 00:00:14,498 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0010 being deleted.
2015-08-14 00:00:14,949 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:15,263 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813235839115_0011
2015-08-14 00:00:15,264 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0011
2015-08-14 00:00:15,626 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:16,111 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:16,612 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:16,822 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:16,924 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:24,492 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechain/_temporary
2015-08-14 00:00:24,526 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechain
2015-08-14 00:00:24,572 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:00:24,572 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:00:24,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-14 00:00:24,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:00:24,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:00:24,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:00:24,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-08-14 00:00:24,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-08-14 00:00:24,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-08-14 00:00:24,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-08-14 00:00:24,640 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-14 00:00:24,678 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:24,784 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:25,099 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:25,154 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:25,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0012
2015-08-14 00:00:25,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0012
2015-08-14 00:00:25,673 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:25,790 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:25,866 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:26,488 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:32,987 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-14 00:00:33,105 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0012 being deleted.
2015-08-14 00:00:33,520 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0013
2015-08-14 00:00:33,520 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0013
2015-08-14 00:00:34,013 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:34,080 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:34,251 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:34,826 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:35,043 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:35,669 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:41,760 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-14 00:00:42,679 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:42,697 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0014
2015-08-14 00:00:42,698 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0014
2015-08-14 00:00:43,017 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:43,055 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:43,106 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0013 being deleted.
2015-08-14 00:00:44,080 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:44,226 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:44,303 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:51,118 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-08-14 00:00:51,146 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-08-14 00:00:51,168 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:51,199 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:00:51,199 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:00:51,219 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 00:00:51,219 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-08-14 00:00:51,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/splitsourcemerged"]
2015-08-14 00:00:51,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 00:00:51,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-08-14 00:00:51,221 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-08-14 00:00:51,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-08-14 00:00:52,502 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0014 being deleted.
2015-08-14 00:00:52,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813235839115_0015
2015-08-14 00:00:52,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0015
2015-08-14 00:00:52,634 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:52,638 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:52,717 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:53,862 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:00:54,012 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:01,046 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/splitsourcemerged/_temporary
2015-08-14 00:01:01,071 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/splitsourcemerged
2015-08-14 00:01:01,102 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:01:01,104 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:01:01,147 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 00:01:01,147 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:01:01,147 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:01:01,147 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:01:01,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-08-14 00:01:01,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 00:01:01,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 2
2015-08-14 00:01:01,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 2
2015-08-14 00:01:01,151 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-08-14 00:01:01,906 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:01,970 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:02,327 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:02,737 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:02,895 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813235839115_0016
2015-08-14 00:01:02,896 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0016
2015-08-14 00:01:03,606 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:03,660 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:11,446 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-08-14 00:01:11,744 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:11,959 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:12,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813235839115_0017
2015-08-14 00:01:12,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0017
2015-08-14 00:01:12,504 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0016 being deleted.
2015-08-14 00:01:13,354 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:14,059 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:14,343 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:14,706 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:20,259 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-08-14 00:01:20,285 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-08-14 00:01:20,317 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:01:20,318 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:01:20,325 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemergefail
2015-08-14 00:01:20,342 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:01:20,342 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:01:20,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 00:01:20,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:01:20,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:01:20,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:01:20,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup"]
2015-08-14 00:01:20,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 00:01:20,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-08-14 00:01:20,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-08-14 00:01:20,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-08-14 00:01:20,505 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0017 being deleted.
2015-08-14 00:01:21,184 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:21,204 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:21,269 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:21,296 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:21,317 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813235839115_0018
2015-08-14 00:01:21,317 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0018
2015-08-14 00:01:21,617 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:22,613 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:38,809 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-08-14 00:01:38,864 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechaingroup
2015-08-14 00:01:38,887 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:01:38,887 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:01:38,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-14 00:01:38,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-08-14 00:01:38,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-08-14 00:01:38,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-14 00:01:39,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0019
2015-08-14 00:01:39,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0019
2015-08-14 00:01:39,590 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:39,717 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:39,818 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:40,418 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:40,938 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:41,012 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:41,317 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:41,508 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:41,632 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:47,354 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-14 00:01:48,672 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:48,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0020
2015-08-14 00:01:48,703 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0020
2015-08-14 00:01:48,949 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:48,987 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:49,113 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0019 being deleted.
2015-08-14 00:01:50,083 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:50,127 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:50,814 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:56,177 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-08-14 00:01:56,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813235839115_0021
2015-08-14 00:01:56,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0021
2015-08-14 00:01:56,510 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0020 being deleted.
2015-08-14 00:01:56,648 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:58,397 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:58,504 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:01:58,727 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:04,738 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-08-14 00:02:04,761 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-08-14 00:02:04,790 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:02:04,790 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:02:04,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 00:02:04,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:02:04,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:02:04,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:02:04,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed"]
2015-08-14 00:02:04,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 00:02:04,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-08-14 00:02:04,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-08-14 00:02:04,813 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-08-14 00:02:05,390 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:05,511 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0021 being deleted.
2015-08-14 00:02:06,302 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:06,568 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813235839115_0022
2015-08-14 00:02:06,568 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0022
2015-08-14 00:02:06,928 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:07,487 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:07,750 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:07,915 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:14,731 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-08-14 00:02:14,756 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinstreamed
2015-08-14 00:02:14,789 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:02:14,790 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:02:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 00:02:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:02:14,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:02:14,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:02:14,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup"]
2015-08-14 00:02:14,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 00:02:14,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-08-14 00:02:14,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-08-14 00:02:14,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-08-14 00:02:14,979 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:15,119 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0022 being deleted.
2015-08-14 00:02:15,306 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:15,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813235839115_0023
2015-08-14 00:02:15,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0023
2015-08-14 00:02:16,772 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:16,883 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:16,884 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:16,995 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:32,695 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-08-14 00:02:32,710 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechaincogroup
2015-08-14 00:02:32,735 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:02:32,736 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:02:32,762 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 00:02:32,762 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:02:32,763 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup"]
2015-08-14 00:02:32,763 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 00:02:32,764 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 2
2015-08-14 00:02:32,764 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 2
2015-08-14 00:02:32,766 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-08-14 00:02:33,575 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:33,662 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:33,672 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:33,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813235839115_0024
2015-08-14 00:02:33,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0024
2015-08-14 00:02:33,924 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:33,954 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:34,135 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:34,264 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:34,992 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:35,254 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:48,714 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-14 00:02:49,209 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:49,327 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:49,656 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813235839115_0025
2015-08-14 00:02:49,657 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0025
2015-08-14 00:02:50,146 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:50,243 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:50,351 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:50,446 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:02:50,517 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0024 being deleted.
2015-08-14 00:03:06,062 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup/_temporary
2015-08-14 00:03:06,077 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/samemergethreechaingroup
2015-08-14 00:03:06,101 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:03:06,101 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:03:06,165 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-14 00:03:06,165 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:03:06,165 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:03:06,165 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:03:06,166 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-08-14 00:03:06,166 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-08-14 00:03:06,166 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-08-14 00:03:06,166 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-08-14 00:03:06,167 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-14 00:03:06,518 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0025 being deleted.
2015-08-14 00:03:07,111 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0026
2015-08-14 00:03:07,111 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0026
2015-08-14 00:03:07,133 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:07,189 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:07,744 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:07,774 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:07,952 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:08,464 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:08,617 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:14,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-14 00:03:15,000 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0027
2015-08-14 00:03:15,000 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0027
2015-08-14 00:03:15,485 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:15,595 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:15,627 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:15,757 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:15,849 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:16,834 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0026 being deleted.
2015-08-14 00:03:17,607 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:23,355 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-14 00:03:23,887 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813235839115_0028
2015-08-14 00:03:23,887 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0028
2015-08-14 00:03:24,101 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:25,129 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0027 being deleted.
2015-08-14 00:03:25,149 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:25,218 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:25,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:25,630 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:25,666 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:31,832 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-08-14 00:03:31,858 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-08-14 00:03:31,888 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:03:31,889 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:03:31,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-14 00:03:31,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:03:31,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:03:31,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:03:31,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-08-14 00:03:31,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-08-14 00:03:31,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-08-14 00:03:31,917 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-08-14 00:03:31,918 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-14 00:03:32,521 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0028 being deleted.
2015-08-14 00:03:33,229 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:33,254 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813235839115_0029
2015-08-14 00:03:33,254 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0029
2015-08-14 00:03:33,466 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:33,700 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:34,084 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:34,169 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:34,439 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:41,408 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-14 00:03:41,729 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:42,522 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0029 being deleted.
2015-08-14 00:03:42,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813235839115_0030
2015-08-14 00:03:42,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0030
2015-08-14 00:03:42,974 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:43,086 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:43,368 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:43,375 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:43,396 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:49,883 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-08-14 00:03:49,905 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinaccumulated
2015-08-14 00:03:49,934 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:03:49,934 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:03:49,958 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 00:03:49,958 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2015-08-14 00:03:49,958 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex"]
2015-08-14 00:03:49,959 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 00:03:49,959 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-08-14 00:03:49,959 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-08-14 00:03:49,960 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-08-14 00:03:50,566 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:50,683 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:50,838 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0030 being deleted.
2015-08-14 00:03:50,892 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813235839115_0031
2015-08-14 00:03:50,892 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0031
2015-08-14 00:03:51,307 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:51,347 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:52,654 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:03:59,468 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-08-14 00:03:59,490 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/splitsourcemergedcomplex
2015-08-14 00:03:59,518 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:03:59,519 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:03:59,556 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-14 00:03:59,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:03:59,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:03:59,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:03:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-08-14 00:03:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-08-14 00:03:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-08-14 00:03:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-08-14 00:03:59,561 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-14 00:03:59,804 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:00,513 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813235839115_0032
2015-08-14 00:04:00,513 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0032
2015-08-14 00:04:00,567 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:01,031 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:01,064 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:01,068 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:02,467 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:08,569 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-14 00:04:08,696 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813235839115_0033
2015-08-14 00:04:08,697 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0033
2015-08-14 00:04:08,992 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:09,134 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0032 being deleted.
2015-08-14 00:04:09,833 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:10,103 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:10,699 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:10,979 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:11,067 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:17,444 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-08-14 00:04:17,467 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-08-14 00:04:17,496 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:04:17,497 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:04:17,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-08-14 00:04:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:04:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:04:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:04:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-08-14 00:04:17,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] parallel execution is enabled: true
2015-08-14 00:04:17,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting jobs: 3
2015-08-14 00:04:17,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] allocating threads: 3
2015-08-14 00:04:17,555 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-08-14 00:04:17,698 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:18,493 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813235839115_0034
2015-08-14 00:04:18,493 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0034
2015-08-14 00:04:18,617 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:19,135 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0033 being deleted.
2015-08-14 00:04:19,995 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:20,015 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:20,026 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:20,212 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:25,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-08-14 00:04:26,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813235839115_0035
2015-08-14 00:04:26,485 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0035
2015-08-14 00:04:26,722 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:26,852 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:27,026 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:27,135 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0034 being deleted.
2015-08-14 00:04:27,352 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:28,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:28,448 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:34,126 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-14 00:04:34,824 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:35,053 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:35,533 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0035 being deleted.
2015-08-14 00:04:35,873 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813235839115_0036
2015-08-14 00:04:35,873 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0036
2015-08-14 00:04:36,216 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:36,242 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:36,276 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:42,904 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-08-14 00:04:42,932 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-08-14 00:04:42,964 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:04:42,965 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:04:43,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-14 00:04:43,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/upper.txt"]
2015-08-14 00:04:43,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower.txt"]
2015-08-14 00:04:43,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 00:04:43,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-08-14 00:04:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-08-14 00:04:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-08-14 00:04:43,028 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-08-14 00:04:43,029 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-14 00:04:43,180 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0037
2015-08-14 00:04:43,180 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0037
2015-08-14 00:04:43,850 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:44,844 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0036 being deleted.
2015-08-14 00:04:44,911 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:45,511 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:45,766 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:45,784 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:51,130 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-14 00:04:51,238 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:51,353 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:51,683 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0038
2015-08-14 00:04:51,683 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0038
2015-08-14 00:04:51,720 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:52,529 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150813235839115_0037 being deleted.
2015-08-14 00:04:52,968 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:53,419 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:04:53,506 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:00,705 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-14 00:05:01,244 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:01,287 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:01,365 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:01,646 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813235839115_0039
2015-08-14 00:05:01,646 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:47345/jobdetails.jsp?jobid=job_20150813235839115_0039
2015-08-14 00:05:01,749 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:01,934 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:02,102 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:03,210 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:03,297 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:05:10,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-08-14 00:05:10,447 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge