Class cascading.MergePipesPlatformTest

21

tests

0

failures

16m2.70s

duration

100%

successful

Tests

Test Duration Result
testHashJoinMergeIntoHashJoinAccumulated 46.525s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 1m6.81s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 1m12.01s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 1m9.07s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 1m10.99s passed
testHashJoinMergeIntoHashJoinStreamed 45.026s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 1m9.01s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 1m9.84s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 45.464s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 1m21.15s passed
testMergeIntoHashJoinAccumulated 43.967s passed
testMergeIntoHashJoinStreamed 22.174s passed
testSameSourceMergeThreeChainGroup 1m4.20s passed
testSimpleMerge 32.675s passed
testSimpleMergeFail 0.023s passed
testSimpleMergeThree 21.860s passed
testSimpleMergeThreeChain 24.064s passed
testSimpleMergeThreeChainCoGroup 37.882s passed
testSimpleMergeThreeChainGroup 37.882s passed
testSplitSameSourceMerged 21.057s passed
testSplitSameSourceMergedComplex 21.037s passed

Standard output

2015-08-13 20:38:18,520 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 20:38:18,570 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 20:38:18,570 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-08-13 20:38:18,611 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-13 20:38:19,599 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2015-08-13 20:38:20,775 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 20:38:20,778 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2015-08-13 20:38:21,358 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 20:38:21,359 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-13 20:38:21,476 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2015-08-13 20:38:21,815 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 20:38:21,816 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-13 20:38:21,902 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2015-08-13 20:38:22,216 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 20:38:22,217 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1520)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-13 20:38:22,291 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:517)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Generating rack names for tasktrackers
Generating host names for tasktrackers
2015-08-13 20:38:22,676 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2015-08-13 20:38:22,677 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:296)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:396)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:662)
2015-08-13 20:38:23,660 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 20:38:23,720 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 20:38:24,019 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 20:38:24,293 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 20:38:24,564 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 20:38:27,886 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-13 20:38:28,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:38:28,008 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:38:28,019 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 391FFBE5CCCE439C8C37B2A8ADDFAAE3
2015-08-13 20:38:28,230 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 20:38:28,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-13 20:38:28,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:38:28,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:38:28,235 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemerge"]
2015-08-13 20:38:28,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-08-13 20:38:28,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-08-13 20:38:28,238 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-08-13 20:38:28,240 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-13 20:38:28,321 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 20:38:28,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813203822624_0001
2015-08-13 20:38:28,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0001
2015-08-13 20:38:51,144 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemerge/_temporary
2015-08-13 20:38:51,183 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:38:51,256 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemerge
2015-08-13 20:38:51,337 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:38:51,338 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:38:51,507 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-13 20:38:51,508 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:38:51,508 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:38:51,509 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:38:51,509 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-08-13 20:38:51,509 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-08-13 20:38:51,510 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-08-13 20:38:51,510 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-08-13 20:38:51,512 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-13 20:38:51,880 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0001 being deleted.
2015-08-13 20:38:52,023 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:38:52,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0002
2015-08-13 20:38:52,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0002
2015-08-13 20:38:52,593 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:38:52,653 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:38:52,919 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:38:53,036 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:16,034 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0002 being deleted.
2015-08-13 20:39:16,039 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-13 20:39:16,582 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0003
2015-08-13 20:39:16,583 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0003
2015-08-13 20:39:17,210 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:17,268 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:18,353 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:19,100 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:19,691 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:19,793 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:40,083 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-13 20:39:40,603 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0004
2015-08-13 20:39:40,604 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0004
2015-08-13 20:39:40,757 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:41,263 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:42,376 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:43,053 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0003 being deleted.
2015-08-13 20:39:43,142 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:43,497 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:39:43,531 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:03,252 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-08-13 20:40:03,278 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-08-13 20:40:03,316 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:40:03,316 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:40:03,449 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-13 20:40:03,450 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:40:03,450 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:40:03,450 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:40:03,450 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-08-13 20:40:03,450 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-08-13 20:40:03,451 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-08-13 20:40:03,451 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-08-13 20:40:03,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-13 20:40:04,006 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0005
2015-08-13 20:40:04,006 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0005
2015-08-13 20:40:04,094 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0004 being deleted.
2015-08-13 20:40:04,200 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:04,244 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:04,496 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:04,616 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:05,057 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:25,143 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-13 20:40:25,679 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0006
2015-08-13 20:40:25,679 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0006
2015-08-13 20:40:26,045 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:26,045 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:26,155 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:26,482 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:27,401 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0005 being deleted.
2015-08-13 20:40:27,439 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:28,163 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:54,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-13 20:40:54,470 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:54,580 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:54,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0007
2015-08-13 20:40:54,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0007
2015-08-13 20:40:55,377 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:55,475 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:55,508 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:55,627 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:55,708 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:40:55,888 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:24,386 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-08-13 20:41:24,419 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-08-13 20:41:24,463 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:41:24,464 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:41:24,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-13 20:41:24,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:41:24,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:41:24,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:41:24,492 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethree"]
2015-08-13 20:41:24,492 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-08-13 20:41:24,492 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-08-13 20:41:24,492 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-08-13 20:41:24,494 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-13 20:41:24,593 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:24,617 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813203822624_0008
2015-08-13 20:41:24,617 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0008
2015-08-13 20:41:25,416 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,439 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,451 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,451 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,605 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,929 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:25,950 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:46,248 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethree/_temporary
2015-08-13 20:41:46,279 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemergethree
2015-08-13 20:41:46,324 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:41:46,325 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:41:46,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-08-13 20:41:46,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:41:46,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:41:46,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:41:46,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-08-13 20:41:46,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  parallel execution is enabled: true
2015-08-13 20:41:46,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  starting jobs: 2
2015-08-13 20:41:46,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  allocating threads: 2
2015-08-13 20:41:46,395 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-08-13 20:41:46,514 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813203822624_0009
2015-08-13 20:41:46,515 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0009
2015-08-13 20:41:47,009 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:47,064 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:47,215 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:47,767 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:48,575 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:49,436 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:49,542 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:41:49,571 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:09,453 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-08-13 20:42:09,973 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813203822624_0010
2015-08-13 20:42:09,974 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0010
2015-08-13 20:42:10,267 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0009 being deleted.
2015-08-13 20:42:10,384 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:10,438 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:10,518 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:10,660 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:10,891 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:11,527 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:31,726 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-08-13 20:42:31,751 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-08-13 20:42:31,785 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:42:31,785 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:42:31,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-13 20:42:31,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:42:31,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:42:31,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:42:31,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechain"]
2015-08-13 20:42:31,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-08-13 20:42:31,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-08-13 20:42:31,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-08-13 20:42:31,812 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-08-13 20:42:32,233 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:32,322 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813203822624_0011
2015-08-13 20:42:32,323 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0011
2015-08-13 20:42:32,634 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:33,502 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0010 being deleted.
2015-08-13 20:42:33,644 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:34,263 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:35,170 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:35,197 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:55,773 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechain/_temporary
2015-08-13 20:42:55,807 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechain
2015-08-13 20:42:55,861 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:42:55,861 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:42:55,935 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-13 20:42:55,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:42:55,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:42:55,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:42:55,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-08-13 20:42:55,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-08-13 20:42:55,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-08-13 20:42:55,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-08-13 20:42:55,940 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-13 20:42:56,003 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:56,458 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0012
2015-08-13 20:42:56,458 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0012
2015-08-13 20:42:56,589 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:57,672 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:58,440 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:58,558 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:58,717 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:59,796 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:42:59,925 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:18,555 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-13 20:43:19,078 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0013
2015-08-13 20:43:19,078 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0013
2015-08-13 20:43:19,377 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:19,679 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:19,739 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:19,782 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0012 being deleted.
2015-08-13 20:43:20,083 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:20,385 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:20,541 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:42,614 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-13 20:43:42,718 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0014
2015-08-13 20:43:42,718 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0014
2015-08-13 20:43:43,503 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:43,563 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:43,797 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0013 being deleted.
2015-08-13 20:43:43,996 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:44,566 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:46,637 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:43:46,744 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:04,800 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-08-13 20:44:04,824 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-08-13 20:44:05,277 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:44:05,279 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:44:05,293 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:05,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-13 20:44:05,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 20:44:05,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/splitsourcemerged"]
2015-08-13 20:44:05,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-08-13 20:44:05,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-08-13 20:44:05,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-08-13 20:44:05,301 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-08-13 20:44:05,413 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813203822624_0015
2015-08-13 20:44:05,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0015
2015-08-13 20:44:05,654 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:05,739 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:05,843 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:06,642 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0014 being deleted.
2015-08-13 20:44:07,550 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:25,859 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/splitsourcemerged/_temporary
2015-08-13 20:44:25,883 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/splitsourcemerged
2015-08-13 20:44:25,891 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:25,913 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:44:25,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:44:25,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-13 20:44:25,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:44:25,956 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:44:25,956 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:44:25,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-08-13 20:44:25,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-08-13 20:44:25,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 2
2015-08-13 20:44:25,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 2
2015-08-13 20:44:25,959 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-08-13 20:44:26,081 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813203822624_0016
2015-08-13 20:44:26,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0016
2015-08-13 20:44:26,759 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:27,781 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:28,267 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:28,487 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:29,726 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:48,681 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-08-13 20:44:48,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813203822624_0017
2015-08-13 20:44:48,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0017
2015-08-13 20:44:49,575 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:49,638 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:49,765 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:49,869 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0016 being deleted.
2015-08-13 20:44:49,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:49,998 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:44:50,978 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:10,881 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-08-13 20:45:10,906 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-08-13 20:45:10,936 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:45:10,937 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:45:10,944 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemergefail
2015-08-13 20:45:10,960 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:45:10,961 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:45:10,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-13 20:45:10,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:45:10,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:45:10,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:45:10,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup"]
2015-08-13 20:45:10,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-08-13 20:45:10,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-08-13 20:45:10,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-08-13 20:45:10,991 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-08-13 20:45:11,512 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813203822624_0018
2015-08-13 20:45:11,513 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0018
2015-08-13 20:45:11,730 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:11,801 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:11,806 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:12,078 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:12,696 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0017 being deleted.
2015-08-13 20:45:12,866 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:13,605 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:48,767 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-08-13 20:45:48,822 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechaingroup
2015-08-13 20:45:48,844 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:45:48,845 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:45:48,913 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-13 20:45:48,914 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:45:48,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:45:48,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:45:48,916 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-08-13 20:45:48,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-08-13 20:45:48,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-08-13 20:45:48,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-08-13 20:45:48,921 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-13 20:45:49,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0019
2015-08-13 20:45:49,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0019
2015-08-13 20:45:49,403 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:49,560 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:49,670 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:49,833 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:49,931 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:50,084 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:51,449 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:51,458 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:45:51,518 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:10,953 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-13 20:46:11,065 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0020
2015-08-13 20:46:11,066 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0020
2015-08-13 20:46:11,683 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:11,753 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:11,852 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:12,295 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:12,791 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0019 being deleted.
2015-08-13 20:46:12,956 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:13,640 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:35,002 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-08-13 20:46:35,518 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813203822624_0021
2015-08-13 20:46:35,518 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0021
2015-08-13 20:46:35,968 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:36,617 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:36,811 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0020 being deleted.
2015-08-13 20:46:37,546 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:37,747 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:39,180 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:57,861 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-08-13 20:46:57,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-08-13 20:46:57,919 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:46:57,919 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:46:57,943 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-13 20:46:57,943 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:46:57,943 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:46:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:46:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed"]
2015-08-13 20:46:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-08-13 20:46:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-08-13 20:46:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-08-13 20:46:57,946 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-08-13 20:46:58,450 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:58,466 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813203822624_0022
2015-08-13 20:46:58,466 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0022
2015-08-13 20:46:58,806 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:58,819 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:59,014 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0021 being deleted.
2015-08-13 20:46:59,384 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:46:59,942 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:20,036 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-08-13 20:47:20,061 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinstreamed
2015-08-13 20:47:20,092 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:47:20,093 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:47:20,117 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-13 20:47:20,118 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:47:20,119 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:47:20,119 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:47:20,120 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup"]
2015-08-13 20:47:20,121 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-08-13 20:47:20,121 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-08-13 20:47:20,121 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-08-13 20:47:20,125 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-08-13 20:47:20,245 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813203822624_0023
2015-08-13 20:47:20,245 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0023
2015-08-13 20:47:20,760 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:20,939 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:20,976 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:21,588 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:21,873 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0022 being deleted.
2015-08-13 20:47:22,038 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:22,794 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:57,939 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-08-13 20:47:57,954 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/simplemergethreechaincogroup
2015-08-13 20:47:57,981 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:47:57,982 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:47:58,012 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-13 20:47:58,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:47:58,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup"]
2015-08-13 20:47:58,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-08-13 20:47:58,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 2
2015-08-13 20:47:58,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 2
2015-08-13 20:47:58,016 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-08-13 20:47:58,695 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:58,873 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:58,943 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:58,996 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:59,116 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:47:59,336 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813203822624_0024
2015-08-13 20:47:59,336 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0024
2015-08-13 20:47:59,397 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:00,587 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:00,630 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:00,658 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:30,999 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-13 20:48:31,522 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813203822624_0025
2015-08-13 20:48:31,523 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0025
2015-08-13 20:48:31,661 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:31,727 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:32,257 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:32,345 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:33,051 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:33,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:48:33,959 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0024 being deleted.
2015-08-13 20:49:02,140 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup/_temporary
2015-08-13 20:49:02,154 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/samemergethreechaingroup
2015-08-13 20:49:02,179 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:49:02,180 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:49:02,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-13 20:49:02,256 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:49:02,257 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:49:02,257 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:49:02,257 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-08-13 20:49:02,257 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-08-13 20:49:02,257 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-08-13 20:49:02,258 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-08-13 20:49:02,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-13 20:49:02,805 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0026
2015-08-13 20:49:02,806 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0026
2015-08-13 20:49:02,818 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:02,994 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:03,003 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:03,014 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:03,350 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:04,013 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0025 being deleted.
2015-08-13 20:49:04,153 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:04,836 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:26,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-13 20:49:27,090 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0027
2015-08-13 20:49:27,090 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0027
2015-08-13 20:49:27,276 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:27,802 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:28,170 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:28,967 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:29,021 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:29,038 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:29,155 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0026 being deleted.
2015-08-13 20:49:49,053 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-13 20:49:49,569 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813203822624_0028
2015-08-13 20:49:49,569 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0028
2015-08-13 20:49:49,863 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:50,001 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:50,092 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:50,585 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:50,590 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0027 being deleted.
2015-08-13 20:49:51,275 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:49:51,306 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:13,107 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-08-13 20:50:13,132 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-08-13 20:50:13,163 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:50:13,163 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:50:13,191 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-13 20:50:13,191 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:50:13,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:50:13,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:50:13,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-08-13 20:50:13,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-08-13 20:50:13,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-08-13 20:50:13,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-08-13 20:50:13,196 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-13 20:50:13,851 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:14,116 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813203822624_0029
2015-08-13 20:50:14,117 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0029
2015-08-13 20:50:14,159 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:14,195 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:14,207 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0028 being deleted.
2015-08-13 20:50:14,244 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:15,251 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:15,596 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:35,253 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-13 20:50:35,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813203822624_0030
2015-08-13 20:50:35,365 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0030
2015-08-13 20:50:35,800 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:35,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:36,566 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:36,771 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:37,115 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0029 being deleted.
2015-08-13 20:50:38,011 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:38,105 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:57,079 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-08-13 20:50:57,101 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinaccumulated
2015-08-13 20:50:57,130 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:50:57,131 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:50:57,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-13 20:50:57,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 20:50:57,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex"]
2015-08-13 20:50:57,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-08-13 20:50:57,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-08-13 20:50:57,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-08-13 20:50:57,157 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-08-13 20:50:57,274 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813203822624_0031
2015-08-13 20:50:57,274 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0031
2015-08-13 20:50:57,632 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:57,877 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:58,300 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:58,952 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:59,049 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:50:59,263 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0030 being deleted.
2015-08-13 20:51:18,112 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-08-13 20:51:18,139 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/splitsourcemergedcomplex
2015-08-13 20:51:18,168 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:51:18,169 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:51:18,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-13 20:51:18,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:51:18,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:51:18,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:51:18,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-08-13 20:51:18,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-08-13 20:51:18,210 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-08-13 20:51:18,210 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-08-13 20:51:18,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-13 20:51:18,332 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813203822624_0032
2015-08-13 20:51:18,332 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0032
2015-08-13 20:51:18,599 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:18,940 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:19,335 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:19,806 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:19,935 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:21,102 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:41,321 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-13 20:51:41,837 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:42,122 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0032 being deleted.
2015-08-13 20:51:42,644 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813203822624_0033
2015-08-13 20:51:42,645 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0033
2015-08-13 20:51:42,827 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:43,354 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:44,185 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:44,373 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:51:44,487 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:04,642 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-08-13 20:52:04,664 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-08-13 20:52:04,701 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:52:04,702 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:52:04,765 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-08-13 20:52:04,765 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:52:04,765 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:52:04,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:52:04,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-08-13 20:52:04,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  parallel execution is enabled: true
2015-08-13 20:52:04,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  starting jobs: 3
2015-08-13 20:52:04,766 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  allocating threads: 3
2015-08-13 20:52:04,768 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-08-13 20:52:04,878 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813203822624_0034
2015-08-13 20:52:04,878 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0034
2015-08-13 20:52:05,125 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:05,150 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:05,171 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:05,523 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:06,136 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0033 being deleted.
2015-08-13 20:52:06,273 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:26,382 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-08-13 20:52:26,485 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813203822624_0035
2015-08-13 20:52:26,486 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0035
2015-08-13 20:52:27,294 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:27,567 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:27,974 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:27,985 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:28,652 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0034 being deleted.
2015-08-13 20:52:29,434 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:29,542 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:49,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-13 20:52:49,881 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813203822624_0036
2015-08-13 20:52:49,881 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0036
2015-08-13 20:52:50,612 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:51,152 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:51,169 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0035 being deleted.
2015-08-13 20:52:51,482 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:53,630 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:52:53,661 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:11,448 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-08-13 20:53:11,471 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-08-13 20:53:11,507 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 20:53:11,508 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 20:53:11,570 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-13 20:53:11,571 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-08-13 20:53:11,571 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-08-13 20:53:11,571 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-13 20:53:11,571 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-08-13 20:53:11,572 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-08-13 20:53:11,572 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-08-13 20:53:11,572 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-08-13 20:53:11,575 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-13 20:53:11,685 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0037
2015-08-13 20:53:11,685 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0037
2015-08-13 20:53:12,344 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:12,355 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:12,673 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:12,996 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:13,709 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0036 being deleted.
2015-08-13 20:53:14,507 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:34,768 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-13 20:53:34,973 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:35,334 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0038
2015-08-13 20:53:35,334 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0038
2015-08-13 20:53:35,462 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813203822624_0037 being deleted.
2015-08-13 20:53:35,836 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:35,839 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:35,879 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:36,883 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:37,159 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:53:58,817 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-13 20:53:59,698 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:00,129 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:00,138 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813203822624_0039
2015-08-13 20:54:00,138 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:55580/jobdetails.jsp?jobid=job_20150813203822624_0039
2015-08-13 20:54:00,296 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:00,409 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:00,438 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:01,148 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:02,923 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:02,977 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 20:54:21,286 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-08-13 20:54:21,308 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge