Class cascading.cascade.ParallelCascadePlatformTest

2

tests

0

failures

1m31.09s

duration

100%

successful

Tests

Test Duration Result
testCascade 1m8.78s passed
testCascadeRaceCondition 22.314s passed

Standard output

2015-08-13 23:14:36,903 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 23:14:36,951 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 23:14:36,952 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.ParallelCascadePlatformTest
2015-08-13 23:14:36,982 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-13 23:14:38,009 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-13 23:14:39,077 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:14:39,079 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:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 1 with dfs.data.dir: build/test/data/dfs/data/data3,build/test/data/dfs/data/data4
2015-08-13 23:14:43,616 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:14:43,617 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:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:43,731 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:554)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:44,069 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:14:44,071 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:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:44,152 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:554)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:44,469 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties
2015-08-13 23:14:44,470 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:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1589)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:44,545 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:554)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:407)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:309)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1651)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1590)
	at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1565)
	at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:421)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:284)
	at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
	at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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-13 23:14:44,936 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties
2015-08-13 23:14:44,937 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:500)
	at org.apache.hadoop.metrics2.impl.MetricsSystemImpl.init(MetricsSystemImpl.java:140)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.init(DefaultMetricsSystem.java:40)
	at org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.initialize(DefaultMetricsSystem.java:50)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:308)
	at org.apache.hadoop.mapred.JobTracker.startTracker(JobTracker.java:303)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:396)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1149)
	at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
	at java.lang.Thread.run(Thread.java:662)
2015-08-13 23:14:45,886 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 23:14:45,992 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:14:46,335 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:14:46,655 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:14:46,988 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4391)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 23:14:48,355 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-13 23:14:48,466 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:48,468 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-13 23:14:48,483 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 94CDD801DEAE4CA4A38256BB187772FA
2015-08-13 23:14:48,646 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopping all flows
2015-08-13 23:14:48,647 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 23:14:48,648 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopped all flows
2015-08-13 23:14:48,648 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] starting
2015-08-13 23:14:48,675 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:48,677 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-13 23:14:48,699 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting
2015-08-13 23:14:48,702 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...]  parallel execution is enabled: true
2015-08-13 23:14:48,702 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...]  starting flows: 1
2015-08-13 23:14:48,703 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...]  allocating threads: 1
2015-08-13 23:14:48,704 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-08-13 23:14:48,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-08-13 23:14:48,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:48,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting
2015-08-13 23:14:48,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:48,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-50/first-nondeterministic"]
2015-08-13 23:14:48,730 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...]  parallel execution is enabled: true
2015-08-13 23:14:48,730 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...]  starting jobs: 1
2015-08-13 23:14:48,730 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...]  allocating threads: 1
2015-08-13 23:14:48,733 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:48,749 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping all flows
2015-08-13 23:14:48,751 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-08-13 23:14:48,752 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopping all jobs
2015-08-13 23:14:48,753 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:48,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopped all jobs
2015-08-13 23:14:48,755 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutting down job executor
2015-08-13 23:14:48,843 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 23:14:49,105 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] submitted hadoop job: job_20150813231444880_0001
2015-08-13 23:14:49,106 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0001
2015-08-13 23:14:49,110 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutdown complete
2015-08-13 23:14:49,111 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopped all flows
2015-08-13 23:14:49,112 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutting down flow executor
2015-08-13 23:14:49,111 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-08-13 23:14:49,113 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutdown complete
2015-08-13 23:14:49,131 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:49,132 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-13 23:14:49,153 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting
2015-08-13 23:14:49,155 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:49,156 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...]  starting flows: 1
2015-08-13 23:14:49,156 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...]  allocating threads: 1
2015-08-13 23:14:49,157 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-08-13 23:14:49,158 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:49,158 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:49,165 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting
2015-08-13 23:14:49,166 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:49,166 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-100/first-nondeterministic"]
2015-08-13 23:14:49,166 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:49,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...]  starting jobs: 1
2015-08-13 23:14:49,167 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...]  allocating threads: 1
2015-08-13 23:14:49,168 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:49,253 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping all flows
2015-08-13 23:14:49,257 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-08-13 23:14:49,258 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopping all jobs
2015-08-13 23:14:49,259 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:49,261 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopped all jobs
2015-08-13 23:14:49,262 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutting down job executor
2015-08-13 23:14:49,804 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] submitted hadoop job: job_20150813231444880_0002
2015-08-13 23:14:49,805 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0002
2015-08-13 23:14:49,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutdown complete
2015-08-13 23:14:49,811 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopped all flows
2015-08-13 23:14:49,811 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-08-13 23:14:49,812 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutting down flow executor
2015-08-13 23:14:49,813 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutdown complete
2015-08-13 23:14:49,835 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:49,836 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-13 23:14:49,858 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting
2015-08-13 23:14:49,862 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:49,862 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...]  starting flows: 1
2015-08-13 23:14:49,863 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...]  allocating threads: 1
2015-08-13 23:14:49,866 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-08-13 23:14:49,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:49,868 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:49,875 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting
2015-08-13 23:14:49,876 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:49,877 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-150/first-nondeterministic"]
2015-08-13 23:14:49,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:49,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...]  starting jobs: 1
2015-08-13 23:14:49,879 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...]  allocating threads: 1
2015-08-13 23:14:49,881 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:50,008 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping all flows
2015-08-13 23:14:50,010 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-08-13 23:14:50,011 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopping all jobs
2015-08-13 23:14:50,012 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:50,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopped all jobs
2015-08-13 23:14:50,014 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutting down job executor
2015-08-13 23:14:50,507 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] submitted hadoop job: job_20150813231444880_0003
2015-08-13 23:14:50,507 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0003
2015-08-13 23:14:50,511 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutdown complete
2015-08-13 23:14:50,512 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopped all flows
2015-08-13 23:14:50,512 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-08-13 23:14:50,513 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutting down flow executor
2015-08-13 23:14:50,514 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutdown complete
2015-08-13 23:14:50,545 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:50,547 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-13 23:14:50,584 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting
2015-08-13 23:14:50,585 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:50,586 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...]  starting flows: 1
2015-08-13 23:14:50,586 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...]  allocating threads: 1
2015-08-13 23:14:50,587 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-08-13 23:14:50,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:50,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:50,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting
2015-08-13 23:14:50,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:50,603 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-200/first-nondeterministic"]
2015-08-13 23:14:50,604 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:50,604 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...]  starting jobs: 1
2015-08-13 23:14:50,605 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...]  allocating threads: 1
2015-08-13 23:14:50,607 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:50,784 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping all flows
2015-08-13 23:14:50,785 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-08-13 23:14:50,786 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopping all jobs
2015-08-13 23:14:50,787 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:50,787 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopped all jobs
2015-08-13 23:14:50,788 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutting down job executor
2015-08-13 23:14:51,220 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] submitted hadoop job: job_20150813231444880_0004
2015-08-13 23:14:51,220 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0004
2015-08-13 23:14:51,231 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutdown complete
2015-08-13 23:14:51,232 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopped all flows
2015-08-13 23:14:51,233 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutting down flow executor
2015-08-13 23:14:51,233 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-08-13 23:14:51,234 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutdown complete
2015-08-13 23:14:51,256 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:51,257 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-13 23:14:51,287 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting
2015-08-13 23:14:51,289 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:51,289 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...]  starting flows: 1
2015-08-13 23:14:51,290 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...]  allocating threads: 1
2015-08-13 23:14:51,291 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-08-13 23:14:51,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:51,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:51,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting
2015-08-13 23:14:51,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:51,303 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-250/first-nondeterministic"]
2015-08-13 23:14:51,303 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:51,303 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...]  starting jobs: 1
2015-08-13 23:14:51,303 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...]  allocating threads: 1
2015-08-13 23:14:51,305 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:51,537 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping all flows
2015-08-13 23:14:51,539 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-08-13 23:14:51,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopping all jobs
2015-08-13 23:14:51,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:51,541 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopped all jobs
2015-08-13 23:14:51,542 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutting down job executor
2015-08-13 23:14:51,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] submitted hadoop job: job_20150813231444880_0005
2015-08-13 23:14:51,925 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0005
2015-08-13 23:14:51,929 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutdown complete
2015-08-13 23:14:51,930 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopped all flows
2015-08-13 23:14:51,930 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutting down flow executor
2015-08-13 23:14:51,930 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-08-13 23:14:51,935 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutdown complete
2015-08-13 23:14:51,950 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:51,951 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-13 23:14:51,972 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting
2015-08-13 23:14:51,974 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:51,974 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...]  starting flows: 1
2015-08-13 23:14:51,975 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...]  allocating threads: 1
2015-08-13 23:14:51,977 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-08-13 23:14:51,978 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:51,978 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:51,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting
2015-08-13 23:14:51,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:51,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-300/first-nondeterministic"]
2015-08-13 23:14:51,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:51,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...]  starting jobs: 1
2015-08-13 23:14:51,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...]  allocating threads: 1
2015-08-13 23:14:51,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:52,272 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping all flows
2015-08-13 23:14:52,274 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-08-13 23:14:52,274 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopping all jobs
2015-08-13 23:14:52,275 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:52,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopped all jobs
2015-08-13 23:14:52,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutting down job executor
2015-08-13 23:14:52,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] submitted hadoop job: job_20150813231444880_0006
2015-08-13 23:14:52,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0006
2015-08-13 23:14:52,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutdown complete
2015-08-13 23:14:52,813 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopped all flows
2015-08-13 23:14:52,813 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-08-13 23:14:52,814 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutting down flow executor
2015-08-13 23:14:52,815 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutdown complete
2015-08-13 23:14:52,829 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:52,830 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-13 23:14:52,848 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting
2015-08-13 23:14:52,851 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:52,852 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...]  starting flows: 1
2015-08-13 23:14:52,857 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...]  allocating threads: 1
2015-08-13 23:14:52,857 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-08-13 23:14:52,858 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:52,859 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:52,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting
2015-08-13 23:14:52,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:52,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-350/first-nondeterministic"]
2015-08-13 23:14:52,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:52,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...]  starting jobs: 1
2015-08-13 23:14:52,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...]  allocating threads: 1
2015-08-13 23:14:52,888 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:53,198 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping all flows
2015-08-13 23:14:53,199 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-08-13 23:14:53,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopping all jobs
2015-08-13 23:14:53,207 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:53,207 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopped all jobs
2015-08-13 23:14:53,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutting down job executor
2015-08-13 23:14:53,616 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:54,066 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] submitted hadoop job: job_20150813231444880_0007
2015-08-13 23:14:54,067 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0007
2015-08-13 23:14:54,078 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutdown complete
2015-08-13 23:14:54,079 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopped all flows
2015-08-13 23:14:54,079 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-08-13 23:14:54,079 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutting down flow executor
2015-08-13 23:14:54,080 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutdown complete
2015-08-13 23:14:54,141 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:54,141 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-13 23:14:54,220 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting
2015-08-13 23:14:54,244 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:54,244 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...]  starting flows: 1
2015-08-13 23:14:54,245 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...]  allocating threads: 1
2015-08-13 23:14:54,252 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-08-13 23:14:54,253 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:54,253 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:54,353 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting
2015-08-13 23:14:54,353 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:54,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-400/first-nondeterministic"]
2015-08-13 23:14:54,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:54,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...]  starting jobs: 1
2015-08-13 23:14:54,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...]  allocating threads: 1
2015-08-13 23:14:54,355 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:54,419 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:54,599 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping all flows
2015-08-13 23:14:54,605 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-08-13 23:14:54,605 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopping all jobs
2015-08-13 23:14:54,606 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:54,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopped all jobs
2015-08-13 23:14:54,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutting down job executor
2015-08-13 23:14:55,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] submitted hadoop job: job_20150813231444880_0008
2015-08-13 23:14:55,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0008
2015-08-13 23:14:55,391 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutdown complete
2015-08-13 23:14:55,391 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopped all flows
2015-08-13 23:14:55,391 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-08-13 23:14:55,392 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutting down flow executor
2015-08-13 23:14:55,400 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutdown complete
2015-08-13 23:14:55,417 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:55,418 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-13 23:14:55,481 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting
2015-08-13 23:14:55,484 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:55,485 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...]  starting flows: 1
2015-08-13 23:14:55,486 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...]  allocating threads: 1
2015-08-13 23:14:55,487 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-08-13 23:14:55,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:55,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:55,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting
2015-08-13 23:14:55,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:55,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-450/first-nondeterministic"]
2015-08-13 23:14:55,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:55,544 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...]  starting jobs: 1
2015-08-13 23:14:55,545 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...]  allocating threads: 1
2015-08-13 23:14:55,553 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:55,822 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:55,931 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping all flows
2015-08-13 23:14:55,932 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-08-13 23:14:55,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopping all jobs
2015-08-13 23:14:55,938 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 23:14:55,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopped all jobs
2015-08-13 23:14:55,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutting down job executor
2015-08-13 23:14:56,255 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:57,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] submitted hadoop job: job_20150813231444880_0009
2015-08-13 23:14:57,127 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0009
2015-08-13 23:14:57,243 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutdown complete
2015-08-13 23:14:57,244 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopped all flows
2015-08-13 23:14:57,245 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutting down flow executor
2015-08-13 23:14:57,245 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-08-13 23:14:57,246 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutdown complete
2015-08-13 23:14:57,271 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:57,282 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-13 23:14:57,367 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting
2015-08-13 23:14:57,386 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:57,386 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...]  starting flows: 1
2015-08-13 23:14:57,387 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...]  allocating threads: 1
2015-08-13 23:14:57,400 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-08-13 23:14:57,404 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-08-13 23:14:57,405 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:57,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting
2015-08-13 23:14:57,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:57,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/race-500/first-nondeterministic"]
2015-08-13 23:14:57,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...]  parallel execution is enabled: true
2015-08-13 23:14:57,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...]  starting jobs: 1
2015-08-13 23:14:57,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...]  allocating threads: 1
2015-08-13 23:14:57,553 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:57,612 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:57,775 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:57,867 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping all flows
2015-08-13 23:14:57,905 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-08-13 23:14:57,905 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopping all jobs
2015-08-13 23:14:57,909 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 23:14:57,910 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopped all jobs
2015-08-13 23:14:57,910 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutting down job executor
2015-08-13 23:14:59,144 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:14:59,182 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] submitted hadoop job: job_20150813231444880_0010
2015-08-13 23:14:59,182 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0010
2015-08-13 23:14:59,203 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutdown complete
2015-08-13 23:14:59,204 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopped all flows
2015-08-13 23:14:59,204 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutting down flow executor
2015-08-13 23:14:59,204 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-08-13 23:14:59,205 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutdown complete
2015-08-13 23:14:59,206 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-100/first-nondeterministic
2015-08-13 23:14:59,211 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-0/first-nondeterministic
2015-08-13 23:14:59,213 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-200/first-nondeterministic
2015-08-13 23:14:59,218 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-150/first-nondeterministic
2015-08-13 23:14:59,222 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-50/first-nondeterministic
2015-08-13 23:14:59,266 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-250/first-nondeterministic
2015-08-13 23:14:59,271 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-450/first-nondeterministic
2015-08-13 23:14:59,275 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-350/first-nondeterministic
2015-08-13 23:14:59,282 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-300/first-nondeterministic
2015-08-13 23:14:59,286 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-500/first-nondeterministic
2015-08-13 23:14:59,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/race-400/first-nondeterministic
2015-08-13 23:14:59,313 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:59,314 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-13 23:14:59,345 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:59,345 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-13 23:14:59,404 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:59,405 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-13 23:14:59,465 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:59,465 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-13 23:14:59,574 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:14:59,576 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-13 23:14:59,695 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting
2015-08-13 23:14:59,702 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...]  parallel execution is enabled: true
2015-08-13 23:14:59,702 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...]  starting flows: 5
2015-08-13 23:14:59,703 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...]  allocating threads: 5
2015-08-13 23:14:59,726 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first2
2015-08-13 23:14:59,727 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] at least one sink is marked for delete
2015-08-13 23:14:59,727 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:59,740 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first1
2015-08-13 23:14:59,741 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] at least one sink is marked for delete
2015-08-13 23:14:59,741 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:14:59,806 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting
2015-08-13 23:14:59,807 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:59,807 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first1"]
2015-08-13 23:14:59,807 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1]  parallel execution is enabled: true
2015-08-13 23:14:59,808 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1]  starting jobs: 1
2015-08-13 23:14:59,808 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first1]  allocating threads: 1
2015-08-13 23:14:59,808 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting
2015-08-13 23:14:59,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-08-13 23:14:59,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first2"]
2015-08-13 23:14:59,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2]  parallel execution is enabled: true
2015-08-13 23:14:59,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2]  starting jobs: 1
2015-08-13 23:14:59,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first2]  allocating threads: 1
2015-08-13 23:14:59,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] starting step: (1/1) ...lelcascadeplatform/first1
2015-08-13 23:14:59,885 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] starting step: (1/1) ...lelcascadeplatform/first2
2015-08-13 23:15:00,771 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:01,105 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:01,666 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:01,814 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:02,189 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:02,297 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:02,840 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] submitted hadoop job: job_20150813231444880_0011
2015-08-13 23:15:02,847 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0011
2015-08-13 23:15:02,871 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] submitted hadoop job: job_20150813231444880_0012
2015-08-13 23:15:02,871 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0012
2015-08-13 23:15:04,536 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:04,838 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:05,125 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:05,371 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:08,398 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:08,509 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:08,948 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0001 being deleted.
2015-08-13 23:15:09,661 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,161 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,238 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,461 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,767 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,840 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:10,949 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0002 being deleted.
2015-08-13 23:15:11,925 WARN  mapred.TaskTracker (TaskTracker.java:statusUpdate(3506)) - Failed validating JVM
java.io.IOException: JvmValidate Failed. Ignoring request from task: attempt_20150813231444880_0004_m_000003_0, with JvmId: jvm_20150813231444880_0004_m_-1433149675
	at org.apache.hadoop.mapred.TaskTracker.validateJVM(TaskTracker.java:3434)
	at org.apache.hadoop.mapred.TaskTracker.statusUpdate(TaskTracker.java:3504)
	at sun.reflect.GeneratedMethodAccessor31.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:578)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1393)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1389)
	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:1149)
	at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1387)
2015-08-13 23:15:12,021 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:12,069 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:14,301 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0003 being deleted.
2015-08-13 23:15:14,357 WARN  mapred.TaskTracker (TaskTracker.java:statusUpdate(3506)) - Failed validating JVM
java.io.IOException: JvmValidate Failed. Ignoring request from task: attempt_20150813231444880_0005_m_000000_0, with JvmId: jvm_20150813231444880_0005_m_-1476445695
	at org.apache.hadoop.mapred.TaskTracker.validateJVM(TaskTracker.java:3434)
	at org.apache.hadoop.mapred.TaskTracker.statusUpdate(TaskTracker.java:3504)
	at sun.reflect.GeneratedMethodAccessor31.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:578)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1393)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1389)
	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:1149)
	at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1387)
2015-08-13 23:15:14,451 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:14,796 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:15,791 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:16,690 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:16,963 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:17,034 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0004 being deleted.
2015-08-13 23:15:17,256 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:17,319 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:17,796 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:18,332 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:18,333 WARN  mapred.TaskTracker (TaskTracker.java:statusUpdate(3506)) - Failed validating JVM
java.io.IOException: JvmValidate Failed. Ignoring request from task: attempt_20150813231444880_0006_m_000002_0, with JvmId: jvm_20150813231444880_0006_m_1720401415
	at org.apache.hadoop.mapred.TaskTracker.validateJVM(TaskTracker.java:3434)
	at org.apache.hadoop.mapred.TaskTracker.statusUpdate(TaskTracker.java:3504)
	at sun.reflect.GeneratedMethodAccessor31.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:578)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1393)
	at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1389)
	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:1149)
	at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1387)
2015-08-13 23:15:18,420 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:20,119 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:20,413 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:21,995 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:22,303 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0005 being deleted.
2015-08-13 23:15:23,334 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0006 being deleted.
2015-08-13 23:15:23,820 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:24,515 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:24,685 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:24,754 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:24,832 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:25,042 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0006 being deleted.
2015-08-13 23:15:25,152 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:25,277 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:26,230 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:26,777 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:30,305 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0007 being deleted.
2015-08-13 23:15:30,335 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:30,864 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:30,995 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0007 being deleted.
2015-08-13 23:15:31,043 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0008 being deleted.
2015-08-13 23:15:31,175 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:31,253 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:31,336 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0008 being deleted.
2015-08-13 23:15:31,455 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:31,551 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:32,619 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:32,770 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:35,044 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0010 being deleted.
2015-08-13 23:15:36,449 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:36,570 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:37,337 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0009 being deleted.
2015-08-13 23:15:37,731 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first1/_temporary
2015-08-13 23:15:37,733 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first1
2015-08-13 23:15:37,733 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second1
2015-08-13 23:15:37,733 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] at least one sink is marked for delete
2015-08-13 23:15:37,734 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:15:37,737 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting
2015-08-13 23:15:37,737 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first1"]
2015-08-13 23:15:37,737 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second1"]
2015-08-13 23:15:37,738 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1]  parallel execution is enabled: true
2015-08-13 23:15:37,738 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1]  starting jobs: 1
2015-08-13 23:15:37,738 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second1]  allocating threads: 1
2015-08-13 23:15:37,739 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] starting step: (1/1) ...elcascadeplatform/second1
2015-08-13 23:15:38,481 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:39,114 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] submitted hadoop job: job_20150813231444880_0013
2015-08-13 23:15:39,114 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0013
2015-08-13 23:15:39,149 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first2/_temporary
2015-08-13 23:15:39,151 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first2
2015-08-13 23:15:39,151 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second2
2015-08-13 23:15:39,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] at least one sink is marked for delete
2015-08-13 23:15:39,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:15:39,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting
2015-08-13 23:15:39,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/first2"]
2015-08-13 23:15:39,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second2"]
2015-08-13 23:15:39,157 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2]  parallel execution is enabled: true
2015-08-13 23:15:39,157 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2]  starting jobs: 1
2015-08-13 23:15:39,157 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second2]  allocating threads: 1
2015-08-13 23:15:39,159 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] starting step: (1/1) ...elcascadeplatform/second2
2015-08-13 23:15:39,234 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:39,329 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:39,338 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0011 being deleted.
2015-08-13 23:15:39,889 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:40,124 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] submitted hadoop job: job_20150813231444880_0014
2015-08-13 23:15:40,124 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0014
2015-08-13 23:15:40,307 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:40,580 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:40,654 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:40,848 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:42,470 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:44,312 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:47,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second1/_temporary
2015-08-13 23:15:47,713 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second1
2015-08-13 23:15:48,314 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0013 being deleted.
2015-08-13 23:15:49,693 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:49,741 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second2/_temporary
2015-08-13 23:15:49,742 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second2
2015-08-13 23:15:49,742 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-08-13 23:15:49,742 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] at least one sink is marked for delete
2015-08-13 23:15:49,743 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 23:15:49,745 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second2"]
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/second1"]
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/third"]
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 1
2015-08-13 23:15:49,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 1
2015-08-13 23:15:49,748 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...llelcascadeplatform/third
2015-08-13 23:15:50,040 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:50,267 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:50,345 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:50,688 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_20150813231444880_0015
2015-08-13 23:15:50,689 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://localhost:36057/jobdetails.jsp?jobid=job_20150813231444880_0015
2015-08-13 23:15:50,806 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:50,823 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:51,047 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0014 being deleted.
2015-08-13 23:15:51,269 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:15:51,340 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(2213)) - Unknown job job_20150813231444880_0014 being deleted.
2015-08-13 23:15:51,450 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(146)) - Exit code from task is : 143
2015-08-13 23:16:07,981 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/parallelcascadeplatform/third/_temporary
2015-08-13 23:16:07,982 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-08-13 23:16:08,007 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/second2
2015-08-13 23:16:08,025 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/second1
2015-08-13 23:16:08,042 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/first1
2015-08-13 23:16:08,056 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/first2
2015-08-13 23:16:08,071 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/parallelcascadeplatform/third