Class cascading.MergePipesPlatformTest

22

tests

0

failures

0

ignored

15m54.32s

duration

100%

successful

Tests

Test Duration Result
testGroupByAggregationMerge 1m3.06s passed
testHashJoinMergeIntoHashJoinAccumulated 48.000s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 1m18.12s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 1m20.88s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 1m22.27s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 1m15.85s passed
testHashJoinMergeIntoHashJoinStreamed 23.511s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 50.327s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 51.043s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 26.918s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 24.206s passed
testMergeIntoHashJoinAccumulated 26.643s passed
testMergeIntoHashJoinStreamed 24.020s passed
testSameSourceMergeThreeChainGroup 1m9.47s passed
testSimpleMerge 31.892s passed
testSimpleMergeFail 0.033s passed
testSimpleMergeThree 30.143s passed
testSimpleMergeThreeChain 30.555s passed
testSimpleMergeThreeChainCoGroup 40.839s passed
testSimpleMergeThreeChainGroup 41.447s passed
testSplitSameSourceMerged 27.717s passed
testSplitSameSourceMergedComplex 27.391s passed

Standard output

2016-05-17 21:47:38,726 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 21:47:38,742 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop
2016-05-17 21:47:38,771 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-05-17 21:47:39,542 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2016-05-17 21:47:40,302 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 21:47:40,304 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1483)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-05-17 21:47:40,708 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 21:47:40,709 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1483)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-05-17 21:47:40,800 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:500)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-05-17 21:47:41,105 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 21:47:41,106 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1483)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-05-17 21:47:41,190 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:500)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-05-17 21:47:41,405 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-05-17 21:47:41,405 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1483)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-05-17 21:47:41,472 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java:500)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:375)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:281)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1545)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1484)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1459)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-05-17 21:47:41,755 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-05-17 21:47:41,757 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:296)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:415)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1059)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:745)
2016-05-17 21:47:42,741 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 21:47:42,790 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 21:47:43,002 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 21:47:43,324 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 21:47:43,528 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-05-17 21:47:43,716 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-17 21:47:43,812 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:43,813 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:43,888 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 354CC41944D04ED08F4F00C03377D37D
2016-05-17 21:47:44,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.128
2016-05-17 21:47:44,060 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:47:44,061 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:44,186 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 21:47:44,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:47:44,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:47:44,189 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:47:44,189 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-05-17 21:47:44,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-17 21:47:44,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 1
2016-05-17 21:47:44,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 1
2016-05-17 21:47:44,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-17 21:47:44,887 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160517214741709_0001
2016-05-17 21:47:44,887 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0001
2016-05-17 21:48:10,570 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-17 21:48:10,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 00:26.381
2016-05-17 21:48:10,641 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMerge/simplemerge
2016-05-17 21:48:10,699 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:48:10,699 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:48:10,721 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0001 being deleted.
2016-05-17 21:48:10,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.221
2016-05-17 21:48:10,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:48:10,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:48:10,999 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-17 21:48:11,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:48:11,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:48:11,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:48:11,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-05-17 21:48:11,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-05-17 21:48:11,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  executing total steps: 3
2016-05-17 21:48:11,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  allocating management threads: 3
2016-05-17 21:48:11,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/3)
2016-05-17 21:48:11,253 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:11,535 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160517214741709_0002
2016-05-17 21:48:11,536 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0002
2016-05-17 21:48:11,621 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:13,227 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:13,738 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:14,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:14,357 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:37,616 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/3)
2016-05-17 21:48:37,739 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0002 being deleted.
2016-05-17 21:48:37,768 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160517214741709_0003
2016-05-17 21:48:37,768 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0003
2016-05-17 21:48:38,257 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:38,313 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:40,259 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:40,735 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:40,852 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:48:40,880 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:04,660 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-05-17 21:49:04,753 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0003 being deleted.
2016-05-17 21:49:05,104 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:05,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160517214741709_0004
2016-05-17 21:49:05,168 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0004
2016-05-17 21:49:05,774 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:07,258 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:07,952 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:08,008 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:08,769 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:31,501 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-05-17 21:49:31,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  completed in: 01:20.497
2016-05-17 21:49:31,527 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-05-17 21:49:31,527 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:31,561 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:49:31,561 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:49:31,650 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-17 21:49:31,652 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:49:31,652 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:49:31,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 21:49:31,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:49:31,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:49:31,680 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:49:31,680 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-05-17 21:49:31,681 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-05-17 21:49:31,681 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  executing total steps: 1
2016-05-17 21:49:31,681 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  allocating management threads: 1
2016-05-17 21:49:31,682 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-05-17 21:49:31,773 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0004 being deleted.
2016-05-17 21:49:32,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160517214741709_0005
2016-05-17 21:49:32,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0005
2016-05-17 21:49:32,456 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:33,158 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:34,295 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:34,442 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:55,705 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-05-17 21:49:55,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  completed in: 00:24.025
2016-05-17 21:49:55,733 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-05-17 21:49:55,760 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:49:55,760 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:49:55,784 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0005 being deleted.
2016-05-17 21:49:55,825 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:49:55,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:49:55,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:49:55,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:49:55,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:49:55,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:49:55,858 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:49:55,858 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-17 21:49:55,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-17 21:49:55,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 1
2016-05-17 21:49:55,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 1
2016-05-17 21:49:55,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-17 21:49:56,361 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160517214741709_0006
2016-05-17 21:49:56,361 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0006
2016-05-17 21:49:56,601 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:56,613 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:58,300 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:58,494 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:58,634 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:49:59,871 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:25,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-17 21:50:25,839 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 00:29.979
2016-05-17 21:50:25,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-05-17 21:50:25,906 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:50:25,907 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:50:25,982 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-17 21:50:25,983 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:50:25,984 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:50:26,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting
2016-05-17 21:50:26,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:50:26,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:50:26,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:50:26,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-05-17 21:50:26,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  parallel execution of steps is enabled: true
2016-05-17 21:50:26,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  executing total steps: 1
2016-05-17 21:50:26,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  allocating management threads: 1
2016-05-17 21:50:26,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-05-17 21:50:26,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] submitted hadoop job: job_20160517214741709_0007
2016-05-17 21:50:26,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0007
2016-05-17 21:50:26,345 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:26,613 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:28,406 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:29,181 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:29,526 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:30,108 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:52,770 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-05-17 21:50:52,771 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  completed in: 00:26.761
2016-05-17 21:50:52,796 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-05-17 21:50:52,823 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:50:52,824 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:50:52,842 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0007 being deleted.
2016-05-17 21:50:52,887 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:50:52,888 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:50:52,888 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:50:52,903 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:50:52,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:50:52,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:50:52,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:50:52,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-05-17 21:50:52,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-17 21:50:52,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 1
2016-05-17 21:50:52,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 1
2016-05-17 21:50:52,909 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-05-17 21:50:53,410 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160517214741709_0008
2016-05-17 21:50:53,410 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0008
2016-05-17 21:50:53,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:54,080 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:55,339 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:56,135 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:50:56,709 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:23,286 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-05-17 21:51:23,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 00:30.382
2016-05-17 21:51:23,349 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-05-17 21:51:23,383 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:51:23,383 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:51:23,469 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-05-17 21:51:23,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:51:23,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:51:23,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 21:51:23,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:51:23,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:51:23,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:51:23,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-05-17 21:51:23,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-05-17 21:51:23,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  executing total steps: 2
2016-05-17 21:51:23,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  allocating management threads: 2
2016-05-17 21:51:23,509 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/2)
2016-05-17 21:51:23,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160517214741709_0009
2016-05-17 21:51:23,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0009
2016-05-17 21:51:24,287 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:24,795 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:25,598 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:26,221 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:26,933 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:27,090 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:46,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-05-17 21:51:47,295 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0009 being deleted.
2016-05-17 21:51:47,306 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160517214741709_0010
2016-05-17 21:51:47,306 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0010
2016-05-17 21:51:47,478 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:47,491 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:49,385 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:49,798 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:50,053 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:51:51,047 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:13,661 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-05-17 21:52:13,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  completed in: 00:50.151
2016-05-17 21:52:13,682 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-05-17 21:52:13,719 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:52:13,719 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:52:13,761 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 21:52:13,762 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:52:13,763 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:52:13,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-17 21:52:13,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:52:13,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-17 21:52:13,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  parallel execution of steps is enabled: true
2016-05-17 21:52:13,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  executing total steps: 1
2016-05-17 21:52:13,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  allocating management threads: 1
2016-05-17 21:52:13,780 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-17 21:52:13,845 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:14,307 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0010 being deleted.
2016-05-17 21:52:14,667 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_20160517214741709_0011
2016-05-17 21:52:14,667 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0011
2016-05-17 21:52:14,871 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:15,297 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:16,405 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:17,826 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:41,344 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-17 21:52:41,345 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  completed in: 00:27.566
2016-05-17 21:52:41,400 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-17 21:52:41,421 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:52:41,422 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:52:41,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-17 21:52:41,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:52:41,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:52:41,496 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:52:41,496 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:52:41,496 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:52:41,497 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:52:41,498 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-05-17 21:52:41,498 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-17 21:52:41,499 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-17 21:52:41,499 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-17 21:52:41,500 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 21:52:41,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160517214741709_0012
2016-05-17 21:52:41,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0012
2016-05-17 21:52:41,662 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:42,217 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:43,427 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:43,704 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:44,165 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:52:44,542 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:04,881 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-05-17 21:53:04,883 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:23.383
2016-05-17 21:53:04,906 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-05-17 21:53:04,931 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:53:04,931 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:53:04,950 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.015
2016-05-17 21:53:04,950 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 21:53:04,952 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-05-17 21:53:04,965 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:53:04,965 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:53:05,026 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-17 21:53:05,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:53:05,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:53:05,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:53:05,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:53:05,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:53:05,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:53:05,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-05-17 21:53:05,060 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-17 21:53:05,060 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 1
2016-05-17 21:53:05,060 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 1
2016-05-17 21:53:05,061 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-05-17 21:53:05,344 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:05,351 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0012 being deleted.
2016-05-17 21:53:05,804 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:05,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160517214741709_0013
2016-05-17 21:53:05,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0013
2016-05-17 21:53:07,442 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:07,632 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:08,115 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:09,096 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:46,382 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-05-17 21:53:46,384 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 00:41.321
2016-05-17 21:53:46,395 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-05-17 21:53:46,415 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:53:46,416 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:53:46,471 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:46,531 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.110
2016-05-17 21:53:46,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:53:46,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:53:46,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 21:53:46,563 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:53:46,563 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:53:46,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:53:46,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-05-17 21:53:46,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-05-17 21:53:46,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  executing total steps: 3
2016-05-17 21:53:46,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  allocating management threads: 3
2016-05-17 21:53:46,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/3)
2016-05-17 21:53:46,889 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:47,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160517214741709_0014
2016-05-17 21:53:47,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0014
2016-05-17 21:53:47,371 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:47,525 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:47,527 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:47,858 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:47,951 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:53:48,028 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:13,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/3)
2016-05-17 21:54:13,914 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0014 being deleted.
2016-05-17 21:54:14,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160517214741709_0015
2016-05-17 21:54:14,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0015
2016-05-17 21:54:14,718 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:15,127 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:15,356 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:15,662 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:16,549 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:17,014 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:41,179 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-05-17 21:54:41,273 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:41,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_20160517214741709_0016
2016-05-17 21:54:41,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0016
2016-05-17 21:54:41,409 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0015 being deleted.
2016-05-17 21:54:41,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:42,470 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:43,549 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:54:44,653 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:08,636 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-05-17 21:55:08,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  completed in: 01:22.055
2016-05-17 21:55:08,652 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0016 being deleted.
2016-05-17 21:55:08,655 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-05-17 21:55:08,677 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:55:08,677 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:55:08,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-17 21:55:08,723 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:55:08,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:55:08,740 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:55:08,740 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:55:08,741 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:55:08,741 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:55:08,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-05-17 21:55:08,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-17 21:55:08,743 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-17 21:55:08,743 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-17 21:55:08,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 21:55:09,195 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160517214741709_0017
2016-05-17 21:55:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0017
2016-05-17 21:55:10,119 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:10,602 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:11,899 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:12,249 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:12,296 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:32,654 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-05-17 21:55:32,655 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:23.909
2016-05-17 21:55:32,665 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0017 being deleted.
2016-05-17 21:55:32,674 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-05-17 21:55:32,697 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:55:32,697 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:55:32,748 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-17 21:55:32,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:55:32,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:55:32,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:55:32,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:55:32,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:55:32,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:55:32,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-05-17 21:55:32,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-17 21:55:32,773 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-17 21:55:32,773 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-17 21:55:32,773 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-05-17 21:55:32,966 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:33,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_20160517214741709_0018
2016-05-17 21:55:33,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0018
2016-05-17 21:55:33,614 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:34,587 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:35,376 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:35,791 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:55:36,738 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:13,508 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-05-17 21:56:13,510 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:40.738
2016-05-17 21:56:13,521 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-05-17 21:56:13,536 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:56:13,537 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:56:13,609 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-17 21:56:13,610 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:56:13,611 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:56:13,636 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:56:13,636 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:56:13,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-17 21:56:13,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-17 21:56:13,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 2
2016-05-17 21:56:13,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 2
2016-05-17 21:56:13,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/2)
2016-05-17 21:56:13,738 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160517214741709_0019
2016-05-17 21:56:13,738 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0019
2016-05-17 21:56:14,229 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:14,311 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:14,397 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:14,698 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:15,329 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:15,400 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:15,442 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:15,729 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:15,790 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:44,282 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-17 21:56:44,489 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:44,632 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:44,820 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_20160517214741709_0020
2016-05-17 21:56:44,820 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0020
2016-05-17 21:56:44,870 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:45,775 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:46,104 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:46,314 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:56:46,522 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0019 being deleted.
2016-05-17 21:57:22,977 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-17 21:57:22,979 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 01:09.335
2016-05-17 21:57:22,993 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-17 21:57:23,013 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:57:23,013 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:57:23,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-17 21:57:23,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:57:23,106 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:57:23,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 21:57:23,137 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:57:23,137 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:57:23,137 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:57:23,138 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-05-17 21:57:23,138 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-05-17 21:57:23,138 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  executing total steps: 3
2016-05-17 21:57:23,138 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  allocating management threads: 3
2016-05-17 21:57:23,140 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/3)
2016-05-17 21:57:23,222 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:23,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160517214741709_0021
2016-05-17 21:57:23,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0021
2016-05-17 21:57:23,654 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:23,725 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0020 being deleted.
2016-05-17 21:57:23,860 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:24,367 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:24,612 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:25,211 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:47,756 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (2/3)
2016-05-17 21:57:48,243 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160517214741709_0022
2016-05-17 21:57:48,243 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0022
2016-05-17 21:57:48,493 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:48,877 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:50,117 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:50,325 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0021 being deleted.
2016-05-17 21:57:51,069 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:57:51,969 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:14,361 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-05-17 21:58:14,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_20160517214741709_0023
2016-05-17 21:58:14,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0023
2016-05-17 21:58:14,765 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0022 being deleted.
2016-05-17 21:58:14,810 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:15,046 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:15,177 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:15,288 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:17,597 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:18,260 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:38,806 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-05-17 21:58:38,809 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  completed in: 01:15.664
2016-05-17 21:58:38,831 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-05-17 21:58:38,861 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:58:38,861 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:58:38,863 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:38,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 21:58:38,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:58:38,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:58:38,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 21:58:38,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:58:38,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:58:38,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:58:38,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-05-17 21:58:38,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  parallel execution of steps is enabled: true
2016-05-17 21:58:38,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  executing total steps: 1
2016-05-17 21:58:38,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  allocating management threads: 1
2016-05-17 21:58:38,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-05-17 21:58:39,015 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160517214741709_0024
2016-05-17 21:58:39,015 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0024
2016-05-17 21:58:39,489 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:41,149 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:41,372 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0023 being deleted.
2016-05-17 21:58:41,991 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:42,163 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:58:43,209 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:05,412 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-05-17 21:59:05,421 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  completed in: 00:26.491
2016-05-17 21:59:05,477 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-05-17 21:59:05,501 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:59:05,502 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:59:05,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 21:59:05,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:59:05,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:59:05,559 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting
2016-05-17 21:59:05,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:59:05,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-05-17 21:59:05,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  parallel execution of steps is enabled: true
2016-05-17 21:59:05,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  executing total steps: 1
2016-05-17 21:59:05,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  allocating management threads: 1
2016-05-17 21:59:05,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-05-17 21:59:05,600 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:05,812 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0024 being deleted.
2016-05-17 21:59:06,348 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:06,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] submitted hadoop job: job_20160517214741709_0025
2016-05-17 21:59:06,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0025
2016-05-17 21:59:07,340 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:08,175 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:09,662 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:32,853 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-05-17 21:59:32,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  completed in: 00:27.293
2016-05-17 21:59:32,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-05-17 21:59:32,893 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:59:32,894 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:59:32,969 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-17 21:59:32,970 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:59:32,971 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:59:32,999 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 21:59:33,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:59:33,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:59:33,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:59:33,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-05-17 21:59:33,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  parallel execution of steps is enabled: true
2016-05-17 21:59:33,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  executing total steps: 2
2016-05-17 21:59:33,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  allocating management threads: 2
2016-05-17 21:59:33,005 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/2)
2016-05-17 21:59:33,315 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:33,497 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160517214741709_0026
2016-05-17 21:59:33,497 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0026
2016-05-17 21:59:33,781 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:35,189 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:35,991 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:36,223 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:36,990 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:56,820 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-05-17 21:59:56,860 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0026 being deleted.
2016-05-17 21:59:57,444 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:57,634 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:58,111 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_20160517214741709_0027
2016-05-17 21:59:58,112 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0027
2016-05-17 21:59:59,217 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:59,548 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 21:59:59,572 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:01,036 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:20,855 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-05-17 22:00:20,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  completed in: 00:47.852
2016-05-17 22:00:20,870 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0027 being deleted.
2016-05-17 22:00:20,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-05-17 22:00:20,895 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:00:20,895 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:00:20,998 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-17 22:00:21,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 22:00:21,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:00:21,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting
2016-05-17 22:00:21,033 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 22:00:21,033 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 22:00:21,034 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 22:00:21,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-05-17 22:00:21,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  parallel execution of steps is enabled: true
2016-05-17 22:00:21,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  executing total steps: 3
2016-05-17 22:00:21,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  allocating management threads: 3
2016-05-17 22:00:21,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (1/3)
2016-05-17 22:00:21,397 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:21,444 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:21,937 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160517214741709_0028
2016-05-17 22:00:21,937 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0028
2016-05-17 22:00:23,226 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:23,671 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:23,743 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:24,997 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:44,879 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (2/3)
2016-05-17 22:00:44,885 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0028 being deleted.
2016-05-17 22:00:45,294 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:45,775 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:45,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160517214741709_0029
2016-05-17 22:00:45,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0029
2016-05-17 22:00:47,249 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:47,504 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:47,663 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:00:47,665 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:11,506 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-05-17 22:01:11,899 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0029 being deleted.
2016-05-17 22:01:12,800 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_20160517214741709_0030
2016-05-17 22:01:12,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0030
2016-05-17 22:01:12,840 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:13,065 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:13,084 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:14,262 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:14,408 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:38,948 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0030 being deleted.
2016-05-17 22:01:38,962 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-05-17 22:01:38,965 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  completed in: 01:17.920
2016-05-17 22:01:38,984 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-05-17 22:01:39,010 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:39,010 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:01:39,076 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-05-17 22:01:39,078 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-17 22:01:39,078 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:39,112 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 22:01:39,113 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 22:01:39,113 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 22:01:39,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testGroupByAggregationMerge"]
2016-05-17 22:01:39,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-17 22:01:39,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 3
2016-05-17 22:01:39,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 3
2016-05-17 22:01:39,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/3)
2016-05-17 22:01:39,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (2/3)
2016-05-17 22:01:39,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160517214741709_0031
2016-05-17 22:01:39,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0031
2016-05-17 22:01:39,529 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:39,683 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160517214741709_0032
2016-05-17 22:01:39,684 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0032
2016-05-17 22:01:40,142 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:40,534 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:41,293 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:42,460 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:48,428 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:54,353 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:01:57,131 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:18,107 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:18,408 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:19,174 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:19,252 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:20,195 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (3/3) ...stGroupByAggregationMerge
2016-05-17 22:02:20,693 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_20160517214741709_0033
2016-05-17 22:02:20,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0033
2016-05-17 22:02:21,025 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0031 being deleted.
2016-05-17 22:02:21,449 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:21,662 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:21,724 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:21,796 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:22,338 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:22,448 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:42,014 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0033 being deleted.
2016-05-17 22:02:42,023 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testGroupByAggregationMerge/_temporary
2016-05-17 22:02:42,026 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 01:02.900
2016-05-17 22:02:42,034 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0033 being deleted.
2016-05-17 22:02:42,073 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:02:42,073 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:02:42,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-17 22:02:42,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 22:02:42,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:02:42,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-17 22:02:42,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 22:02:42,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 22:02:42,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]
2016-05-17 22:02:42,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-05-17 22:02:42,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-05-17 22:02:42,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  executing total steps: 2
2016-05-17 22:02:42,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  allocating management threads: 2
2016-05-17 22:02:42,176 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/2)
2016-05-17 22:02:42,320 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:42,675 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160517214741709_0034
2016-05-17 22:02:42,675 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0034
2016-05-17 22:02:42,888 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:44,347 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:02:44,670 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:06,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-05-17 22:03:06,481 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20160517214741709_0034 being deleted.
2016-05-17 22:03:06,894 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:06,941 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_20160517214741709_0035
2016-05-17 22:03:06,941 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://localhost:40214/jobdetails.jsp?jobid=job_20160517214741709_0035
2016-05-17 22:03:07,545 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:08,371 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:09,315 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:09,567 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:09,609 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-05-17 22:03:33,071 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-05-17 22:03:33,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  completed in: 00:50.898
2016-05-17 22:03:33,093 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge