2016-01-14 21:39:24,864 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 21:39:24,880 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop
2016-01-14 21:39:24,908 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-01-14 21:39:25,736 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2016-01-14 21:39:26,744 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 21:39:26,746 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-01-14 21:39:31,987 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 21:39:31,989 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:39:32,070 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-01-14 21:39:32,295 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 21:39:32,300 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:39:32,380 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-01-14 21:39:32,597 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 21:39:32,599 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:39:32,662 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:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-01-14 21:39:32,946 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-01-14 21:39:32,947 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-01-14 21:39:33,901 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 21:39:33,973 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 21:39:34,226 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 21:39:34,435 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 21:39:34,633 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 21:39:35,852 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 21:39:36,368 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:39:36,370 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:39:36,443 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: A31044D25A964E11B5DDE7340402F09A
2016-01-14 21:39:36,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.118
2016-01-14 21:39:36,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:39:36,604 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:39:36,727 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 21:39:36,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 21:39:36,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:39:36,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:39:36,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-01-14 21:39:36,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-14 21:39:36,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-14 21:39:36,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-14 21:39:36,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-14 21:39:37,224 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 21:39:37,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_20160114213932895_0001
2016-01-14 21:39:37,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0001
2016-01-14 21:39:48,513 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-01-14 21:39:48,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:11.783
2016-01-14 21:39:48,639 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMerge/simplemerge
2016-01-14 21:39:49,029 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:39:49,108 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:39:49,110 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:39:49,233 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:39:49,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.215
2016-01-14 21:39:49,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 21:39:49,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:39:49,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-14 21:39:49,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:39:49,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:39:49,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:39:49,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-01-14 21:39:49,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2016-01-14 21:39:49,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 3
2016-01-14 21:39:49,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 3
2016-01-14 21:39:49,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/3)
2016-01-14 21:39:49,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_20160114213932895_0002
2016-01-14 21:39:49,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0002
2016-01-14 21:39:50,217 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0001 being deleted.
2016-01-14 21:39:50,963 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:39:51,170 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:39:52,100 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:00,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/3)
2016-01-14 21:40:01,009 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_20160114213932895_0003
2016-01-14 21:40:01,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0003
2016-01-14 21:40:01,337 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:02,395 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0002 being deleted.
2016-01-14 21:40:03,035 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:03,264 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:03,360 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:12,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-01-14 21:40:12,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_20160114213932895_0004
2016-01-14 21:40:12,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0004
2016-01-14 21:40:12,842 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:12,910 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:13,014 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:13,078 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:14,396 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0003 being deleted.
2016-01-14 21:40:14,702 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:22,722 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-01-14 21:40:22,723 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 00:33.298
2016-01-14 21:40:22,741 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-01-14 21:40:22,768 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:40:22,769 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:40:22,836 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0004 being deleted.
2016-01-14 21:40:22,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-14 21:40:22,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:40:22,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:40:22,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-14 21:40:22,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:40:22,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:40:22,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:40:22,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-01-14 21:40:22,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2016-01-14 21:40:22,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 1
2016-01-14 21:40:22,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 1
2016-01-14 21:40:22,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-01-14 21:40:23,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_20160114213932895_0005
2016-01-14 21:40:23,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0005
2016-01-14 21:40:24,714 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:24,737 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:24,854 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:25,950 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:35,413 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-01-14 21:40:35,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 00:12.535
2016-01-14 21:40:35,433 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-01-14 21:40:35,460 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:40:35,461 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:40:35,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 21:40:35,520 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:40:35,520 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:40:35,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 21:40:35,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:40:35,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:40:35,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:40:35,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-14 21:40:35,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-14 21:40:35,550 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-14 21:40:35,550 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-14 21:40:35,551 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-14 21:40:36,398 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0005 being deleted.
2016-01-14 21:40:36,866 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:37,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_20160114213932895_0006
2016-01-14 21:40:37,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0006
2016-01-14 21:40:37,392 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:37,476 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:37,514 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:38,016 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:38,456 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:52,639 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-01-14 21:40:52,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:17.090
2016-01-14 21:40:52,671 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-01-14 21:40:52,710 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:40:52,710 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:40:52,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 21:40:52,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:40:52,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:40:52,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting
2016-01-14 21:40:52,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:40:52,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:40:52,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:40:52,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-01-14 21:40:52,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2016-01-14 21:40:52,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executing total steps: 1
2016-01-14 21:40:52,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] allocating management threads: 1
2016-01-14 21:40:52,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-01-14 21:40:52,825 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:53,052 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:53,713 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:53,724 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] submitted hadoop job: job_20160114213932895_0007
2016-01-14 21:40:53,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0007
2016-01-14 21:40:54,150 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:54,323 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:54,637 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:54,711 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:40:55,146 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:05,541 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-01-14 21:41:05,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] completed in: 00:12.728
2016-01-14 21:41:05,560 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-01-14 21:41:05,585 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:41:05,586 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:41:05,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2016-01-14 21:41:05,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:41:05,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:41:05,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 21:41:05,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:41:05,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:41:05,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:41:05,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-01-14 21:41:05,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-14 21:41:05,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2016-01-14 21:41:05,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2016-01-14 21:41:05,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-01-14 21:41:06,555 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:06,662 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0007 being deleted.
2016-01-14 21:41:07,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_20160114213932895_0008
2016-01-14 21:41:07,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0008
2016-01-14 21:41:07,337 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:07,396 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:07,521 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:07,668 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:07,757 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:21,782 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-01-14 21:41:21,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:16.092
2016-01-14 21:41:21,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-01-14 21:41:21,840 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:41:21,840 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:41:21,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 21:41:21,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 21:41:21,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:41:21,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-14 21:41:21,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:41:21,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:41:21,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:41:21,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-01-14 21:41:21,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-01-14 21:41:21,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 2
2016-01-14 21:41:21,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 2
2016-01-14 21:41:21,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/2)
2016-01-14 21:41:22,467 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:22,738 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:22,793 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:22,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_20160114213932895_0009
2016-01-14 21:41:22,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0009
2016-01-14 21:41:23,008 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:23,641 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:24,040 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:24,164 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:24,275 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:33,513 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-01-14 21:41:34,651 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:34,665 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0009 being deleted.
2016-01-14 21:41:34,696 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:34,795 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:34,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_20160114213932895_0010
2016-01-14 21:41:34,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0010
2016-01-14 21:41:35,579 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:35,795 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:46,061 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-01-14 21:41:46,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 00:24.112
2016-01-14 21:41:46,078 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-01-14 21:41:46,424 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0010 being deleted.
2016-01-14 21:41:46,510 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:41:46,511 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:41:46,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 21:41:46,572 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:41:46,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:41:46,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 21:41:46,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:41:46,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-14 21:41:46,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] parallel execution of steps is enabled: true
2016-01-14 21:41:46,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executing total steps: 1
2016-01-14 21:41:46,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] allocating management threads: 1
2016-01-14 21:41:46,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-14 21:41:46,641 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,366 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,566 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,681 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,691 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,699 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:47,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_20160114213932895_0011
2016-01-14 21:41:47,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0011
2016-01-14 21:41:58,531 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-01-14 21:41:58,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] completed in: 00:11.944
2016-01-14 21:41:58,549 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-14 21:41:58,571 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:41:58,572 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:41:58,656 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-14 21:41:58,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:41:58,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:41:58,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 21:41:58,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:41:58,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:41:58,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:41:58,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-01-14 21:41:58,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-14 21:41:58,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-14 21:41:58,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-14 21:41:58,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-14 21:41:59,039 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:41:59,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_20160114213932895_0012
2016-01-14 21:41:59,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0012
2016-01-14 21:41:59,987 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:01,149 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:01,236 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:01,400 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:10,952 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-01-14 21:42:10,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:12.268
2016-01-14 21:42:10,999 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-01-14 21:42:11,023 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:42:11,024 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:42:11,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-14 21:42:11,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 21:42:11,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-01-14 21:42:11,055 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:42:11,055 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:42:11,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-01-14 21:42:11,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:42:11,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:42:11,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 21:42:11,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:42:11,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:42:11,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:42:11,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-01-14 21:42:11,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-14 21:42:11,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2016-01-14 21:42:11,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2016-01-14 21:42:11,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-01-14 21:42:12,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_20160114213932895_0013
2016-01-14 21:42:12,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0013
2016-01-14 21:42:12,289 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:12,545 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:12,848 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0012 being deleted.
2016-01-14 21:42:12,984 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:13,027 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:13,336 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:13,391 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:34,933 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-01-14 21:42:34,935 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:23.794
2016-01-14 21:42:34,945 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-01-14 21:42:34,960 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:42:34,960 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:42:35,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-14 21:42:35,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 21:42:35,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:42:35,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-14 21:42:35,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:42:35,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:42:35,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:42:35,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-01-14 21:42:35,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-01-14 21:42:35,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 3
2016-01-14 21:42:35,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 3
2016-01-14 21:42:35,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/3)
2016-01-14 21:42:35,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_20160114213932895_0014
2016-01-14 21:42:35,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0014
2016-01-14 21:42:36,295 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:36,722 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:36,756 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:36,805 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:37,757 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:37,999 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:38,340 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:38,522 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:46,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/3)
2016-01-14 21:42:46,852 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0014 being deleted.
2016-01-14 21:42:47,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_20160114213932895_0015
2016-01-14 21:42:47,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0015
2016-01-14 21:42:48,351 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:48,806 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:48,830 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:49,272 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:49,597 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:58,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-01-14 21:42:58,771 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:58,812 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:58,853 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0015 being deleted.
2016-01-14 21:42:58,961 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:42:59,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_20160114213932895_0016
2016-01-14 21:42:59,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0016
2016-01-14 21:43:00,183 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:01,850 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:10,314 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-01-14 21:43:10,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 00:35.235
2016-01-14 21:43:10,330 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-01-14 21:43:10,349 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:43:10,350 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:43:10,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 21:43:10,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:43:10,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:43:10,407 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 21:43:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:43:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:43:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:43:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-01-14 21:43:10,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-14 21:43:10,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-14 21:43:10,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-14 21:43:10,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-14 21:43:11,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_20160114213932895_0017
2016-01-14 21:43:11,310 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0017
2016-01-14 21:43:11,622 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:11,636 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:11,942 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:12,008 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:12,419 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:12,437 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0016 being deleted.
2016-01-14 21:43:13,491 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:22,276 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-01-14 21:43:22,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:11.868
2016-01-14 21:43:22,294 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-01-14 21:43:22,316 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:43:22,316 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:43:22,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 21:43:22,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:43:22,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:43:22,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 21:43:22,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:43:22,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:43:22,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:43:22,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-01-14 21:43:22,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-14 21:43:22,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-14 21:43:22,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-14 21:43:22,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-01-14 21:43:22,826 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:23,034 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:23,059 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:23,170 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:23,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_20160114213932895_0018
2016-01-14 21:43:23,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0018
2016-01-14 21:43:24,241 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0017 being deleted.
2016-01-14 21:43:24,434 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:25,652 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:46,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-01-14 21:43:46,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:23.757
2016-01-14 21:43:46,155 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-01-14 21:43:46,168 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:43:46,168 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:43:46,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-14 21:43:46,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 21:43:46,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:43:46,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 21:43:46,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:43:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-14 21:43:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-14 21:43:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 2
2016-01-14 21:43:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 2
2016-01-14 21:43:46,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/2)
2016-01-14 21:43:46,586 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:46,713 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:46,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_20160114213932895_0019
2016-01-14 21:43:46,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0019
2016-01-14 21:43:47,248 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,305 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,322 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,402 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,456 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,677 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:43:47,701 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:05,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-01-14 21:44:06,244 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0019 being deleted.
2016-01-14 21:44:06,736 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:07,144 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:07,191 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:07,296 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:07,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_20160114213932895_0020
2016-01-14 21:44:07,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0020
2016-01-14 21:44:07,487 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:08,078 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:26,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-01-14 21:44:26,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:40.388
2016-01-14 21:44:26,684 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-14 21:44:26,701 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:44:26,702 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:44:26,807 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.101
2016-01-14 21:44:26,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 21:44:26,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:44:26,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-14 21:44:26,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:44:26,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:44:26,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:44:26,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-01-14 21:44:26,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2016-01-14 21:44:26,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 3
2016-01-14 21:44:26,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 3
2016-01-14 21:44:26,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/3)
2016-01-14 21:44:27,328 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:27,344 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:27,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_20160114213932895_0021
2016-01-14 21:44:27,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0021
2016-01-14 21:44:28,444 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0020 being deleted.
2016-01-14 21:44:28,691 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:29,124 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:29,150 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:29,568 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:29,579 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:39,373 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (2/3)
2016-01-14 21:44:40,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_20160114213932895_0022
2016-01-14 21:44:40,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0022
2016-01-14 21:44:40,693 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0021 being deleted.
2016-01-14 21:44:40,697 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:40,697 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:40,770 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:40,933 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:41,476 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:42,265 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:51,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-01-14 21:44:52,426 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:52,695 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0022 being deleted.
2016-01-14 21:44:52,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_20160114213932895_0023
2016-01-14 21:44:52,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0023
2016-01-14 21:44:52,823 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:53,095 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:53,735 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:53,840 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:44:54,376 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:03,722 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-01-14 21:45:03,723 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 00:36.879
2016-01-14 21:45:03,746 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-01-14 21:45:03,776 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:45:03,777 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:45:03,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-14 21:45:03,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:45:03,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:45:03,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-14 21:45:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:45:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:45:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:45:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-01-14 21:45:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2016-01-14 21:45:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 1
2016-01-14 21:45:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 1
2016-01-14 21:45:03,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-01-14 21:45:03,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_20160114213932895_0024
2016-01-14 21:45:03,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0024
2016-01-14 21:45:04,451 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0023 being deleted.
2016-01-14 21:45:04,476 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:04,683 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:04,792 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:05,171 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:05,618 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:06,061 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:15,195 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-01-14 21:45:15,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 00:11.344
2016-01-14 21:45:15,211 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-01-14 21:45:15,247 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:45:15,248 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:45:15,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 21:45:15,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:45:15,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:45:15,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting
2016-01-14 21:45:15,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:45:15,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-01-14 21:45:15,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] parallel execution of steps is enabled: true
2016-01-14 21:45:15,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executing total steps: 1
2016-01-14 21:45:15,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] allocating management threads: 1
2016-01-14 21:45:15,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-01-14 21:45:16,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] submitted hadoop job: job_20160114213932895_0025
2016-01-14 21:45:16,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0025
2016-01-14 21:45:16,452 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0024 being deleted.
2016-01-14 21:45:16,557 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:16,903 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:17,594 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:17,806 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:18,084 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:18,277 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:26,970 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-01-14 21:45:26,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] completed in: 00:11.666
2016-01-14 21:45:26,986 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-01-14 21:45:27,006 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:45:27,007 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:45:27,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 21:45:27,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 21:45:27,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:45:27,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-14 21:45:27,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:45:27,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:45:27,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:45:27,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-01-14 21:45:27,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2016-01-14 21:45:27,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 2
2016-01-14 21:45:27,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 2
2016-01-14 21:45:27,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/2)
2016-01-14 21:45:28,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_20160114213932895_0026
2016-01-14 21:45:28,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0026
2016-01-14 21:45:28,660 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:29,307 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:29,367 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:29,368 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:29,368 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:29,631 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:39,999 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-01-14 21:45:40,534 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:40,543 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:40,602 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:40,705 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0026 being deleted.
2016-01-14 21:45:40,931 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:40,965 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:41,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_20160114213932895_0027
2016-01-14 21:45:41,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0027
2016-01-14 21:45:41,702 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:50,982 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-01-14 21:45:50,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 00:23.894
2016-01-14 21:45:51,005 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-01-14 21:45:51,026 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:45:51,027 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:45:51,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.114
2016-01-14 21:45:51,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 21:45:51,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:45:51,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting
2016-01-14 21:45:51,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executing total steps: 3
2016-01-14 21:45:51,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] allocating management threads: 3
2016-01-14 21:45:51,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (1/3)
2016-01-14 21:45:51,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_20160114213932895_0028
2016-01-14 21:45:51,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0028
2016-01-14 21:45:52,135 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:52,460 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0027 being deleted.
2016-01-14 21:45:53,084 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:53,444 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:53,541 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:45:53,589 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:02,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (2/3)
2016-01-14 21:46:04,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_20160114213932895_0029
2016-01-14 21:46:04,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0029
2016-01-14 21:46:04,696 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:04,790 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:04,790 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:04,878 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0028 being deleted.
2016-01-14 21:46:05,326 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:05,758 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:15,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-01-14 21:46:16,261 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0029 being deleted.
2016-01-14 21:46:16,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_20160114213932895_0030
2016-01-14 21:46:16,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0030
2016-01-14 21:46:16,605 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:16,881 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:17,137 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:18,070 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:18,320 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:26,574 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-01-14 21:46:26,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] completed in: 00:35.397
2016-01-14 21:46:26,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-01-14 21:46:26,612 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:46:26,612 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:46:26,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-14 21:46:26,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 21:46:26,696 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:46:26,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-14 21:46:26,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:46:26,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:46:26,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 21:46:26,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-01-14 21:46:26,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2016-01-14 21:46:26,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 2
2016-01-14 21:46:26,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 2
2016-01-14 21:46:26,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/2)
2016-01-14 21:46:26,984 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:27,009 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:27,138 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:27,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_20160114213932895_0031
2016-01-14 21:46:27,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0031
2016-01-14 21:46:28,262 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0030 being deleted.
2016-01-14 21:46:28,504 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:29,713 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:39,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-01-14 21:46:39,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_20160114213932895_0032
2016-01-14 21:46:39,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:55402/jobdetails.jsp?jobid=job_20160114213932895_0032
2016-01-14 21:46:40,096 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:40,263 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20160114213932895_0031 being deleted.
2016-01-14 21:46:40,621 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:41,041 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:41,594 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:41,760 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 21:46:49,346 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-01-14 21:46:49,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 00:22.613
2016-01-14 21:46:49,367 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge