Class cascading.cascade.CascadePlatformTest

8

tests

0

failures

2m30.39s

duration

100%

successful

Tests

Test Duration Result
testCascadeID 0.096s passed
testCheckpointTapCascade 49.124s passed
testMultiTapCascade 19.060s passed
testPlannerFailureDuplicateSinks 0.064s passed
testSimpleCascade 37.747s passed
testSimpleCascadeFail 28.309s passed
testSimpleCascadeStop 8.159s passed
testSkippedCascade 7.828s passed

Standard output

2015-08-14 00:21:28,885 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 00:21:28,934 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-14 00:21:28,934 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.CascadePlatformTest
2015-08-14 00:21:28,967 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-14 00:21:29,962 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties
Starting DataNode 0 with dfs.data.dir: build/test/data/dfs/data/data1,build/test/data/dfs/data/data2
2015-08-14 00:21:31,068 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:21:31,069 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:21:31,220 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
2015-08-14 00:21:31,644 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:21:31,645 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:21:31,722 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 2 with dfs.data.dir: build/test/data/dfs/data/data5,build/test/data/dfs/data/data6
2015-08-14 00:21:32,060 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:21:32,061 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:21:32,138 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Starting DataNode 3 with dfs.data.dir: build/test/data/dfs/data/data7,build/test/data/dfs/data/data8
2015-08-14 00:21:32,452 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-14 00:21:32,453 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:21:32,534 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo
javax.management.InstanceAlreadyExistsException: Hadoop:service=DataNode,name=DataNodeInfo
	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:453)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1484)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:963)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.registerMXBean(DataNode.java: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:164)
	at cascading.PlatformTestCase.setUp(PlatformTestCase.java:181)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
	at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:103)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:355)
	at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Cluster is active
Generating rack names for tasktrackers
Generating host names for tasktrackers
2015-08-14 00:21:32,922 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2015-08-14 00:21:32,923 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control
javax.management.InstanceAlreadyExistsException: MXBean already registered with name Hadoop:service=NameNode,name=MetricsSystem,sub=Control
	at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(MXBeanLookup.java:120)
	at com.sun.jmx.mbeanserver.MXBeanSupport.register(MXBeanSupport.java:143)
	at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(MBeanSupport.java:185)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:941)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:917)
	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312)
	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:483)
	at org.apache.hadoop.metrics2.util.MBeans.register(MBeans.java:56)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.initSystemMBean(MetricsSystemImpl.java: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:396)
	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:662)
