Class cascading.FieldedPipesPlatformTest

29

tests

0

failures

0

ignored

12m2.19s

duration

100%

successful

Tests

Test Duration Result
testChainEndingWithEach 22.087s passed
testConcatenation 23.655s passed
testCopy 12.096s passed
testFilter 10.412s passed
testFilterAll 43.260s passed
testFilterComplex 29.282s passed
testGeneratorAggregator 21.790s passed
testGroupByInsensitive 27.178s passed
testGroupGroup 41.962s passed
testLogicFilter 12.342s passed
testNoGroup 12.101s passed
testNone 22.211s passed
testReplace 11.773s passed
testSameSourceMergeThreeChainGroup 49.313s passed
testSimpleChain 21.888s passed
testSimpleGroup 23.329s passed
testSimpleMerge 24.598s passed
testSimpleMergeThree 27.014s passed
testSplit 15.796s passed
testSplitComplex 36.195s passed
testSplitMultiple 59.132s passed
testSplitNonSafe 28.815s passed
testSplitOut 47.036s passed
testSplitSameSourceMerged 22.265s passed
testSplitSameSourceMergedSameName 21.779s passed
testSwap 22.693s passed
testUnGroup 10.287s passed
testUnGroupAnon 10.281s passed
testUnGroupBySize 11.617s passed

Standard output

2016-01-14 23:13:56,609 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 23:13:56,625 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop
2016-01-14 23:13:56,655 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(144)) - using cluster
2016-01-14 23:13:57,481 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 23:13:58,467 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 23:13:58,469 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:518)
	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:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:13:58,600 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Starting DataNode 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2016-01-14 23:13:58,910 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 23:13:58,910 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:518)
	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:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:13:58,993 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:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2016-01-14 23:13:59,215 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 23:13:59,216 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:518)
	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:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:13:59,289 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:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2016-01-14 23:13:59,495 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 23:13:59,495 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:518)
	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:1650)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:13:59,561 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:581)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:422)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:321)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1712)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1626)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java:180)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:161)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2016-01-14 23:13:59,852 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 23:13:59,853 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:518)
	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:316)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:311)
	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:1190)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:14:00,885 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 23:14:01,173 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 23:14:01,457 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 23:14:01,661 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2016-01-14 23:14:02,884 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 23:14:02,980 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:14:02,982 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 23:14:03,056 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 25D01C71751D4364B311E07588F12752
