2016-01-14 18:05:07,997 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 18:05:08,013 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop
2016-01-14 18:05:08,045 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-01-14 18:05:08,762 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2016-01-14 18:05:09,561 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 18:05:09,562 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-01-14 18:05:10,011 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 18:05:10,013 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 18:05:10,090 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-01-14 18:05:10,373 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 18:05:10,374 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 18:05:10,456 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-01-14 18:05:10,669 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2016-01-14 18:05:10,670 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 18:05:10,734 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-01-14 18:05:11,012 WARN impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2016-01-14 18:05:11,015 WARN util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:151)
at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:160)
at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:173)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:930)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java:500)
at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:296)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 18:05:11,098 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 18:05:12,027 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 18:05:12,243 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 18:05:12,429 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 18:05:12,611 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 18:05:15,785 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 18:05:15,878 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:05:15,879 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:05:15,957 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: E536976181B248849E16D46B42BB38B6
2016-01-14 18:05:16,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.117
2016-01-14 18:05:16,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:05:16,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:05:16,242 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 18:05:16,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:05:16,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:05:16,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 18:05:16,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-01-14 18:05:16,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:05:16,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:05:16,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:05:16,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-01-14 18:05:16,319 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 18:05:16,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0001
2016-01-14 18:05:16,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0001
2016-01-14 18:05:42,492 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-01-14 18:05:42,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.248
2016-01-14 18:05:42,559 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-01-14 18:05:42,591 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:05:42,591 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:05:42,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.131
2016-01-14 18:05:42,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 18:05:42,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:05:42,788 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0001 being deleted.
2016-01-14 18:05:42,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2016-01-14 18:05:42,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:05:42,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:05:42,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-01-14 18:05:42,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] parallel execution of steps is enabled: true
2016-01-14 18:05:42,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executing total steps: 2
2016-01-14 18:05:42,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] allocating management threads: 2
2016-01-14 18:05:42,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/2)
2016-01-14 18:05:42,917 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:05:42,948 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:05:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_20160114180510964_0002
2016-01-14 18:05:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0002
2016-01-14 18:05:44,032 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:05:45,468 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:05:45,981 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:09,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-01-14 18:06:09,804 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0002 being deleted.
2016-01-14 18:06:10,056 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:10,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_20160114180510964_0003
2016-01-14 18:06:10,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0003
2016-01-14 18:06:11,107 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:12,498 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:13,739 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:13,971 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:36,555 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-01-14 18:06:36,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] completed in: 00:53.715
2016-01-14 18:06:36,597 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-01-14 18:06:36,635 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:06:36,635 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:06:36,745 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.104
2016-01-14 18:06:36,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 18:06:36,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:06:36,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting
2016-01-14 18:06:36,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:06:36,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:06:36,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:06:36,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-01-14 18:06:36,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] parallel execution of steps is enabled: true
2016-01-14 18:06:36,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executing total steps: 2
2016-01-14 18:06:36,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] allocating management threads: 2
2016-01-14 18:06:36,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (1/2)
2016-01-14 18:06:36,819 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0003 being deleted.
2016-01-14 18:06:36,923 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:37,131 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:37,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_20160114180510964_0004
2016-01-14 18:06:37,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0004
2016-01-14 18:06:37,704 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:39,524 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:06:40,710 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:03,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-01-14 18:07:03,749 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:03,832 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0004 being deleted.
2016-01-14 18:07:03,840 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:04,535 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:04,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_20160114180510964_0005
2016-01-14 18:07:04,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0005
2016-01-14 18:07:06,541 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:07,582 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:31,144 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0005 being deleted.
2016-01-14 18:07:31,150 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-01-14 18:07:31,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] completed in: 00:54.374
2016-01-14 18:07:31,189 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-01-14 18:07:31,212 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:07:31,212 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:07:31,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 18:07:31,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:07:31,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:07:31,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2016-01-14 18:07:31,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:07:31,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:07:31,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-01-14 18:07:31,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] parallel execution of steps is enabled: true
2016-01-14 18:07:31,283 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executing total steps: 1
2016-01-14 18:07:31,283 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] allocating management threads: 1
2016-01-14 18:07:31,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-01-14 18:07:31,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_20160114180510964_0006
2016-01-14 18:07:31,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0006
2016-01-14 18:07:31,837 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:32,591 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:33,544 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:33,701 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:34,010 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:34,926 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:57,653 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-01-14 18:07:57,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] completed in: 00:26.367
2016-01-14 18:07:57,703 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-01-14 18:07:57,731 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:07:57,732 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:07:57,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.096
2016-01-14 18:07:57,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 18:07:57,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:07:57,846 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:57,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:07:57,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:07:57,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:07:57,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-01-14 18:07:57,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:07:57,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 18:07:57,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 18:07:57,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 18:07:57,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 18:07:58,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0008
2016-01-14 18:07:58,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0008
2016-01-14 18:07:58,162 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0006 being deleted.
2016-01-14 18:07:58,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0007
2016-01-14 18:07:58,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0007
2016-01-14 18:07:58,722 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:07:59,395 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:00,569 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:01,731 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:13,542 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:34,490 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:34,556 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:34,615 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:35,014 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:35,427 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:36,469 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0008 being deleted.
2016-01-14 18:08:39,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-01-14 18:08:39,784 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:40,022 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:40,189 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0007 being deleted.
2016-01-14 18:08:40,241 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:40,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0009
2016-01-14 18:08:40,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0009
2016-01-14 18:08:40,587 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:08:41,782 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:00,932 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-01-14 18:09:00,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:03.024
2016-01-14 18:09:00,954 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-01-14 18:09:01,104 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0009 being deleted.
2016-01-14 18:09:01,199 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0009 being deleted.
2016-01-14 18:09:01,205 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0009 being deleted.
2016-01-14 18:09:01,394 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:09:01,394 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:09:01,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-14 18:09:01,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:09:01,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:09:01,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 18:09:01,513 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:09:01,513 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:09:01,513 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:09:01,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:09:01,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-01-14 18:09:01,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2016-01-14 18:09:01,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 1
2016-01-14 18:09:01,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 1
2016-01-14 18:09:01,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-01-14 18:09:01,562 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:01,623 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0010
2016-01-14 18:09:01,623 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0010
2016-01-14 18:09:02,299 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:34,369 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0010 being deleted.
2016-01-14 18:09:34,374 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-01-14 18:09:34,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:32.861
2016-01-14 18:09:34,395 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-01-14 18:09:34,595 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:34,825 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:09:34,825 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:09:34,931 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.101
2016-01-14 18:09:34,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-01-14 18:09:34,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:09:34,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2016-01-14 18:09:34,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:09:34,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:09:34,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 18:09:34,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-01-14 18:09:34,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-01-14 18:09:34,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] parallel execution of steps is enabled: true
2016-01-14 18:09:34,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executing total steps: 3
2016-01-14 18:09:34,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] allocating management threads: 3
2016-01-14 18:09:34,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/3)
2016-01-14 18:09:35,040 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:35,295 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:35,391 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:35,408 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:09:35,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_20160114180510964_0011
2016-01-14 18:09:35,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0011
2016-01-14 18:09:35,840 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:07,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-01-14 18:10:07,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-01-14 18:10:07,480 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0011 being deleted.
2016-01-14 18:10:07,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_20160114180510964_0012
2016-01-14 18:10:07,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0012
2016-01-14 18:10:07,610 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:07,951 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:08,310 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:08,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_20160114180510964_0013
2016-01-14 18:10:08,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0013
2016-01-14 18:10:08,512 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:08,668 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:08,856 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:28,456 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0013 being deleted.
2016-01-14 18:10:28,456 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0012 being deleted.
2016-01-14 18:10:28,456 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0012 being deleted.
2016-01-14 18:10:28,466 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-01-14 18:10:28,467 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-01-14 18:10:28,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] completed in: 00:53.484
2016-01-14 18:10:28,490 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0013 being deleted.
2016-01-14 18:10:28,490 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0012 being deleted.
2016-01-14 18:10:28,516 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-01-14 18:10:28,519 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-01-14 18:10:28,537 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:10:28,537 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:10:28,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-01-14 18:10:28,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 18:10:28,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:10:28,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 18:10:28,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:10:28,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:10:28,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:10:28,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:10:28,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-01-14 18:10:28,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2016-01-14 18:10:28,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 2
2016-01-14 18:10:28,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 2
2016-01-14 18:10:28,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2016-01-14 18:10:29,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0014
2016-01-14 18:10:29,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0014
2016-01-14 18:10:29,313 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:29,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:29,468 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:29,504 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:31,445 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0013 being deleted.
2016-01-14 18:10:55,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-01-14 18:10:55,501 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0014 being deleted.
2016-01-14 18:10:55,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0015
2016-01-14 18:10:55,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0015
2016-01-14 18:10:55,772 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:56,571 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:57,096 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:10:58,599 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:28,509 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-01-14 18:11:28,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:59.848
2016-01-14 18:11:28,515 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0015 being deleted.
2016-01-14 18:11:28,539 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-01-14 18:11:28,564 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:11:28,564 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:11:28,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-14 18:11:28,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 18:11:28,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:11:28,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 18:11:28,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2016-01-14 18:11:28,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 2
2016-01-14 18:11:28,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 2
2016-01-14 18:11:28,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2016-01-14 18:11:29,139 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:29,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0016
2016-01-14 18:11:29,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0016
2016-01-14 18:11:29,751 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:29,797 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:29,857 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:29,923 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:30,032 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:55,555 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-01-14 18:11:55,568 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0016 being deleted.
2016-01-14 18:11:55,906 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:56,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0017
2016-01-14 18:11:56,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0017
2016-01-14 18:11:56,345 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:58,662 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:59,625 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:11:59,771 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:00,009 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:28,576 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-01-14 18:12:28,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:59.905
2016-01-14 18:12:28,582 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0017 being deleted.
2016-01-14 18:12:28,598 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-01-14 18:12:28,714 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:12:28,715 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:12:28,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 18:12:28,752 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:12:28,752 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:12:28,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:12:28,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:12:28,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:12:28,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-01-14 18:12:28,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:12:28,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:12:28,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:12:28,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-01-14 18:12:29,143 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:29,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0018
2016-01-14 18:12:29,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0018
2016-01-14 18:12:29,951 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:29,962 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:30,070 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:31,687 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:32,815 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:55,619 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-01-14 18:12:55,621 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.850
2016-01-14 18:12:55,659 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0018 being deleted.
2016-01-14 18:12:55,672 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-01-14 18:12:55,700 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:12:55,700 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:12:55,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 18:12:55,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 18:12:55,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:12:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting
2016-01-14 18:12:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:12:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:12:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 18:12:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-01-14 18:12:55,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] parallel execution of steps is enabled: true
2016-01-14 18:12:55,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executing total steps: 2
2016-01-14 18:12:55,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] allocating management threads: 2
2016-01-14 18:12:55,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (1/2)
2016-01-14 18:12:55,897 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:56,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_20160114180510964_0019
2016-01-14 18:12:56,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0019
2016-01-14 18:12:56,537 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:56,733 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:12:58,705 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:00,085 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:28,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-01-14 18:13:28,672 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0019 being deleted.
2016-01-14 18:13:29,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_20160114180510964_0020
2016-01-14 18:13:29,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0020
2016-01-14 18:13:29,165 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:29,180 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:29,491 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:29,724 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:29,880 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:30,011 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:50,052 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0020 being deleted.
2016-01-14 18:13:50,053 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0020 being deleted.
2016-01-14 18:13:50,053 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0020 being deleted.
2016-01-14 18:13:50,067 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-01-14 18:13:50,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] completed in: 00:54.271
2016-01-14 18:13:50,087 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-01-14 18:13:50,100 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:13:50,101 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:13:50,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 18:13:50,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:13:50,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:13:50,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-14 18:13:50,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:13:50,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:13:50,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testCross/cross"]
2016-01-14 18:13:50,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-01-14 18:13:50,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2016-01-14 18:13:50,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2016-01-14 18:13:50,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-01-14 18:13:50,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_20160114180510964_0021
2016-01-14 18:13:50,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0021
2016-01-14 18:13:50,791 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:13:51,601 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:14,496 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testCross/cross/_temporary
2016-01-14 18:14:14,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:24.350
2016-01-14 18:14:14,527 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testCross/cross
2016-01-14 18:14:14,546 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:14:14,546 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:14:14,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 18:14:14,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:14:14,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:14:14,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:14:14,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:14:14,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:14:14,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoin/join"]
2016-01-14 18:14:14,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:14:14,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:14:14,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:14:14,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-01-14 18:14:14,935 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:15,146 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:15,154 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:15,887 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0022
2016-01-14 18:14:15,887 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0022
2016-01-14 18:14:16,019 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:16,105 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:18,003 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:41,566 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0022 being deleted.
2016-01-14 18:14:41,572 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoin/join/_temporary
2016-01-14 18:14:41,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.971
2016-01-14 18:14:41,616 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoin/join
2016-01-14 18:14:41,644 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:14:41,644 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:14:41,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-01-14 18:14:41,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 18:14:41,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:14:41,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 18:14:41,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:14:41,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:14:41,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:14:41,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-01-14 18:14:41,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-01-14 18:14:41,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2016-01-14 18:14:41,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 3
2016-01-14 18:14:41,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 3
2016-01-14 18:14:41,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2016-01-14 18:14:41,912 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:42,539 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:42,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0023
2016-01-14 18:14:42,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0023
2016-01-14 18:14:44,225 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:45,240 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:45,665 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:14:45,951 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:05,991 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0023 being deleted.
2016-01-14 18:15:05,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/rhs
2016-01-14 18:15:05,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/lhs
2016-01-14 18:15:06,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0025
2016-01-14 18:15:06,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0025
2016-01-14 18:15:06,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0024
2016-01-14 18:15:06,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0024
2016-01-14 18:15:06,847 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:07,363 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:08,240 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:08,688 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:09,783 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:41,336 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:41,566 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0024 being deleted.
2016-01-14 18:15:41,571 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-01-14 18:15:41,572 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-01-14 18:15:41,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:59.777
2016-01-14 18:15:41,599 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-01-14 18:15:41,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-01-14 18:15:41,620 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:15:41,620 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:15:41,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 18:15:41,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:15:41,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:15:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting
2016-01-14 18:15:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:15:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:15:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:15:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:15:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-01-14 18:15:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] parallel execution of steps is enabled: true
2016-01-14 18:15:41,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executing total steps: 1
2016-01-14 18:15:41,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] allocating management threads: 1
2016-01-14 18:15:41,715 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-01-14 18:15:41,889 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:41,937 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:41,939 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:42,017 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0024 being deleted.
2016-01-14 18:15:42,018 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0025 being deleted.
2016-01-14 18:15:42,192 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:42,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] submitted hadoop job: job_20160114180510964_0026
2016-01-14 18:15:42,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0026
2016-01-14 18:15:42,558 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:43,108 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:43,207 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:43,361 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:43,458 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:15:44,155 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0025 being deleted.
2016-01-14 18:16:20,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-01-14 18:16:20,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] completed in: 00:38.508
2016-01-14 18:16:20,247 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-01-14 18:16:20,261 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:16:20,261 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:16:20,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 18:16:20,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:16:20,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:16:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:16:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:16:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:16:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-01-14 18:16:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:16:20,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:16:20,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:16:20,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-01-14 18:16:20,712 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:20,783 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:20,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0027
2016-01-14 18:16:20,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0027
2016-01-14 18:16:21,040 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0026 being deleted.
2016-01-14 18:16:21,149 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:21,284 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:21,405 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:21,564 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:22,111 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:45,489 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-01-14 18:16:45,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:25.183
2016-01-14 18:16:45,532 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-01-14 18:16:45,553 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:16:45,554 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:16:45,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 18:16:45,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:16:45,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:16:45,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2016-01-14 18:16:45,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:16:45,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:16:45,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:16:45,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-01-14 18:16:45,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-01-14 18:16:45,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 1
2016-01-14 18:16:45,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 1
2016-01-14 18:16:45,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-01-14 18:16:45,826 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:46,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_20160114180510964_0028
2016-01-14 18:16:46,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0028
2016-01-14 18:16:46,372 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:47,541 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:47,609 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0027 being deleted.
2016-01-14 18:16:48,437 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:16:49,405 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:11,649 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-01-14 18:17:11,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 00:26.031
2016-01-14 18:17:11,682 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-01-14 18:17:11,702 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:17:11,703 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:17:11,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 18:17:11,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:17:11,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:17:11,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:17:11,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:17:11,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:17:11,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-01-14 18:17:11,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:17:11,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:17:11,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:17:11,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-01-14 18:17:12,496 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0028 being deleted.
2016-01-14 18:17:12,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0029
2016-01-14 18:17:12,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0029
2016-01-14 18:17:12,701 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:12,762 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:13,464 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:14,315 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:15,449 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:39,128 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-01-14 18:17:39,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:27.378
2016-01-14 18:17:39,166 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinNone/joinnone
2016-01-14 18:17:39,185 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:17:39,185 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:17:39,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 18:17:39,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 18:17:39,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:17:39,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:17:39,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:17:39,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:17:39,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-01-14 18:17:39,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:17:39,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2016-01-14 18:17:39,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2016-01-14 18:17:39,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-14 18:17:39,495 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:39,509 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0029 being deleted.
2016-01-14 18:17:40,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0030
2016-01-14 18:17:40,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0030
2016-01-14 18:17:40,459 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:41,401 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:42,499 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:17:42,543 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:05,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-01-14 18:18:05,791 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:06,210 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0031
2016-01-14 18:18:06,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0031
2016-01-14 18:18:06,525 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0030 being deleted.
2016-01-14 18:18:06,568 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:07,296 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:09,480 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:09,873 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:29,729 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-01-14 18:18:29,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:50.486
2016-01-14 18:18:29,766 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSelf/joinself
2016-01-14 18:18:29,789 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:18:29,790 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:18:29,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 18:18:29,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 18:18:29,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:18:29,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 18:18:29,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:18:29,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:18:29,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:18:29,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-01-14 18:18:29,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-01-14 18:18:29,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2016-01-14 18:18:29,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 3
2016-01-14 18:18:29,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 3
2016-01-14 18:18:29,891 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2016-01-14 18:18:29,924 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:29,953 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:29,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0032
2016-01-14 18:18:29,998 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0032
2016-01-14 18:18:30,150 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0031 being deleted.
2016-01-14 18:18:31,328 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:31,660 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:32,542 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:32,568 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:50,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2016-01-14 18:18:50,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2016-01-14 18:18:50,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0034
2016-01-14 18:18:50,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0034
2016-01-14 18:18:50,980 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:51,496 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:51,640 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:51,729 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:52,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0033
2016-01-14 18:18:52,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0033
2016-01-14 18:18:52,527 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:54,484 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:18:59,617 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:00,764 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:01,782 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:17,764 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0034 being deleted.
2016-01-14 18:19:18,217 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-01-14 18:19:18,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-01-14 18:19:18,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:48.325
2016-01-14 18:19:18,260 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-01-14 18:19:18,269 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-01-14 18:19:18,287 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:19:18,287 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:19:18,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 18:19:18,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 18:19:18,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:19:18,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting
2016-01-14 18:19:18,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:19:18,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:19:18,361 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:19:18,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-01-14 18:19:18,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] parallel execution of steps is enabled: true
2016-01-14 18:19:18,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executing total steps: 2
2016-01-14 18:19:18,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] allocating management threads: 2
2016-01-14 18:19:18,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (1/2)
2016-01-14 18:19:18,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_20160114180510964_0035
2016-01-14 18:19:18,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0035
2016-01-14 18:19:18,511 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:18,576 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0033 being deleted.
2016-01-14 18:19:19,018 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:19,203 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:19,692 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:19,721 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:21,217 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:21,769 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:42,201 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-01-14 18:19:42,223 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0035 being deleted.
2016-01-14 18:19:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_20160114180510964_0036
2016-01-14 18:19:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0036
2016-01-14 18:19:43,283 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:43,507 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:43,573 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:43,838 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:44,895 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:19:45,073 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:09,672 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-01-14 18:20:09,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] completed in: 00:51.298
2016-01-14 18:20:09,691 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0036 being deleted.
2016-01-14 18:20:09,704 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-01-14 18:20:09,725 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:20:09,725 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:20:09,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-14 18:20:09,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 18:20:09,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:20:09,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:20:09,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:20:09,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:20:09,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-01-14 18:20:09,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:20:09,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2016-01-14 18:20:09,801 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2016-01-14 18:20:09,801 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-14 18:20:10,350 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:10,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0037
2016-01-14 18:20:10,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0037
2016-01-14 18:20:10,973 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:11,916 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:12,055 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:13,559 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:48,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-01-14 18:20:48,427 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:48,707 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0037 being deleted.
2016-01-14 18:20:48,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0038
2016-01-14 18:20:48,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0038
2016-01-14 18:20:49,032 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:49,079 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:49,463 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:49,702 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:20:49,832 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:15,278 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-01-14 18:21:15,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:05.477
2016-01-14 18:21:15,314 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-01-14 18:21:15,338 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:21:15,338 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:21:15,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-01-14 18:21:15,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 18:21:15,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:21:15,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-01-14 18:21:15,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 3
2016-01-14 18:21:15,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 3
2016-01-14 18:21:15,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/3)
2016-01-14 18:21:15,506 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:15,719 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0038 being deleted.
2016-01-14 18:21:16,260 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:16,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_20160114180510964_0039
2016-01-14 18:21:16,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0039
2016-01-14 18:21:17,191 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:18,375 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:19,470 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:42,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/3)
2016-01-14 18:21:42,732 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0039 being deleted.
2016-01-14 18:21:43,203 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:44,009 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:44,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_20160114180510964_0040
2016-01-14 18:21:44,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0040
2016-01-14 18:21:44,104 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:45,395 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:21:45,753 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:10,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-01-14 18:22:10,191 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0040 being deleted.
2016-01-14 18:22:11,004 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:11,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_20160114180510964_0041
2016-01-14 18:22:11,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0041
2016-01-14 18:22:11,677 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:12,416 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:13,644 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:14,145 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:14,152 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:36,770 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-01-14 18:22:36,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 01:21.322
2016-01-14 18:22:36,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-01-14 18:22:36,826 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:22:36,827 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:22:36,898 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:36,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-14 18:22:36,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:22:36,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:22:36,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 18:22:36,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:22:36,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:22:36,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:22:36,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:22:36,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-01-14 18:22:36,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2016-01-14 18:22:36,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 1
2016-01-14 18:22:36,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 1
2016-01-14 18:22:36,941 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-01-14 18:22:37,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_20160114180510964_0042
2016-01-14 18:22:37,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0042
2016-01-14 18:22:37,214 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0041 being deleted.
2016-01-14 18:22:37,647 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:38,548 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:39,607 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:22:40,684 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:13,224 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-01-14 18:23:13,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:36.285
2016-01-14 18:23:13,254 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-01-14 18:23:13,293 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:23:13,293 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:23:13,322 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 18:23:13,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:23:13,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:23:13,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:23:13,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-01-14 18:23:13,559 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:13,625 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:13,717 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:13,927 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:14,024 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:14,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0043
2016-01-14 18:23:14,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0043
2016-01-14 18:23:15,458 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:15,783 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0042 being deleted.
2016-01-14 18:23:15,947 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:40,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-01-14 18:23:40,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.881
2016-01-14 18:23:40,247 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0043 being deleted.
2016-01-14 18:23:40,258 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinInner/joininner
2016-01-14 18:23:40,277 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:23:40,278 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:23:40,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 18:23:40,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 18:23:40,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:23:40,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 18:23:40,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs.txt"]
2016-01-14 18:23:40,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:23:40,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-01-14 18:23:40,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-01-14 18:23:40,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2016-01-14 18:23:40,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2016-01-14 18:23:40,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2016-01-14 18:23:40,348 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...latform/testJoinSplit/rhs
2016-01-14 18:23:40,348 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...latform/testJoinSplit/lhs
2016-01-14 18:23:40,881 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:40,887 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0045
2016-01-14 18:23:40,888 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0045
2016-01-14 18:23:41,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_20160114180510964_0044
2016-01-14 18:23:41,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0044
2016-01-14 18:23:41,535 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:41,539 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:42,475 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:23:43,515 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:07,742 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0045 being deleted.
2016-01-14 18:24:08,264 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:08,835 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:09,371 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0045 being deleted.
2016-01-14 18:24:10,761 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-01-14 18:24:10,762 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-01-14 18:24:10,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:30.417
2016-01-14 18:24:10,808 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSplit/rhs
2016-01-14 18:24:10,817 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSplit/lhs
2016-01-14 18:24:10,834 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:24:10,834 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:24:10,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-01-14 18:24:10,926 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 18:24:10,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:24:10,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-14 18:24:10,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:24:10,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-01-14 18:24:10,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-01-14 18:24:10,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 2
2016-01-14 18:24:10,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 2
2016-01-14 18:24:10,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/2)
2016-01-14 18:24:11,174 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:11,315 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:11,436 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:11,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_20160114180510964_0046
2016-01-14 18:24:11,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0046
2016-01-14 18:24:11,929 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:12,502 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:13,242 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0044 being deleted.
2016-01-14 18:24:13,442 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:13,706 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0044 being deleted.
2016-01-14 18:24:48,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-01-14 18:24:48,916 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:49,381 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:49,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_20160114180510964_0047
2016-01-14 18:24:49,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0047
2016-01-14 18:24:49,774 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0046 being deleted.
2016-01-14 18:24:49,802 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:50,131 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:50,206 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:24:50,280 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:16,767 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-01-14 18:25:16,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 01:05.818
2016-01-14 18:25:16,787 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0047 being deleted.
2016-01-14 18:25:16,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-01-14 18:25:16,834 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:25:16,834 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:25:16,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-14 18:25:16,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 18:25:16,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:25:16,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2016-01-14 18:25:16,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:25:16,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:25:16,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-01-14 18:25:16,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] parallel execution of steps is enabled: true
2016-01-14 18:25:16,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executing total steps: 3
2016-01-14 18:25:16,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] allocating management threads: 3
2016-01-14 18:25:16,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/3)
2016-01-14 18:25:16,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/3)
2016-01-14 18:25:17,126 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:17,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_20160114180510964_0049
2016-01-14 18:25:17,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0049
2016-01-14 18:25:17,702 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:18,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_20160114180510964_0048
2016-01-14 18:25:18,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0048
2016-01-14 18:25:18,960 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:19,469 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:20,370 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:20,454 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:25,552 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:31,661 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:36,891 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:51,905 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:58,326 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:58,698 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:58,811 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0049 being deleted.
2016-01-14 18:25:59,206 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:25:59,396 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:00,281 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:02,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-01-14 18:26:02,574 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:02,602 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:02,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_20160114180510964_0050
2016-01-14 18:26:02,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0050
2016-01-14 18:26:03,655 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:04,875 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:21,936 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-01-14 18:26:21,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] completed in: 01:05.010
2016-01-14 18:26:21,960 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-01-14 18:26:22,322 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:22,324 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0050 being deleted.
2016-01-14 18:26:22,792 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:26:22,792 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:26:22,831 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.036
2016-01-14 18:26:22,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 18:26:22,833 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-01-14 18:26:22,840 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:26:22,841 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:26:22,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 18:26:22,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:26:22,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:26:22,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 18:26:22,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:26:22,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-01-14 18:26:22,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-14 18:26:22,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-14 18:26:22,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-14 18:26:22,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-01-14 18:26:22,947 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:23,208 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0050 being deleted.
2016-01-14 18:26:23,209 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0050 being deleted.
2016-01-14 18:26:23,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_20160114180510964_0051
2016-01-14 18:26:23,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0051
2016-01-14 18:26:38,383 ERROR datanode.DataNode (DataXceiver.java:run(131)) - DatanodeRegistration(127.0.0.1:58425, storageID=DS-21251633-10.16.231.248-58425-1452794710368, infoPort=49397, ipcPort=57980):DataXceiver
org.apache.hadoop.hdfs.server.datanode.BlockAlreadyExistsException: Block blk_9188893821797133895_1587 is valid, and cannot be written to.
at org.apache.hadoop.hdfs.server.datanode.FSDataset.writeToBlock(FSDataset.java:1402)
at org.apache.hadoop.hdfs.server.datanode.BlockReceiver.<init>(BlockReceiver.java:99)
at org.apache.hadoop.hdfs.server.datanode.DataXceiver.writeBlock(DataXceiver.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataXceiver.run(DataXceiver.java:107)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 18:26:50,647 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-01-14 18:26:50,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:27.772
2016-01-14 18:26:50,686 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-01-14 18:26:50,706 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:26:50,706 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:26:50,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 18:26:50,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:26:50,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:26:50,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2016-01-14 18:26:50,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:26:50,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-01-14 18:26:50,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] parallel execution of steps is enabled: true
2016-01-14 18:26:50,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executing total steps: 1
2016-01-14 18:26:50,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] allocating management threads: 1
2016-01-14 18:26:50,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-01-14 18:26:51,046 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:51,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_20160114180510964_0052
2016-01-14 18:26:51,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0052
2016-01-14 18:26:52,197 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:52,485 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:53,225 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0051 being deleted.
2016-01-14 18:26:53,248 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:53,420 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:26:53,491 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:18,084 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-01-14 18:27:18,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] completed in: 00:27.346
2016-01-14 18:27:18,118 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-01-14 18:27:18,137 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:27:18,137 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:27:18,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 18:27:18,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:27:18,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:27:18,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:27:18,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:27:18,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:27:18,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-01-14 18:27:18,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:27:18,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:27:18,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:27:18,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-01-14 18:27:18,495 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:18,970 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0052 being deleted.
2016-01-14 18:27:19,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0053
2016-01-14 18:27:19,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0053
2016-01-14 18:27:19,622 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:20,364 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:20,385 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:20,594 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:50,281 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-01-14 18:27:50,283 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.092
2016-01-14 18:27:50,310 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-01-14 18:27:50,322 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:27:50,323 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:27:50,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 18:27:50,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:27:50,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:27:50,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 18:27:50,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:27:50,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-01-14 18:27:50,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-14 18:27:50,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-14 18:27:50,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-14 18:27:50,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-01-14 18:27:50,433 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:50,856 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:50,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_20160114180510964_0054
2016-01-14 18:27:50,861 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0054
2016-01-14 18:27:51,238 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:51,547 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:51,821 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:27:52,378 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0053 being deleted.
2016-01-14 18:27:52,403 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:16,816 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-01-14 18:28:16,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:26.460
2016-01-14 18:28:16,853 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-01-14 18:28:16,872 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:28:16,873 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:28:16,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-01-14 18:28:16,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-01-14 18:28:16,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:28:17,000 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting
2016-01-14 18:28:17,000 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:28:17,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-01-14 18:28:17,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] parallel execution of steps is enabled: true
2016-01-14 18:28:17,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] executing total steps: 4
2016-01-14 18:28:17,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] allocating management threads: 4
2016-01-14 18:28:17,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (1/4)
2016-01-14 18:28:17,203 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:17,294 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0054 being deleted.
2016-01-14 18:28:17,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_20160114180510964_0055
2016-01-14 18:28:17,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0055
2016-01-14 18:28:18,231 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:19,142 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:19,142 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:19,259 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:19,819 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:55,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (2/4)
2016-01-14 18:28:55,380 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:55,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_20160114180510964_0056
2016-01-14 18:28:55,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0056
2016-01-14 18:28:55,581 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:56,121 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:56,418 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:56,672 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:57,050 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:28:57,137 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0055 being deleted.
2016-01-14 18:29:26,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (3/4)
2016-01-14 18:29:26,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_20160114180510964_0057
2016-01-14 18:29:26,841 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0057
2016-01-14 18:29:27,150 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0056 being deleted.
2016-01-14 18:29:27,293 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:28,073 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0056 being deleted.
2016-01-14 18:29:28,179 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:28,248 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:28,851 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0056 being deleted.
2016-01-14 18:29:58,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-01-14 18:29:58,519 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:58,545 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:58,864 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0057 being deleted.
2016-01-14 18:29:59,142 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:29:59,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_20160114180510964_0058
2016-01-14 18:29:59,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0058
2016-01-14 18:29:59,764 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0057 being deleted.
2016-01-14 18:30:00,167 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0057 being deleted.
2016-01-14 18:30:18,615 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-01-14 18:30:18,617 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] completed in: 02:01.598
2016-01-14 18:30:18,634 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-01-14 18:30:18,648 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:30:18,648 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:30:18,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 18:30:18,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:30:18,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:30:18,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:30:18,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-14 18:30:18,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-14 18:30:18,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-01-14 18:30:18,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:30:18,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:30:18,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:30:18,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-01-14 18:30:19,113 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0058 being deleted.
2016-01-14 18:30:19,146 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:30:19,875 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0058 being deleted.
2016-01-14 18:30:19,888 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:30:19,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0059
2016-01-14 18:30:19,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0059
2016-01-14 18:30:20,773 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0058 being deleted.
2016-01-14 18:30:46,153 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-01-14 18:30:46,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:27.463
2016-01-14 18:30:46,187 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-01-14 18:30:46,207 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:30:46,207 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 18:30:46,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 18:30:46,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 18:30:46,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/upper.txt"]
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/lower.txt"]
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:30:46,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:30:46,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-01-14 18:30:47,070 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:30:47,519 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:30:47,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_20160114180510964_0060
2016-01-14 18:30:47,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:41646/jobdetails.jsp?jobid=job_20160114180510964_0060
2016-01-14 18:30:47,785 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20160114180510964_0059 being deleted.
2016-01-14 18:30:47,874 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:30:48,757 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2016-01-14 18:31:13,197 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-01-14 18:31:13,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.950
2016-01-14 18:31:13,229 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/joinfieldedpipesplatform/testJoinDiffFields/difffields