Class cascading.MergePipesPlatformTest

22

tests

0

failures

0

ignored

8m5.23s

duration

100%

successful

Tests

Test Duration Result
testGroupByAggregationMerge 35.240s passed
testHashJoinMergeIntoHashJoinAccumulated 23.109s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 37.279s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 38.004s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 38.274s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 37.934s passed
testHashJoinMergeIntoHashJoinStreamed 12.698s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 26.409s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 23.822s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 12.523s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 11.852s passed
testMergeIntoHashJoinAccumulated 11.548s passed
testMergeIntoHashJoinStreamed 13.088s passed
testSameSourceMergeThreeChainGroup 41.154s passed
testSimpleMerge 19.666s passed
testSimpleMergeFail 0.036s passed
testSimpleMergeThree 16.717s passed
testSimpleMergeThreeChain 15.199s passed
testSimpleMergeThreeChainCoGroup 23.303s passed
testSimpleMergeThreeChainGroup 22.448s passed
testSplitSameSourceMerged 12.122s passed
testSplitSameSourceMergedComplex 12.803s passed

Standard output

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