2016-01-14 23:14:03,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.124
2016-01-14 23:14:03,226 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:14:03,227 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:14:03,368 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 23:14:03,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:14:03,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:14:03,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-01-14 23:14:03,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:14:03,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:14:03,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:14:03,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-01-14 23:14:03,466 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 23:14:03,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0001
2016-01-14 23:14:03,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0001
2016-01-14 23:14:25,876 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2016-01-14 23:14:25,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:22.501
2016-01-14 23:14:25,925 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-01-14 23:14:25,961 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:14:25,961 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 23:14:26,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-14 23:14:26,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:14:26,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:14:26,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:14:26,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:14:26,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-01-14 23:14:26,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:14:26,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:14:26,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:14:26,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-01-14 23:14:26,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0002
2016-01-14 23:14:26,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0002
2016-01-14 23:14:26,961 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:27,478 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:28,637 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:28,678 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:28,860 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:28,879 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:29,019 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:47,782 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-14 23:14:47,783 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:21.700
2016-01-14 23:14:47,811 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSimpleChain/simplechain
2016-01-14 23:14:47,841 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:14:47,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 23:14:47,919 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-01-14 23:14:47,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:14:47,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:14:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:14:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:14:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleGroup/simple"]
2016-01-14 23:14:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:14:47,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:14:47,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:14:47,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-01-14 23:14:48,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0003
2016-01-14 23:14:48,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0003
2016-01-14 23:14:49,131 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0002 being deleted.
2016-01-14 23:14:49,545 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:49,626 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:49,934 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:50,126 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:50,208 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:50,360 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:50,905 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:50,956 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:14:51,068 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:11,102 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2016-01-14 23:15:11,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:23.161
2016-01-14 23:15:11,144 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSimpleGroup/simple
2016-01-14 23:15:11,191 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:15:11,191 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 23:15:11,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 23:15:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:15:11,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:15:11,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 23:15:11,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 23:15:11,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 23:15:11,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-01-14 23:15:11,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 23:15:11,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 23:15:11,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 23:15:11,284 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-14 23:15:11,433 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0003 being deleted.
2016-01-14 23:15:11,559 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:11,584 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:11,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_20160114231359793_0004
2016-01-14 23:15:11,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0004
2016-01-14 23:15:11,885 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:12,049 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:12,179 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:12,356 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:12,949 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:13,099 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:35,715 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2016-01-14 23:15:35,716 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:24.432
2016-01-14 23:15:35,746 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-01-14 23:15:35,874 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:15:35,874 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 23:15:35,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 23:15:35,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:15:35,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:15:35,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:15:35,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:15:35,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-01-14 23:15:35,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:15:35,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:15:35,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:15:35,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-01-14 23:15:36,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0005
2016-01-14 23:15:36,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0005
2016-01-14 23:15:36,750 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:37,260 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:37,610 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:37,665 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,100 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,126 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,293 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,301 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,401 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:38,774 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:57,815 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2016-01-14 23:15:57,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:21.853
2016-01-14 23:15:57,832 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-01-14 23:15:57,850 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:15:57,851 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 23:15:57,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 23:15:57,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:15:57,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:15:57,916 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:15:57,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:15:57,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-01-14 23:15:57,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:15:57,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:15:57,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:15:57,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-01-14 23:15:59,164 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0005 being deleted.
2016-01-14 23:15:59,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0006
2016-01-14 23:15:59,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0006
2016-01-14 23:15:59,698 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:15:59,905 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:00,703 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:00,813 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:00,865 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:00,949 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:01,134 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:01,235 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:01,340 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:19,603 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2016-01-14 23:16:19,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:21.684
2016-01-14 23:16:19,621 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-01-14 23:16:19,637 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0006 being deleted.
2016-01-14 23:16:20,055 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:16:20,055 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 23:16:20,132 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:20,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.102
2016-01-14 23:16:20,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:16:20,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:16:20,185 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:20,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 23:16:20,201 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 23:16:20,201 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 23:16:20,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 23:16:20,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-14 23:16:20,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 23:16:20,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 23:16:20,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 23:16:20,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-14 23:16:20,282 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:21,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_20160114231359793_0007
2016-01-14 23:16:21,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0007
2016-01-14 23:16:21,874 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:22,044 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:22,054 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:22,230 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:22,330 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:46,606 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-01-14 23:16:46,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:26.406
2016-01-14 23:16:46,636 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-01-14 23:16:46,655 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:16:46,656 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 23:16:46,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2016-01-14 23:16:46,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 23:16:46,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:16:46,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 23:16:46,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:16:46,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-01-14 23:16:46,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-01-14 23:16:46,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 23:16:46,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2016-01-14 23:16:46,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2016-01-14 23:16:46,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2016-01-14 23:16:47,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0008
2016-01-14 23:16:47,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0008
2016-01-14 23:16:47,962 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:47,980 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,104 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,220 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,269 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,314 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,402 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,439 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,502 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:48,696 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:49,251 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:59,010 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2016-01-14 23:16:59,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2016-01-14 23:16:59,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0009
2016-01-14 23:16:59,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0009
2016-01-14 23:16:59,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0010
2016-01-14 23:16:59,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0010
2016-01-14 23:16:59,642 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0008 being deleted.
2016-01-14 23:16:59,760 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:59,770 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:16:59,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:00,015 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:00,157 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:00,409 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:05,725 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:13,793 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:15,047 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:15,065 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:15,176 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0009 being deleted.
2016-01-14 23:17:15,398 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2016-01-14 23:17:15,399 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2016-01-14 23:17:15,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:28.634
2016-01-14 23:17:15,429 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-01-14 23:17:15,449 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-01-14 23:17:15,476 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:17:15,477 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 23:17:15,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-01-14 23:17:15,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 23:17:15,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:17:15,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting
2016-01-14 23:17:15,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:17:15,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitOut/splitout2"]
2016-01-14 23:17:15,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitOut/splitout1"]
2016-01-14 23:17:15,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  parallel execution of steps is enabled: true
2016-01-14 23:17:15,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  executing total steps: 3
2016-01-14 23:17:15,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  allocating management threads: 3
2016-01-14 23:17:15,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (1/3)
2016-01-14 23:17:15,644 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0010 being deleted.
2016-01-14 23:17:16,259 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:16,692 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:16,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_20160114231359793_0011
2016-01-14 23:17:16,911 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0011
2016-01-14 23:17:17,455 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0010 being deleted.
2016-01-14 23:17:18,006 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:18,373 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:38,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout1
2016-01-14 23:17:38,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout2
2016-01-14 23:17:38,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_20160114231359793_0012
2016-01-14 23:17:38,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0012
2016-01-14 23:17:39,169 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:39,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_20160114231359793_0013
2016-01-14 23:17:39,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0013
2016-01-14 23:17:39,705 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:39,880 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0011 being deleted.
2016-01-14 23:17:39,884 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:40,069 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:40,147 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:40,718 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:41,069 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:42,264 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:53,926 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:54,639 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:55,935 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:17:56,625 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:02,426 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2016-01-14 23:18:02,428 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2016-01-14 23:18:02,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  completed in: 00:46.839
2016-01-14 23:18:02,483 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitOut/splitout2
2016-01-14 23:18:02,490 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitOut/splitout1
2016-01-14 23:18:02,526 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:18:02,527 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 23:18:02,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 23:18:02,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 23:18:02,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:18:02,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 23:18:02,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:18:02,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplit/split1"]
2016-01-14 23:18:02,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplit/split2"]
2016-01-14 23:18:02,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 23:18:02,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 2
2016-01-14 23:18:02,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 2
2016-01-14 23:18:02,593 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/2) ...platform/testSplit/split2
2016-01-14 23:18:02,593 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/2) ...platform/testSplit/split1
2016-01-14 23:18:03,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0015
2016-01-14 23:18:03,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0015
2016-01-14 23:18:03,357 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:03,804 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:03,836 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:03,882 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0013 being deleted.
2016-01-14 23:18:03,893 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:03,947 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:03,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0014
2016-01-14 23:18:03,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0014
2016-01-14 23:18:04,633 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:08,759 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:17,675 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:17,883 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0015 being deleted.
2016-01-14 23:18:18,218 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:18,247 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplit/split2/_temporary
2016-01-14 23:18:18,248 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplit/split1/_temporary
2016-01-14 23:18:18,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:15.655
2016-01-14 23:18:18,277 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplit/split2
2016-01-14 23:18:18,287 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplit/split1
2016-01-14 23:18:18,304 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:18:18,304 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 23:18:18,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 23:18:18,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:18:18,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:18:18,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 23:18:18,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:18:18,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-14 23:18:18,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2016-01-14 23:18:18,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2016-01-14 23:18:18,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2016-01-14 23:18:18,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-14 23:18:18,506 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:18,513 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:19,191 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0014 being deleted.
2016-01-14 23:18:19,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_20160114231359793_0016
2016-01-14 23:18:19,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0016
2016-01-14 23:18:19,462 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0014 being deleted.
2016-01-14 23:18:19,878 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:19,997 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:20,500 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:21,132 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:40,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-01-14 23:18:40,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:22.164
2016-01-14 23:18:40,553 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-14 23:18:40,568 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:18:40,568 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 23:18:40,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 23:18:40,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:18:40,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:18:40,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:18:40,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:18:40,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testCopy/copy"]
2016-01-14 23:18:40,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:18:40,600 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:18:40,600 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:18:40,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-01-14 23:18:41,193 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0016 being deleted.
2016-01-14 23:18:41,831 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:41,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0017
2016-01-14 23:18:41,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0017
2016-01-14 23:18:41,978 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,022 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,180 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,226 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,670 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,814 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:42,979 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:52,626 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testCopy/copy/_temporary
2016-01-14 23:18:52,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:12.026
2016-01-14 23:18:52,644 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testCopy/copy
2016-01-14 23:18:52,667 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:18:52,667 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 23:18:52,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 23:18:52,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:18:52,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:18:52,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:18:52,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:18:52,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testNone/none"]
2016-01-14 23:18:52,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:18:52,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:18:52,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:18:52,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-01-14 23:18:53,417 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:53,460 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:53,656 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0017 being deleted.
2016-01-14 23:18:53,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0018
2016-01-14 23:18:53,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0018
2016-01-14 23:18:54,071 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:54,155 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:18:55,404 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:14,806 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testNone/none/_temporary
2016-01-14 23:19:14,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:22.078
2016-01-14 23:19:14,861 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testNone/none
2016-01-14 23:19:14,878 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:19:14,878 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 23:19:14,914 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 23:19:14,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:19:14,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:19:14,933 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:19:14,933 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:19:14,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSwap/swap"]
2016-01-14 23:19:14,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:19:14,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:19:14,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:19:14,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-14 23:19:15,838 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:15,889 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0018 being deleted.
2016-01-14 23:19:16,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0019
2016-01-14 23:19:16,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0019
2016-01-14 23:19:16,404 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:16,445 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:16,476 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:16,481 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:16,533 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:16,945 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:17,023 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:37,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSwap/swap/_temporary
2016-01-14 23:19:37,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:22.604
2016-01-14 23:19:37,554 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSwap/swap
2016-01-14 23:19:37,571 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:19:37,572 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 23:19:37,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 23:19:37,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:19:37,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:19:37,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:19:37,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-01-14 23:19:37,976 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:38,386 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:39,033 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:39,113 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:39,199 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0019 being deleted.
2016-01-14 23:19:39,226 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:39,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0020
2016-01-14 23:19:39,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0020
2016-01-14 23:19:39,771 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:39,772 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:40,533 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:49,877 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2016-01-14 23:19:49,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:12.269
2016-01-14 23:19:49,893 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testLogicFilter/logicfilter
2016-01-14 23:19:49,923 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:19:49,923 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 23:19:49,952 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 23:19:49,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:19:49,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:19:49,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:19:49,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 23:19:49,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-01-14 23:19:49,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:19:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:19:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:19:49,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-14 23:19:50,155 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:50,497 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:51,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0021
2016-01-14 23:19:51,279 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0021
2016-01-14 23:19:51,413 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:51,464 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:51,662 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0020 being deleted.
2016-01-14 23:19:51,786 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:19:52,043 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:00,150 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-14 23:20:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:10.187
2016-01-14 23:20:00,168 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testUnGroup/ungrouped
2016-01-14 23:20:00,201 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:20:00,201 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 23:20:00,259 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 23:20:00,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 23:20:00,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:20:00,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:20:00,295 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:20:00,295 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilterAll/filterall"]
2016-01-14 23:20:00,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:20:00,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2016-01-14 23:20:00,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2016-01-14 23:20:00,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 23:20:01,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0022
2016-01-14 23:20:01,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0022
2016-01-14 23:20:01,663 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0021 being deleted.
2016-01-14 23:20:01,664 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:02,261 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:03,066 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:03,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:22,733 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2016-01-14 23:20:23,511 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:23,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0023
2016-01-14 23:20:23,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0023
2016-01-14 23:20:23,665 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0022 being deleted.
2016-01-14 23:20:23,780 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:24,339 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:24,396 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:24,516 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:24,678 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:24,877 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:25,126 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:43,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilterAll/filterall/_temporary
2016-01-14 23:20:43,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:43.138
2016-01-14 23:20:43,448 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testFilterAll/filterall
2016-01-14 23:20:43,461 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:20:43,461 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 23:20:43,501 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 23:20:43,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:20:43,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:20:43,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 23:20:43,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:20:43,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-01-14 23:20:43,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2016-01-14 23:20:43,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2016-01-14 23:20:43,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2016-01-14 23:20:43,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-01-14 23:20:43,868 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,285 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,364 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,420 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,445 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_20160114231359793_0024
2016-01-14 23:20:44,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0024
2016-01-14 23:20:44,522 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:44,577 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:45,150 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:20:45,208 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0023 being deleted.
2016-01-14 23:21:05,208 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2016-01-14 23:21:05,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:21.690
2016-01-14 23:21:05,224 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-01-14 23:21:05,242 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:05,243 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 23:21:05,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 23:21:05,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:05,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:21:05,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting
2016-01-14 23:21:05,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-01-14 23:21:05,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 23:21:05,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-01-14 23:21:05,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  parallel execution of steps is enabled: true
2016-01-14 23:21:05,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  executing total steps: 1
2016-01-14 23:21:05,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  allocating management threads: 1
2016-01-14 23:21:05,309 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-01-14 23:21:05,418 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:05,486 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0024 being deleted.
2016-01-14 23:21:05,558 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,016 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,153 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,506 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,696 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,773 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:06,862 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:07,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] submitted hadoop job: job_20160114231359793_0025
2016-01-14 23:21:07,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0025
2016-01-14 23:21:07,266 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:32,383 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2016-01-14 23:21:32,387 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  completed in: 00:27.075
2016-01-14 23:21:32,402 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-01-14 23:21:32,419 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:32,420 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 23:21:32,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 23:21:32,448 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:21:32,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:21:32,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:32,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 23:21:32,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-01-14 23:21:32,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:21:32,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:21:32,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:21:32,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-01-14 23:21:33,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0026
2016-01-14 23:21:33,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0026
2016-01-14 23:21:33,692 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:33,839 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:33,868 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:34,072 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:34,182 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:34,264 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:34,836 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:35,171 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:35,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:35,391 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:42,664 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2016-01-14 23:21:42,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:10.205
2016-01-14 23:21:42,682 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-01-14 23:21:42,700 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:42,701 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 23:21:42,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 23:21:42,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 23:21:42,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:21:42,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:42,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:21:42,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-01-14 23:21:42,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:21:42,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2016-01-14 23:21:42,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2016-01-14 23:21:42,783 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 23:21:43,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0027
2016-01-14 23:21:43,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0027
2016-01-14 23:21:43,374 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:43,491 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0026 being deleted.
2016-01-14 23:21:43,651 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:44,509 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:21:44,838 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:04,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2016-01-14 23:22:05,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0028
2016-01-14 23:22:05,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0028
2016-01-14 23:22:05,399 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:05,610 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:05,831 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:05,974 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:06,024 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:06,230 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:06,358 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:06,582 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:07,220 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:24,633 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2016-01-14 23:22:24,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:41.851
2016-01-14 23:22:24,647 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testGroupGroup/groupgroup
2016-01-14 23:22:24,663 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:22:24,663 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 23:22:24,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 23:22:24,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 23:22:24,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:22:24,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting
2016-01-14 23:22:24,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-01-14 23:22:24,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-14 23:22:24,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  parallel execution of steps is enabled: true
2016-01-14 23:22:24,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  executing total steps: 2
2016-01-14 23:22:24,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  allocating management threads: 2
2016-01-14 23:22:24,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (1/2)
2016-01-14 23:22:25,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_20160114231359793_0029
2016-01-14 23:22:25,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0029
2016-01-14 23:22:25,495 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0028 being deleted.
2016-01-14 23:22:25,548 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:25,907 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:26,232 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:26,560 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:27,011 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:27,096 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:27,354 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:47,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2016-01-14 23:22:48,087 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:48,341 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_20160114231359793_0030
2016-01-14 23:22:48,341 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0030
2016-01-14 23:22:48,435 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:49,099 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:49,730 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:50,398 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:50,692 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:50,707 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:50,963 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:22:51,212 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:13,944 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-01-14 23:23:13,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  completed in: 00:49.180
2016-01-14 23:23:13,960 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-14 23:23:13,977 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:23:13,978 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 23:23:14,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 23:23:14,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:23:14,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testReplace/replace"]
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:23:14,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:23:14,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-14 23:23:14,261 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:15,096 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:15,450 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:15,464 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:15,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0031
2016-01-14 23:23:15,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0031
2016-01-14 23:23:15,781 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,261 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,346 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,583 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,651 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,651 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:16,848 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:25,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testReplace/replace/_temporary
2016-01-14 23:23:25,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:11.694
2016-01-14 23:23:25,730 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testReplace/replace
2016-01-14 23:23:25,940 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0031 being deleted.
2016-01-14 23:23:26,158 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:23:26,159 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 23:23:26,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 23:23:26,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:23:26,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:23:26,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:23:26,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/extra+lower+upper.txt"]
2016-01-14 23:23:26,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-01-14 23:23:26,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:23:26,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:23:26,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:23:26,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-01-14 23:23:27,270 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:27,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0032
2016-01-14 23:23:27,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0032
2016-01-14 23:23:27,930 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:28,409 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:29,128 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:29,287 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:37,330 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2016-01-14 23:23:37,332 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:11.136
2016-01-14 23:23:37,348 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-01-14 23:23:37,365 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:23:37,365 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 23:23:37,389 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 23:23:37,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:23:37,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:23:37,396 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:23:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:23:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilter/filter"]
2016-01-14 23:23:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:23:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:23:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:23:37,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-14 23:23:37,934 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:37,941 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0032 being deleted.
2016-01-14 23:23:37,944 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:38,037 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:38,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0033
2016-01-14 23:23:38,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0033
2016-01-14 23:23:39,633 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:40,017 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:47,747 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testFilter/filter/_temporary
2016-01-14 23:23:47,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:10.350
2016-01-14 23:23:47,762 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testFilter/filter
2016-01-14 23:23:47,781 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:23:47,781 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 23:23:47,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-01-14 23:23:47,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2016-01-14 23:23:47,880 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:23:47,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting
2016-01-14 23:23:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:23:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/left"]
2016-01-14 23:23:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-01-14 23:23:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-01-14 23:23:47,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  parallel execution of steps is enabled: true
2016-01-14 23:23:47,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  executing total steps: 5
2016-01-14 23:23:47,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  allocating management threads: 5
2016-01-14 23:23:47,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (1/5)
2016-01-14 23:23:48,156 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:49,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_20160114231359793_0034
2016-01-14 23:23:49,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0034
2016-01-14 23:23:49,387 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:49,504 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0033 being deleted.
2016-01-14 23:23:49,960 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:50,054 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:23:50,125 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:10,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (2/5) ...rm/testSplitMultiple/left
2016-01-14 23:24:10,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (3/5)
2016-01-14 23:24:10,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_20160114231359793_0036
2016-01-14 23:24:10,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0036
2016-01-14 23:24:11,341 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:11,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_20160114231359793_0035
2016-01-14 23:24:11,430 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0035
2016-01-14 23:24:11,753 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,152 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,203 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,207 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,228 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,726 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:12,944 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:14,764 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:24,318 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:25,507 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0035 being deleted.
2016-01-14 23:24:25,572 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:25,707 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0035 being deleted.
2016-01-14 23:24:25,721 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:34,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (5/5) ...tSplitMultiple/rightright
2016-01-14 23:24:34,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (4/5) ...stSplitMultiple/rightleft
2016-01-14 23:24:34,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_20160114231359793_0038
2016-01-14 23:24:34,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0038
2016-01-14 23:24:34,979 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:35,241 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0036 being deleted.
2016-01-14 23:24:35,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_20160114231359793_0037
2016-01-14 23:24:35,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0037
2016-01-14 23:24:35,712 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:35,937 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:36,866 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:36,998 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:37,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:39,242 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:46,849 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/left/_temporary
2016-01-14 23:24:46,852 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2016-01-14 23:24:46,853 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2016-01-14 23:24:46,855 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  completed in: 00:58.923
2016-01-14 23:24:46,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitMultiple/left
2016-01-14 23:24:46,892 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitMultiple/rightright
2016-01-14 23:24:46,897 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitMultiple/rightleft
2016-01-14 23:24:46,912 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:24:46,913 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 23:24:46,945 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 23:24:46,945 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:24:46,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/upper.txt"]]]
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  parallel execution of steps is enabled: true
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  executing total steps: 1
2016-01-14 23:24:46,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  allocating management threads: 1
2016-01-14 23:24:46,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-01-14 23:24:47,253 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0037 being deleted.
2016-01-14 23:24:47,524 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:47,747 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:47,931 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:47,951 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0037 being deleted.
2016-01-14 23:24:48,315 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:48,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] submitted hadoop job: job_20160114231359793_0039
2016-01-14 23:24:48,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0039
2016-01-14 23:24:48,996 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:49,038 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:24:49,377 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:10,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2016-01-14 23:25:10,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  completed in: 00:23.578
2016-01-14 23:25:10,551 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testConcatenation/complexconcat
2016-01-14 23:25:10,567 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:25:10,568 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 23:25:10,640 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-14 23:25:10,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-01-14 23:25:10,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:25:10,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 23:25:10,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:25:10,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-01-14 23:25:10,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-01-14 23:25:10,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 23:25:10,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2016-01-14 23:25:10,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2016-01-14 23:25:10,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2016-01-14 23:25:11,257 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0039 being deleted.
2016-01-14 23:25:12,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0040
2016-01-14 23:25:12,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0040
2016-01-14 23:25:12,061 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:12,139 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:12,175 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:12,712 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:12,867 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:12,998 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:13,050 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:13,110 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:33,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2016-01-14 23:25:33,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2016-01-14 23:25:33,259 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0040 being deleted.
2016-01-14 23:25:33,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0041
2016-01-14 23:25:33,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0041
2016-01-14 23:25:34,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_20160114231359793_0042
2016-01-14 23:25:34,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0042
2016-01-14 23:25:34,027 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,222 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,306 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,307 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,362 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,391 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:34,439 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:35,123 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:37,045 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:46,710 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2016-01-14 23:25:46,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2016-01-14 23:25:46,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:36.026
2016-01-14 23:25:46,741 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-01-14 23:25:46,747 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-01-14 23:25:46,761 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:25:46,761 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 23:25:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 23:25:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:25:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:25:46,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:25:46,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:25:46,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testNoGroup/nogroup"]
2016-01-14 23:25:46,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 23:25:46,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 23:25:46,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:25:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-01-14 23:25:47,263 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0042 being deleted.
2016-01-14 23:25:47,717 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0041 being deleted.
2016-01-14 23:25:47,756 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:47,781 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:47,958 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20160114231359793_0042 being deleted.
2016-01-14 23:25:48,059 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:48,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_20160114231359793_0043
2016-01-14 23:25:48,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:58330/jobdetails.jsp?jobid=job_20160114231359793_0043
2016-01-14 23:25:48,269 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:48,382 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:48,628 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:48,726 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:49,129 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2016-01-14 23:25:58,804 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2016-01-14 23:25:58,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:12.011
2016-01-14 23:25:58,841 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/fieldedpipesplatform/testNoGroup/nogroup