2015-08-14 00:21:33,987 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:21:34,339 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:21:34,667 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:21:34,979 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4422)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-14 00:21:36,341 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 00:21:36,455 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,457 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,468 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 679C537E24D44FF99596941C5C462DBB
2015-08-14 00:21:36,644 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,644 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,686 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,687 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,725 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,725 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,763 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 00:21:36,764 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-08-14 00:21:36,770 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  parallel execution is enabled: true
2015-08-14 00:21:36,770 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  starting flows: 4
2015-08-14 00:21:36,771 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  allocating threads: 4
2015-08-14 00:21:36,772 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-08-14 00:21:36,775 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: first
2015-08-14 00:21:36,776 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: second
2015-08-14 00:21:36,777 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: second
2015-08-14 00:21:36,778 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: third
2015-08-14 00:21:36,779 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: third
2015-08-14 00:21:36,779 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: fourth
2015-08-14 00:21:36,780 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: fourth
2015-08-14 00:21:36,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/skipped/second
2015-08-14 00:21:36,788 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/skipped/fourth
2015-08-14 00:21:36,790 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/skipped/first
2015-08-14 00:21:36,791 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/skipped/third
2015-08-14 00:21:36,815 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,816 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,853 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,854 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,921 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:36,922 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:36,949 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting
2015-08-14 00:21:36,952 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  parallel execution is enabled: true
2015-08-14 00:21:36,952 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  starting flows: 3
2015-08-14 00:21:36,952 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  allocating threads: 3
2015-08-14 00:21:36,953 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: second
2015-08-14 00:21:36,953 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: first
2015-08-14 00:21:36,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 00:21:36,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 00:21:36,956 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:21:36,956 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:21:36,974 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 00:21:36,974 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 00:21:36,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:21:36,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:21:36,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/first"]
2015-08-14 00:21:36,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/second"]
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-08-14 00:21:36,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-08-14 00:21:36,979 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...eplatform/multitap/second
2015-08-14 00:21:36,979 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...deplatform/multitap/first
2015-08-14 00:21:37,087 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-14 00:21:37,431 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_20150814002132872_0001
2015-08-14 00:21:37,431 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0001
2015-08-14 00:21:37,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_20150814002132872_0002
2015-08-14 00:21:37,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0002
2015-08-14 00:21:45,985 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/second/_temporary
2015-08-14 00:21:45,987 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: second
2015-08-14 00:21:46,025 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/first/_temporary
2015-08-14 00:21:46,026 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: first
2015-08-14 00:21:46,027 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: multitap
2015-08-14 00:21:46,027 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] at least one sink is marked for delete
2015-08-14 00:21:46,027 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:21:46,034 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting
2015-08-14 00:21:46,034 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/first"], Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/second"]]]
2015-08-14 00:21:46,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/multitap"]
2015-08-14 00:21:46,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  parallel execution is enabled: true
2015-08-14 00:21:46,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  starting jobs: 1
2015-08-14 00:21:46,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  allocating threads: 1
2015-08-14 00:21:46,037 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] starting step: (1/1) ...latform/multitap/multitap
2015-08-14 00:21:46,217 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] submitted hadoop job: job_20150814002132872_0003
2015-08-14 00:21:46,217 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0003
2015-08-14 00:21:46,292 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0002 being deleted.
2015-08-14 00:21:46,625 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0001 being deleted.
2015-08-14 00:21:46,670 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:46,733 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:46,733 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:46,951 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0002 being deleted.
2015-08-14 00:21:47,305 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0001 being deleted.
2015-08-14 00:21:47,357 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:47,493 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:47,759 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:48,581 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:48,790 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:55,726 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/multitap/multitap/_temporary
2015-08-14 00:21:55,727 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: multitap
2015-08-14 00:21:55,785 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/multitap/multitap
2015-08-14 00:21:55,819 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/multitap/first
2015-08-14 00:21:55,837 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/multitap/second
2015-08-14 00:21:55,873 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:55,874 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:55,905 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:55,905 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:55,940 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:55,940 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:55,946 INFO  planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/third"]
2015-08-14 00:21:55,982 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:21:55,983 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:21:56,005 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting
2015-08-14 00:21:56,007 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  parallel execution is enabled: true
2015-08-14 00:21:56,008 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  starting flows: 4
2015-08-14 00:21:56,008 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  allocating threads: 4
2015-08-14 00:21:56,009 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: first
2015-08-14 00:21:56,009 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 00:21:56,010 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:21:56,014 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 00:21:56,015 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:21:56,015 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/first"]
2015-08-14 00:21:56,015 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-08-14 00:21:56,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-08-14 00:21:56,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-08-14 00:21:56,017 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...platform/checkpoint/first
2015-08-14 00:21:56,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_20150814002132872_0004
2015-08-14 00:21:56,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0004
2015-08-14 00:21:57,523 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:57,562 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:57,780 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:57,869 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:57,912 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:58,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:58,158 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:21:58,196 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:04,404 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/first/_temporary
2015-08-14 00:22:04,405 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: first
2015-08-14 00:22:04,406 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: second
2015-08-14 00:22:04,406 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 00:22:04,406 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:22:04,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 00:22:04,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/first"]
2015-08-14 00:22:04,411 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/second"]
2015-08-14 00:22:04,411 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-08-14 00:22:04,412 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-08-14 00:22:04,412 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-08-14 00:22:04,413 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...latform/checkpoint/second
2015-08-14 00:22:05,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_20150814002132872_0005
2015-08-14 00:22:05,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0005
2015-08-14 00:22:05,662 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:05,738 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:05,852 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:06,100 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:06,398 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:07,715 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:13,343 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/second/_temporary
2015-08-14 00:22:13,344 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: second
2015-08-14 00:22:13,345 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: null
2015-08-14 00:22:13,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] at least one sink is marked for delete
2015-08-14 00:22:13,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-14 00:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/second"]
2015-08-14 00:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/unusedpath"]
2015-08-14 00:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: true
2015-08-14 00:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 2
2015-08-14 00:22:13,353 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 2
2015-08-14 00:22:13,354 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...platform/checkpoint/third
2015-08-14 00:22:14,295 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_20150814002132872_0006
2015-08-14 00:22:14,296 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0006
2015-08-14 00:22:14,729 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:15,311 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0005 being deleted.
2015-08-14 00:22:15,383 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:15,471 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:15,607 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:16,350 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:22,273 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...ascadeplatform/unusedpath
2015-08-14 00:22:23,170 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:23,193 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:23,848 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:24,271 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:24,296 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:24,299 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0006 being deleted.
2015-08-14 00:22:24,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_20150814002132872_0007
2015-08-14 00:22:24,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0007
2015-08-14 00:22:24,636 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:33,872 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/third/_temporary
2015-08-14 00:22:33,874 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/unusedpath/_temporary
2015-08-14 00:22:33,875 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: null
2015-08-14 00:22:33,875 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: fourth
2015-08-14 00:22:33,875 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 00:22:33,876 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:22:33,879 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 00:22:33,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/third"]
2015-08-14 00:22:33,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/fourth"]
2015-08-14 00:22:33,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  parallel execution is enabled: true
2015-08-14 00:22:33,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  starting jobs: 1
2015-08-14 00:22:33,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  allocating threads: 1
2015-08-14 00:22:33,881 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...latform/checkpoint/fourth
2015-08-14 00:22:34,823 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_20150814002132872_0008
2015-08-14 00:22:34,824 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0008
2015-08-14 00:22:35,413 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,446 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,481 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,511 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,533 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,536 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:35,546 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:36,722 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:44,865 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/checkpoint/fourth/_temporary
2015-08-14 00:22:44,866 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: fourth
2015-08-14 00:22:44,895 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/checkpoint/third
2015-08-14 00:22:44,912 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/checkpoint/first
2015-08-14 00:22:44,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/unusedpath
2015-08-14 00:22:44,945 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/checkpoint/second
2015-08-14 00:22:44,961 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/checkpoint/fourth
2015-08-14 00:22:44,995 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:22:44,996 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:22:45,025 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:22:45,025 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:22:45,048 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:22:45,049 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:22:45,071 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:22:45,072 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:22:45,089 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-08-14 00:22:45,090 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  parallel execution is enabled: true
2015-08-14 00:22:45,090 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  starting flows: 4
2015-08-14 00:22:45,090 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  allocating threads: 4
2015-08-14 00:22:45,091 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-08-14 00:22:45,091 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 00:22:45,091 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/firsttestSimpleCascadeFail"]
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-08-14 00:22:45,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-08-14 00:22:45,096 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 00:22:45,373 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:45,622 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:45,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_20150814002132872_0009
2015-08-14 00:22:45,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0009
2015-08-14 00:22:45,955 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:45,995 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:46,615 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:47,203 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:47,309 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:22:47,374 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:13,267 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] hadoop job job_20150814002132872_0009 state at FAILED
2015-08-14 00:23:13,267 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] failure info: # of failed Map Tasks exceeded allowed limit. FailedCount: 1. LastFailedTask: task_20150814002132872_0009_m_000001
2015-08-14 00:23:13,270 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events identify failed tasks
2015-08-14 00:23:13,270 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events count: 10
2015-08-14 00:23:13,270 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000005_0, Status : SUCCEEDED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000000_0, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000001_0, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000002_0, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000003_0, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000000_1, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000001_1, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000002_1, Status : FAILED
2015-08-14 00:23:13,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000003_1, Status : FAILED
2015-08-14 00:23:13,272 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_20150814002132872_0009_m_000001_2, Status : FAILED
2015-08-14 00:23:13,273 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 00:23:13,274 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 00:23:13,274 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 00:23:13,277 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/firsttestSimpleCascadeFail/_temporary
2015-08-14 00:23:13,278 WARN  cascade.Cascade (Cascade.java:logWarn(1006)) - [fourth+second+third+first] flow failed: first
cascading.flow.FlowException: step failed: (1/1) ...irsttestSimpleCascadeFail, with job id: job_20150814002132872_0009, please see cluster logs for failure messages
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:261)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:162)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 00:23:13,278 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping all flows
2015-08-14 00:23:13,279 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: fourth
2015-08-14 00:23:13,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-08-14 00:23:13,280 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...urthtestSimpleCascadeFail
2015-08-14 00:23:13,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-08-14 00:23:13,280 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: third
2015-08-14 00:23:13,281 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-08-14 00:23:13,281 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...hirdtestSimpleCascadeFail
2015-08-14 00:23:13,281 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-08-14 00:23:13,281 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: second
2015-08-14 00:23:13,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-08-14 00:23:13,282 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...condtestSimpleCascadeFail
2015-08-14 00:23:13,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-08-14 00:23:13,283 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: first
2015-08-14 00:23:13,283 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 00:23:13,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 00:23:13,283 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 00:23:13,284 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopped all flows
2015-08-14 00:23:13,284 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/secondtestSimpleCascadeFail
2015-08-14 00:23:13,285 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/thirdtestSimpleCascadeFail
2015-08-14 00:23:13,286 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/fourthtestSimpleCascadeFail
2015-08-14 00:23:13,287 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/firsttestSimpleCascadeFail
2015-08-14 00:23:13,306 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:13,306 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:13,331 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:13,332 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:13,355 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:13,355 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:13,382 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:13,382 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
calling start
2015-08-14 00:23:13,402 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-08-14 00:23:13,403 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  parallel execution is enabled: true
2015-08-14 00:23:13,403 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  starting flows: 4
2015-08-14 00:23:13,403 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  allocating threads: 4
2015-08-14 00:23:13,404 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-08-14 00:23:13,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 00:23:13,405 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
testing if running
2015-08-14 00:23:13,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 00:23:13,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:23:13,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/stopped/first-nondeterministic"]
2015-08-14 00:23:13,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-08-14 00:23:13,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-08-14 00:23:13,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-08-14 00:23:13,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...ed/first-nondeterministic
testing if running
2015-08-14 00:23:14,781 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_20150814002132872_0010
2015-08-14 00:23:14,781 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0010
2015-08-14 00:23:14,904 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:15,338 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
calling stop
2015-08-14 00:23:21,411 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping all flows
2015-08-14 00:23:21,412 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: fourth
2015-08-14 00:23:21,412 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-08-14 00:23:21,412 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2015-08-14 00:23:21,413 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-08-14 00:23:21,413 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: third
2015-08-14 00:23:21,413 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-08-14 00:23:21,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2015-08-14 00:23:21,414 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-08-14 00:23:21,414 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: second
2015-08-14 00:23:21,414 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-08-14 00:23:21,415 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...d/second-nondeterministic
2015-08-14 00:23:21,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-08-14 00:23:21,415 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: first
2015-08-14 00:23:21,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 00:23:21,416 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2015-08-14 00:23:21,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 00:23:21,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutting down job executor
2015-08-14 00:23:21,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutdown complete
2015-08-14 00:23:21,421 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopped all flows
2015-08-14 00:23:21,421 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] completed flow: first
2015-08-14 00:23:21,421 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutting down flow executor
2015-08-14 00:23:21,422 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutdown complete
2015-08-14 00:23:21,422 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/stopped/second-nondeterministic
2015-08-14 00:23:21,423 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/stopped/third-nondeterministic
2015-08-14 00:23:21,424 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/stopped/first-nondeterministic
2015-08-14 00:23:21,447 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/stopped/fourth-nondeterministic
2015-08-14 00:23:21,465 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:21,466 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:21,489 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:21,490 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:21,513 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:21,514 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:21,536 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:21,537 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:21,552 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-08-14 00:23:21,553 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  parallel execution is enabled: true
2015-08-14 00:23:21,553 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  starting flows: 4
2015-08-14 00:23:21,553 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  allocating threads: 4
2015-08-14 00:23:21,554 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-08-14 00:23:21,556 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 00:23:21,556 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:23:21,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 00:23:21,561 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 00:23:21,561 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/firsttestSimpleCascade"]
2015-08-14 00:23:21,562 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-08-14 00:23:21,562 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-08-14 00:23:21,562 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-08-14 00:23:21,564 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...le/firsttestSimpleCascade
2015-08-14 00:23:22,574 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_20150814002132872_0011
2015-08-14 00:23:22,575 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0011
2015-08-14 00:23:22,806 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:23,897 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:24,612 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:24,845 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:25,194 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:26,298 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:30,816 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/firsttestSimpleCascade/_temporary
2015-08-14 00:23:30,817 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: first
2015-08-14 00:23:30,817 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: second
2015-08-14 00:23:30,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 00:23:30,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:23:30,822 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 00:23:30,822 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/firsttestSimpleCascade"]
2015-08-14 00:23:30,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/secondtestSimpleCascade"]
2015-08-14 00:23:30,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-08-14 00:23:30,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-08-14 00:23:30,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-08-14 00:23:30,825 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...e/secondtestSimpleCascade
2015-08-14 00:23:31,363 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_20150814002132872_0012
2015-08-14 00:23:31,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0012
2015-08-14 00:23:31,473 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:32,348 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:33,451 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:33,551 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:33,551 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:39,895 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/secondtestSimpleCascade/_temporary
2015-08-14 00:23:39,896 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: second
2015-08-14 00:23:39,897 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: third
2015-08-14 00:23:39,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-08-14 00:23:39,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:23:39,900 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 00:23:39,901 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/secondtestSimpleCascade"]
2015-08-14 00:23:39,901 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-08-14 00:23:39,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  parallel execution is enabled: true
2015-08-14 00:23:39,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  starting jobs: 1
2015-08-14 00:23:39,903 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  allocating threads: 1
2015-08-14 00:23:39,904 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...le/thirdtestSimpleCascade
2015-08-14 00:23:40,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_20150814002132872_0013
2015-08-14 00:23:40,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0013
2015-08-14 00:23:41,042 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:41,238 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:41,324 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0012 being deleted.
2015-08-14 00:23:41,616 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:41,617 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:41,626 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:42,444 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:49,354 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/thirdtestSimpleCascade/_temporary
2015-08-14 00:23:49,354 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: third
2015-08-14 00:23:49,355 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: fourth
2015-08-14 00:23:49,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 00:23:49,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 00:23:49,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 00:23:49,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-08-14 00:23:49,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/fourthtestSimpleCascade"]
2015-08-14 00:23:49,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  parallel execution is enabled: true
2015-08-14 00:23:49,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  starting jobs: 1
2015-08-14 00:23:49,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  allocating threads: 1
2015-08-14 00:23:49,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...e/fourthtestSimpleCascade
2015-08-14 00:23:49,893 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_20150814002132872_0014
2015-08-14 00:23:49,893 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://localhost:54589/jobdetails.jsp?jobid=job_20150814002132872_0014
2015-08-14 00:23:50,119 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:50,851 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:50,936 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:50,968 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:51,325 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2235)) - Unknown job job_20150814002132872_0013 being deleted.
2015-08-14 00:23:52,156 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:52,308 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-14 00:23:59,111 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/cascadeplatform/simple/fourthtestSimpleCascade/_temporary
2015-08-14 00:23:59,112 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: fourth
2015-08-14 00:23:59,139 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/secondtestSimpleCascade
2015-08-14 00:23:59,152 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/firsttestSimpleCascade
2015-08-14 00:23:59,165 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/fourthtestSimpleCascade
2015-08-14 00:23:59,182 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/simple/thirdtestSimpleCascade
2015-08-14 00:23:59,209 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,210 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:59,231 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,232 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:59,253 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,254 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:59,275 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,276 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:59,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/idtest/third
2015-08-14 00:23:59,291 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/idtest/fourth
2015-08-14 00:23:59,292 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/idtest/second
2015-08-14 00:23:59,292 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/cascadeplatform/idtest/first
2015-08-14 00:23:59,305 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,306 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:23:59,341 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:23:59,342 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar