2016-05-18 03:30:47,858 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 03:30:47,874 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop
2016-05-18 03:30:47,901 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-05-18 03:30:48,730 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2016-05-18 03:30:49,748 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 03:30:49,751 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-05-18 03:30:50,158 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 03:30:50,159 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 03:30:50,236 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:554)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-05-18 03:30:50,474 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 03:30:50,476 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 03:30:50,557 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:554)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-05-18 03:30:50,762 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-18 03:30:50,763 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 03:30:50,827 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:554)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-05-18 03:30:51,106 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-05-18 03:30:51,108 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:308)
at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:303)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1149)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 03:30:52,070 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 03:30:52,146 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 03:30:52,404 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 03:30:52,596 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 03:30:52,918 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-18 03:30:54,120 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 03:30:54,229 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:30:54,230 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:30:54,310 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 1291BBE726B44CFE9785B13533C098FC
2016-05-18 03:30:54,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.121
2016-05-18 03:30:54,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:30:54,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:30:54,609 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 03:30:54,611 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 03:30:54,611 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:30:54,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:30:54,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-05-18 03:30:54,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 03:30:54,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 03:30:54,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 03:30:54,617 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-18 03:30:54,704 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 03:30:55,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160518033051064_0001
2016-05-18 03:30:55,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0001
2016-05-18 03:31:07,464 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-18 03:31:07,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:12.851
2016-05-18 03:31:07,539 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMerge/simplemerge
2016-05-18 03:31:07,602 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:31:07,603 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:31:07,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.187
2016-05-18 03:31:07,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:31:07,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:31:07,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-18 03:31:07,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:31:07,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:31:07,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:31:07,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-05-18 03:31:07,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-18 03:31:07,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 3
2016-05-18 03:31:07,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 3
2016-05-18 03:31:07,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/3)
2016-05-18 03:31:08,568 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0001 being deleted.
2016-05-18 03:31:08,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160518033051064_0002
2016-05-18 03:31:08,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0002
2016-05-18 03:31:09,194 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:09,299 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:09,677 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:09,808 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:10,021 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:20,714 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/3)
2016-05-18 03:31:21,094 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:21,223 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:21,257 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:21,321 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:21,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160518033051064_0003
2016-05-18 03:31:21,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0003
2016-05-18 03:31:22,570 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0002 being deleted.
2016-05-18 03:31:23,307 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:23,815 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:33,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-05-18 03:31:33,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160518033051064_0004
2016-05-18 03:31:33,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0004
2016-05-18 03:31:34,690 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:35,083 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:35,094 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0003 being deleted.
2016-05-18 03:31:35,359 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:35,458 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:35,466 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:45,530 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-05-18 03:31:45,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 00:37.658
2016-05-18 03:31:45,555 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-05-18 03:31:45,595 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:31:45,597 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:31:45,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-05-18 03:31:45,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:31:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:31:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-18 03:31:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:31:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:31:45,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:31:45,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-05-18 03:31:45,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-18 03:31:45,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 1
2016-05-18 03:31:45,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 1
2016-05-18 03:31:45,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-05-18 03:31:46,393 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0004 being deleted.
2016-05-18 03:31:46,602 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:46,634 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:46,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160518033051064_0005
2016-05-18 03:31:46,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0005
2016-05-18 03:31:47,458 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:47,817 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:48,219 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:48,378 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:57,383 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-05-18 03:31:57,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 00:11.649
2016-05-18 03:31:57,409 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-05-18 03:31:57,441 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:31:57,442 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:31:57,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 03:31:57,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:31:57,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:31:57,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 03:31:57,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:31:57,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:31:57,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:31:57,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-18 03:31:57,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 03:31:57,538 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 03:31:57,538 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 03:31:57,539 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-18 03:31:58,394 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0005 being deleted.
2016-05-18 03:31:58,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160518033051064_0006
2016-05-18 03:31:58,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0006
2016-05-18 03:31:59,134 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:59,457 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:31:59,903 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:00,328 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:00,371 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:14,077 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-18 03:32:14,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:16.541
2016-05-18 03:32:14,115 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-05-18 03:32:14,156 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:32:14,157 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:32:14,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 03:32:14,231 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:32:14,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:32:14,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting
2016-05-18 03:32:14,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:32:14,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:32:14,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:32:14,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-05-18 03:32:14,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2016-05-18 03:32:14,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executing total steps: 1
2016-05-18 03:32:14,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] allocating management threads: 1
2016-05-18 03:32:14,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-05-18 03:32:14,299 WARN namenode.FSNamesystem (ReplicationTargetChooser.java:chooseTarget(184)) - Not able to place enough replicas, still in need of 1
2016-05-18 03:32:14,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] submitted hadoop job: job_20160518033051064_0007
2016-05-18 03:32:14,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0007
2016-05-18 03:32:14,650 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:14,755 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:14,948 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:15,079 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:15,190 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:15,484 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:15,622 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:26,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-05-18 03:32:26,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] completed in: 00:12.378
2016-05-18 03:32:26,648 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-05-18 03:32:26,677 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:32:26,678 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:32:26,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 03:32:26,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:32:26,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:32:26,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 03:32:26,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:32:26,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:32:26,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:32:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-05-18 03:32:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-18 03:32:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-18 03:32:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-18 03:32:26,763 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-05-18 03:32:26,975 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:27,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160518033051064_0008
2016-05-18 03:32:27,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0008
2016-05-18 03:32:27,860 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:28,143 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:28,534 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:28,575 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0007 being deleted.
2016-05-18 03:32:29,800 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:41,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-05-18 03:32:41,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:15.050
2016-05-18 03:32:41,844 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-05-18 03:32:41,878 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:32:41,878 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:32:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-05-18 03:32:41,964 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:32:41,965 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:32:41,990 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-18 03:32:41,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:32:41,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:32:41,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:32:41,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-05-18 03:32:41,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-18 03:32:41,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 2
2016-05-18 03:32:41,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 2
2016-05-18 03:32:41,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/2)
2016-05-18 03:32:42,705 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:42,739 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:42,786 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:42,814 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:43,247 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:43,485 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:43,573 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:43,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160518033051064_0009
2016-05-18 03:32:43,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0009
2016-05-18 03:32:44,205 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:55,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-05-18 03:32:56,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160518033051064_0010
2016-05-18 03:32:56,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0010
2016-05-18 03:32:56,796 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:56,880 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0009 being deleted.
2016-05-18 03:32:57,279 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:57,380 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:57,418 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:57,912 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:32:58,014 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:08,246 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-05-18 03:33:08,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 00:26.254
2016-05-18 03:33:08,263 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-05-18 03:33:08,307 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:33:08,307 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:33:08,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 03:33:08,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:33:08,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:33:08,386 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 03:33:08,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-05-18 03:33:08,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-18 03:33:08,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-18 03:33:08,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-18 03:33:08,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-18 03:33:08,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-18 03:33:08,811 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,040 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,079 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,104 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0010 being deleted.
2016-05-18 03:33:09,364 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,402 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,465 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:09,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_20160518033051064_0011
2016-05-18 03:33:09,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0011
2016-05-18 03:33:20,370 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-18 03:33:20,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:11.984
2016-05-18 03:33:20,386 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-18 03:33:20,408 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:33:20,409 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:33:20,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-18 03:33:20,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:33:20,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:33:20,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 03:33:20,490 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:33:20,491 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:33:20,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:33:20,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-05-18 03:33:20,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-18 03:33:20,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-18 03:33:20,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-18 03:33:20,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-18 03:33:20,922 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:21,714 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:21,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160518033051064_0012
2016-05-18 03:33:21,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0012
2016-05-18 03:33:21,868 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:22,018 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:22,848 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:23,182 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:33,060 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-05-18 03:33:33,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:12.558
2016-05-18 03:33:33,080 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-05-18 03:33:33,103 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:33:33,104 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:33:33,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2016-05-18 03:33:33,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 03:33:33,129 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-05-18 03:33:33,141 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:33:33,142 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:33:33,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 03:33:33,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:33:33,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:33:33,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 03:33:33,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:33:33,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:33:33,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:33:33,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-05-18 03:33:33,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-18 03:33:33,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-18 03:33:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-18 03:33:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-05-18 03:33:33,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160518033051064_0013
2016-05-18 03:33:33,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0013
2016-05-18 03:33:33,450 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:33,632 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:33,773 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:34,584 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0012 being deleted.
2016-05-18 03:33:35,429 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:35,600 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:55,565 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-05-18 03:33:55,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:22.337
2016-05-18 03:33:55,575 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-05-18 03:33:55,591 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:33:55,591 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:33:55,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 03:33:55,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:33:55,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:33:55,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-18 03:33:55,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:33:55,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:33:55,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:33:55,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-05-18 03:33:55,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-18 03:33:55,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 3
2016-05-18 03:33:55,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 3
2016-05-18 03:33:55,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/3)
2016-05-18 03:33:56,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160518033051064_0014
2016-05-18 03:33:56,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0014
2016-05-18 03:33:56,736 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:57,004 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:57,071 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:57,186 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:57,265 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:58,049 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:58,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:58,462 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:33:58,539 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:08,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/3)
2016-05-18 03:34:08,990 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:09,190 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:09,276 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:09,405 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:09,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160518033051064_0015
2016-05-18 03:34:09,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0015
2016-05-18 03:34:10,029 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:10,291 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:10,410 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0014 being deleted.
2016-05-18 03:34:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-05-18 03:34:22,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160518033051064_0016
2016-05-18 03:34:22,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0016
2016-05-18 03:34:22,505 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:22,589 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0015 being deleted.
2016-05-18 03:34:22,593 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:22,645 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:22,901 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:23,668 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:33,828 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-05-18 03:34:33,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 00:38.116
2016-05-18 03:34:33,844 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-05-18 03:34:33,864 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:34:33,864 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:34:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 03:34:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:34:33,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:34:33,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 03:34:33,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:34:33,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:34:33,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:34:33,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-05-18 03:34:33,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-18 03:34:33,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-18 03:34:33,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-18 03:34:33,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-18 03:34:34,590 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0016 being deleted.
2016-05-18 03:34:34,872 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:34,979 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:35,050 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:35,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160518033051064_0017
2016-05-18 03:34:35,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0017
2016-05-18 03:34:35,773 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:36,265 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:36,393 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:46,910 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-05-18 03:34:46,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:12.984
2016-05-18 03:34:46,930 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-05-18 03:34:46,952 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:34:46,953 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:34:47,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-18 03:34:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:34:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:34:47,022 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 03:34:47,023 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:34:47,023 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:34:47,023 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:34:47,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-05-18 03:34:47,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-18 03:34:47,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-18 03:34:47,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-18 03:34:47,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-05-18 03:34:47,085 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:47,292 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:47,804 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:48,244 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:48,591 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0017 being deleted.
2016-05-18 03:34:48,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160518033051064_0018
2016-05-18 03:34:48,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0018
2016-05-18 03:34:48,866 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:34:48,915 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:10,225 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-05-18 03:35:10,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:23.202
2016-05-18 03:35:10,240 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-05-18 03:35:10,260 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:35:10,262 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:35:10,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 03:35:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 03:35:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:35:10,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 03:35:10,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:35:10,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-18 03:35:10,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-18 03:35:10,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 2
2016-05-18 03:35:10,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 2
2016-05-18 03:35:10,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/2)
2016-05-18 03:35:10,701 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,089 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,168 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,171 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,224 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,314 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,525 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,795 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:11,878 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:12,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160518033051064_0019
2016-05-18 03:35:12,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0019
2016-05-18 03:35:30,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-18 03:35:30,420 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0019 being deleted.
2016-05-18 03:35:30,968 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:30,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160518033051064_0020
2016-05-18 03:35:30,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0020
2016-05-18 03:35:31,262 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:31,472 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:31,912 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:32,316 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:32,489 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:51,384 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-18 03:35:51,386 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:40.967
2016-05-18 03:35:51,396 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-18 03:35:51,413 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:35:51,413 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:35:51,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 03:35:51,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:35:51,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:35:51,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-18 03:35:51,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:35:51,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:35:51,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:35:51,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-05-18 03:35:51,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-18 03:35:51,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 3
2016-05-18 03:35:51,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 3
2016-05-18 03:35:51,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/3)
2016-05-18 03:35:52,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160518033051064_0021
2016-05-18 03:35:52,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0021
2016-05-18 03:35:52,920 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0020 being deleted.
2016-05-18 03:35:52,948 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:52,953 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:53,141 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:53,179 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:53,543 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:53,830 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:35:53,851 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:03,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (2/3)
2016-05-18 03:36:04,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160518033051064_0022
2016-05-18 03:36:04,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0022
2016-05-18 03:36:04,625 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:04,788 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:04,921 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0021 being deleted.
2016-05-18 03:36:05,297 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:05,812 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:05,899 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:06,342 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:16,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-05-18 03:36:16,597 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0022 being deleted.
2016-05-18 03:36:16,776 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:17,021 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:17,236 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:17,401 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:17,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160518033051064_0023
2016-05-18 03:36:17,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0023
2016-05-18 03:36:18,204 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:18,630 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:29,302 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-05-18 03:36:29,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 00:37.742
2016-05-18 03:36:29,322 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-05-18 03:36:29,345 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:36:29,346 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:36:29,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 03:36:29,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:36:29,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:36:29,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-18 03:36:29,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:36:29,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:36:29,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:36:29,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-05-18 03:36:29,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-18 03:36:29,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 1
2016-05-18 03:36:29,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 1
2016-05-18 03:36:29,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-05-18 03:36:29,931 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160518033051064_0024
2016-05-18 03:36:29,931 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0024
2016-05-18 03:36:30,342 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:31,142 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0023 being deleted.
2016-05-18 03:36:31,156 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:31,678 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:31,790 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:32,048 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:40,857 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-05-18 03:36:40,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:11.462
2016-05-18 03:36:40,873 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-05-18 03:36:40,893 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:36:40,893 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:36:40,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 03:36:40,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:36:40,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:36:40,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting
2016-05-18 03:36:40,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-05-18 03:36:40,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-05-18 03:36:40,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] parallel execution of steps is enabled: true
2016-05-18 03:36:40,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executing total steps: 1
2016-05-18 03:36:40,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] allocating management threads: 1
2016-05-18 03:36:40,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-05-18 03:36:41,143 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0024 being deleted.
2016-05-18 03:36:42,739 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:43,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] submitted hadoop job: job_20160518033051064_0025
2016-05-18 03:36:43,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0025
2016-05-18 03:36:43,380 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:43,440 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:43,529 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:43,748 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:43,815 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:53,663 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-05-18 03:36:53,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] completed in: 00:12.719
2016-05-18 03:36:53,679 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-05-18 03:36:53,698 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:36:53,698 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:36:53,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 03:36:53,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:36:53,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:36:53,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-18 03:36:53,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:36:53,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:36:53,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:36:53,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-05-18 03:36:53,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-18 03:36:53,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 2
2016-05-18 03:36:53,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 2
2016-05-18 03:36:53,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/2)
2016-05-18 03:36:54,701 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160518033051064_0026
2016-05-18 03:36:54,701 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0026
2016-05-18 03:36:54,722 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:55,190 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:55,210 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:56,330 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:56,402 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:36:56,491 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:05,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-05-18 03:37:06,756 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:06,836 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:06,926 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0026 being deleted.
2016-05-18 03:37:06,939 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160518033051064_0027
2016-05-18 03:37:06,939 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0027
2016-05-18 03:37:06,951 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:06,968 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:07,628 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:08,606 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:16,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-05-18 03:37:16,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:22.983
2016-05-18 03:37:16,787 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-05-18 03:37:16,808 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:37:16,808 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:37:16,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 03:37:16,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:37:16,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:37:16,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting
2016-05-18 03:37:16,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:37:16,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:37:16,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:37:16,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-05-18 03:37:16,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2016-05-18 03:37:16,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executing total steps: 3
2016-05-18 03:37:16,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] allocating management threads: 3
2016-05-18 03:37:16,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (1/3)
2016-05-18 03:37:16,927 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0027 being deleted.
2016-05-18 03:37:17,286 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:17,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160518033051064_0028
2016-05-18 03:37:17,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0028
2016-05-18 03:37:18,804 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:19,275 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:19,674 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:19,859 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:29,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (2/3)
2016-05-18 03:37:30,066 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160518033051064_0029
2016-05-18 03:37:30,066 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0029
2016-05-18 03:37:30,504 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:30,796 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:31,107 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:31,148 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0028 being deleted.
2016-05-18 03:37:31,570 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:31,630 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:32,221 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:41,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-05-18 03:37:42,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160518033051064_0030
2016-05-18 03:37:42,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0030
2016-05-18 03:37:42,665 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:42,678 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:42,841 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:43,148 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0029 being deleted.
2016-05-18 03:37:43,844 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:43,905 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:44,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:54,051 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-05-18 03:37:54,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] completed in: 00:37.128
2016-05-18 03:37:54,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-05-18 03:37:54,087 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:37:54,087 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:37:54,146 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 03:37:54,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 03:37:54,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:37:54,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 03:37:54,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:37:54,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:37:54,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testGroupByAggregationMerge"]
2016-05-18 03:37:54,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 03:37:54,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 3
2016-05-18 03:37:54,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 3
2016-05-18 03:37:54,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/3)
2016-05-18 03:37:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (2/3)
2016-05-18 03:37:54,439 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0030 being deleted.
2016-05-18 03:37:54,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160518033051064_0032
2016-05-18 03:37:54,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0032
2016-05-18 03:37:54,973 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:54,990 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:55,061 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:55,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160518033051064_0031
2016-05-18 03:37:55,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0031
2016-05-18 03:37:55,999 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:56,367 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:37:56,378 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:01,182 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:18,444 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0032 being deleted.
2016-05-18 03:38:18,929 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:18,959 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:20,046 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:20,145 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:20,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (3/3) ...stGroupByAggregationMerge
2016-05-18 03:38:20,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160518033051064_0033
2016-05-18 03:38:20,728 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:20,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0033
2016-05-18 03:38:20,933 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0031 being deleted.
2016-05-18 03:38:21,156 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:21,421 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:21,699 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:23,024 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:29,291 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testGroupByAggregationMerge/_temporary
2016-05-18 03:38:29,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:35.095
2016-05-18 03:38:29,328 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:38:29,329 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 03:38:29,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 03:38:29,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:38:29,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 03:38:29,410 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-18 03:38:29,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-05-18 03:38:29,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-05-18 03:38:29,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:38:29,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-05-18 03:38:29,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-18 03:38:29,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 2
2016-05-18 03:38:29,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 2
2016-05-18 03:38:29,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/2)
2016-05-18 03:38:30,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160518033051064_0034
2016-05-18 03:38:30,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0034
2016-05-18 03:38:30,445 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0033 being deleted.
2016-05-18 03:38:30,608 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0033 being deleted.
2016-05-18 03:38:31,630 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:32,053 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:32,278 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:32,281 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:41,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-05-18 03:38:42,609 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160518033051064_0034 being deleted.
2016-05-18 03:38:42,692 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:43,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160518033051064_0035
2016-05-18 03:38:43,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:33998/jobdetails.jsp?jobid=job_20160518033051064_0035
2016-05-18 03:38:43,312 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:43,634 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:43,763 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:43,784 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:44,640 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-05-18 03:38:53,103 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-05-18 03:38:53,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 00:23.691
2016-05-18 03:38:53,120 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge