2015-08-13 21:34:02,780 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 21:34:02,831 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 21:34:02,831 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.ParallelCascadePlatformTest
2015-08-13 21:34:02,864 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster
2015-08-13 21:34:03,790 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 21:34:04,890 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 21:34:04,892 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:07,797 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 21:34:07,798 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:07,881 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:08,210 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 21:34:08,211 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:08,287 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:08,581 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 21:34:08,583 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:1520)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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 21:34:08,655 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:517)
at org.apache.hadoop.hdfs.server.datanode.DataNode.startDataNode(DataNode.java:393)
at org.apache.hadoop.hdfs.server.datanode.DataNode.<init>(DataNode.java:299)
at org.apache.hadoop.hdfs.server.datanode.DataNode.makeInstance(DataNode.java:1582)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1521)
at org.apache.hadoop.hdfs.server.datanode.DataNode.instantiateDataNode(DataNode.java:1496)
at org.apache.hadoop.hdfs.MiniDFSCluster.startDataNodes(MiniDFSCluster.java:417)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:280)
at org.apache.hadoop.hdfs.MiniDFSCluster.<init>(MiniDFSCluster.java:124)
at cascading.platform.hadoop.HadoopPlatform.setUp(HadoopPlatform.java: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)
Generating rack names for tasktrackers
Generating host names for tasktrackers
2015-08-13 21:34:09,016 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 21:34:09,017 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:296)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:114)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner$1.run(MiniMRCluster.java:112)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
at org.apache.hadoop.mapred.MiniMRCluster$JobTrackerRunner.run(MiniMRCluster.java:112)
at java.lang.Thread.run(Thread.java:662)
2015-08-13 21:34:10,043 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 21:34:10,101 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 21:34:10,413 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 21:34:10,700 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 21:34:11,010 WARN mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4201)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.
2015-08-13 21:34:14,338 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 21:34:14,446 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:14,447 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 21:34:14,459 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 9D571CB22F524857B978317043814D79
2015-08-13 21:34:14,641 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopping all flows
2015-08-13 21:34:14,642 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopped all flows
2015-08-13 21:34:14,642 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 21:34:14,643 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] starting
2015-08-13 21:34:14,669 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:14,670 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 21:34:14,689 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting
2015-08-13 21:34:14,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-08-13 21:34:14,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flows: 1
2015-08-13 21:34:14,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] allocating threads: 1
2015-08-13 21:34:14,695 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-08-13 21:34:14,696 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-08-13 21:34:14,697 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 21:34:14,723 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting
2015-08-13 21:34:14,724 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:14,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-50/first-nondeterministic"]
2015-08-13 21:34:14,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-08-13 21:34:14,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting jobs: 1
2015-08-13 21:34:14,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] allocating threads: 1
2015-08-13 21:34:14,726 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:14,739 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping all flows
2015-08-13 21:34:14,740 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-08-13 21:34:14,741 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopping all jobs
2015-08-13 21:34:14,742 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:14,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopped all jobs
2015-08-13 21:34:14,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutting down job executor
2015-08-13 21:34:14,806 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 21:34:15,019 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] submitted hadoop job: job_20150813213408963_0001
2015-08-13 21:34:15,019 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0001
2015-08-13 21:34:15,023 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutdown complete
2015-08-13 21:34:15,024 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopped all flows
2015-08-13 21:34:15,024 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-08-13 21:34:15,024 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutting down flow executor
2015-08-13 21:34:15,027 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutdown complete
2015-08-13 21:34:15,045 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:15,045 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 21:34:15,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting
2015-08-13 21:34:15,068 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,068 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flows: 1
2015-08-13 21:34:15,068 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,069 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-08-13 21:34:15,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:15,070 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 21:34:15,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting
2015-08-13 21:34:15,076 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:15,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-100/first-nondeterministic"]
2015-08-13 21:34:15,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting jobs: 1
2015-08-13 21:34:15,079 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,080 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:15,166 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping all flows
2015-08-13 21:34:15,168 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-08-13 21:34:15,168 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopping all jobs
2015-08-13 21:34:15,170 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:15,171 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopped all jobs
2015-08-13 21:34:15,172 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutting down job executor
2015-08-13 21:34:15,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] submitted hadoop job: job_20150813213408963_0002
2015-08-13 21:34:15,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0002
2015-08-13 21:34:15,285 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutdown complete
2015-08-13 21:34:15,285 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopped all flows
2015-08-13 21:34:15,285 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-08-13 21:34:15,286 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutting down flow executor
2015-08-13 21:34:15,287 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutdown complete
2015-08-13 21:34:15,303 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:15,304 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 21:34:15,324 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting
2015-08-13 21:34:15,325 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,325 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flows: 1
2015-08-13 21:34:15,326 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,326 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-08-13 21:34:15,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:15,328 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 21:34:15,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting
2015-08-13 21:34:15,335 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:15,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-150/first-nondeterministic"]
2015-08-13 21:34:15,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting jobs: 1
2015-08-13 21:34:15,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,341 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:15,474 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping all flows
2015-08-13 21:34:15,475 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-08-13 21:34:15,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopping all jobs
2015-08-13 21:34:15,477 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:15,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopped all jobs
2015-08-13 21:34:15,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutting down job executor
2015-08-13 21:34:15,511 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] submitted hadoop job: job_20150813213408963_0003
2015-08-13 21:34:15,511 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0003
2015-08-13 21:34:15,515 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutdown complete
2015-08-13 21:34:15,516 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopped all flows
2015-08-13 21:34:15,516 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutting down flow executor
2015-08-13 21:34:15,516 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-08-13 21:34:15,517 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutdown complete
2015-08-13 21:34:15,534 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:15,535 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 21:34:15,554 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting
2015-08-13 21:34:15,557 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,557 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flows: 1
2015-08-13 21:34:15,558 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,559 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-08-13 21:34:15,560 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:15,560 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 21:34:15,568 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting
2015-08-13 21:34:15,568 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:15,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-200/first-nondeterministic"]
2015-08-13 21:34:15,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting jobs: 1
2015-08-13 21:34:15,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,570 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:15,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] submitted hadoop job: job_20150813213408963_0004
2015-08-13 21:34:15,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0004
2015-08-13 21:34:15,754 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping all flows
2015-08-13 21:34:15,754 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-08-13 21:34:15,755 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopping all jobs
2015-08-13 21:34:15,756 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:15,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopped all jobs
2015-08-13 21:34:15,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutting down job executor
2015-08-13 21:34:15,764 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutdown complete
2015-08-13 21:34:15,765 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopped all flows
2015-08-13 21:34:15,765 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-08-13 21:34:15,765 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutting down flow executor
2015-08-13 21:34:15,767 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutdown complete
2015-08-13 21:34:15,789 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:15,790 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 21:34:15,810 ERROR mapred.JobTracker (JobTracker.java:initJob(4221)) - Job initialization interrupted:
org.apache.hadoop.mapred.JobInProgress$KillInterruptedException: Job job_20150813213408963_0004 killed in init
at org.apache.hadoop.mapred.JobInProgress.initTasks(JobInProgress.java:797)
at org.apache.hadoop.mapred.JobTracker.initJob(JobTracker.java:4207)
at org.apache.hadoop.mapred.EagerTaskInitializationListener$InitJob.run(EagerTaskInitializationListener.java:79)
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 21:34:15,813 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting
2015-08-13 21:34:15,814 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,814 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flows: 1
2015-08-13 21:34:15,815 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,815 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-08-13 21:34:15,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:15,817 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 21:34:15,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting
2015-08-13 21:34:15,824 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:15,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-250/first-nondeterministic"]
2015-08-13 21:34:15,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:15,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting jobs: 1
2015-08-13 21:34:15,826 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] allocating threads: 1
2015-08-13 21:34:15,827 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:15,983 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] submitted hadoop job: job_20150813213408963_0005
2015-08-13 21:34:15,984 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0005
2015-08-13 21:34:16,063 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping all flows
2015-08-13 21:34:16,064 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-08-13 21:34:16,064 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopping all jobs
2015-08-13 21:34:16,065 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:16,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopped all jobs
2015-08-13 21:34:16,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutting down job executor
2015-08-13 21:34:16,079 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutdown complete
2015-08-13 21:34:16,080 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopped all flows
2015-08-13 21:34:16,080 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-08-13 21:34:16,080 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutting down flow executor
2015-08-13 21:34:16,082 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutdown complete
2015-08-13 21:34:16,101 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:16,102 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 21:34:16,120 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting
2015-08-13 21:34:16,122 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,122 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flows: 1
2015-08-13 21:34:16,122 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,123 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-08-13 21:34:16,124 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:16,124 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 21:34:16,129 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting
2015-08-13 21:34:16,130 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:16,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-300/first-nondeterministic"]
2015-08-13 21:34:16,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting jobs: 1
2015-08-13 21:34:16,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,132 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:16,292 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] submitted hadoop job: job_20150813213408963_0006
2015-08-13 21:34:16,292 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0006
2015-08-13 21:34:16,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping all flows
2015-08-13 21:34:16,421 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-08-13 21:34:16,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopping all jobs
2015-08-13 21:34:16,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:16,441 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopped all jobs
2015-08-13 21:34:16,441 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutting down job executor
2015-08-13 21:34:16,452 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutdown complete
2015-08-13 21:34:16,452 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopped all flows
2015-08-13 21:34:16,452 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-08-13 21:34:16,453 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutting down flow executor
2015-08-13 21:34:16,454 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutdown complete
2015-08-13 21:34:16,461 ERROR mapred.JobTracker (JobTracker.java:initJob(4221)) - Job initialization interrupted:
org.apache.hadoop.mapred.JobInProgress$KillInterruptedException: Job job_20150813213408963_0005 killed in init
at org.apache.hadoop.mapred.JobInProgress.initTasks(JobInProgress.java:797)
at org.apache.hadoop.mapred.JobTracker.initJob(JobTracker.java:4207)
at org.apache.hadoop.mapred.EagerTaskInitializationListener$InitJob.run(EagerTaskInitializationListener.java:79)
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 21:34:16,473 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:16,473 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 21:34:16,492 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting
2015-08-13 21:34:16,494 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,494 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flows: 1
2015-08-13 21:34:16,495 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,496 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-08-13 21:34:16,497 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:16,497 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 21:34:16,503 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting
2015-08-13 21:34:16,504 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:16,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-350/first-nondeterministic"]
2015-08-13 21:34:16,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting jobs: 1
2015-08-13 21:34:16,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,507 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:16,677 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] submitted hadoop job: job_20150813213408963_0007
2015-08-13 21:34:16,677 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0007
2015-08-13 21:34:16,842 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping all flows
2015-08-13 21:34:16,843 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-08-13 21:34:16,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopping all jobs
2015-08-13 21:34:16,844 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:16,850 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopped all jobs
2015-08-13 21:34:16,850 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopped all flows
2015-08-13 21:34:16,851 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-08-13 21:34:16,851 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutting down flow executor
2015-08-13 21:34:16,855 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutdown complete
2015-08-13 21:34:16,871 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:16,872 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 21:34:16,891 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting
2015-08-13 21:34:16,893 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,893 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flows: 1
2015-08-13 21:34:16,893 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,895 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-08-13 21:34:16,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:16,896 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 21:34:16,901 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting
2015-08-13 21:34:16,901 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:16,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-400/first-nondeterministic"]
2015-08-13 21:34:16,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:16,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting jobs: 1
2015-08-13 21:34:16,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] allocating threads: 1
2015-08-13 21:34:16,904 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:17,291 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping all flows
2015-08-13 21:34:17,293 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-08-13 21:34:17,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopping all jobs
2015-08-13 21:34:17,294 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:17,294 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopped all jobs
2015-08-13 21:34:17,295 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutting down job executor
2015-08-13 21:34:17,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] submitted hadoop job: job_20150813213408963_0008
2015-08-13 21:34:17,465 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0008
2015-08-13 21:34:17,468 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutdown complete
2015-08-13 21:34:17,468 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopped all flows
2015-08-13 21:34:17,469 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-08-13 21:34:17,469 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutting down flow executor
2015-08-13 21:34:17,470 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutdown complete
2015-08-13 21:34:17,485 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:17,486 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 21:34:17,502 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting
2015-08-13 21:34:17,505 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:17,506 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flows: 1
2015-08-13 21:34:17,506 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] allocating threads: 1
2015-08-13 21:34:17,508 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-08-13 21:34:17,508 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:17,509 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 21:34:17,518 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting
2015-08-13 21:34:17,518 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:17,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-450/first-nondeterministic"]
2015-08-13 21:34:17,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:17,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting jobs: 1
2015-08-13 21:34:17,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] allocating threads: 1
2015-08-13 21:34:17,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:17,952 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping all flows
2015-08-13 21:34:17,957 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-08-13 21:34:17,958 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopping all jobs
2015-08-13 21:34:17,970 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-13 21:34:17,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopped all jobs
2015-08-13 21:34:17,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutting down job executor
2015-08-13 21:34:18,127 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] submitted hadoop job: job_20150813213408963_0009
2015-08-13 21:34:18,128 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0009
2015-08-13 21:34:18,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutdown complete
2015-08-13 21:34:18,132 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopped all flows
2015-08-13 21:34:18,132 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-08-13 21:34:18,132 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutting down flow executor
2015-08-13 21:34:18,135 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutdown complete
2015-08-13 21:34:18,151 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:18,152 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 21:34:18,221 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting
2015-08-13 21:34:18,222 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:18,222 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flows: 1
2015-08-13 21:34:18,222 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] allocating threads: 1
2015-08-13 21:34:18,223 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-08-13 21:34:18,223 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-08-13 21:34:18,224 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 21:34:18,275 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting
2015-08-13 21:34:18,275 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.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:18,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/race-500/first-nondeterministic"]
2015-08-13 21:34:18,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-08-13 21:34:18,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting jobs: 1
2015-08-13 21:34:18,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] allocating threads: 1
2015-08-13 21:34:18,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:18,718 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping all flows
2015-08-13 21:34:18,719 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-08-13 21:34:18,719 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopping all jobs
2015-08-13 21:34:18,720 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-13 21:34:18,720 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopped all jobs
2015-08-13 21:34:18,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutting down job executor
2015-08-13 21:34:19,126 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] submitted hadoop job: job_20150813213408963_0010
2015-08-13 21:34:19,127 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0010
2015-08-13 21:34:19,129 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutdown complete
2015-08-13 21:34:19,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopped all flows
2015-08-13 21:34:19,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-08-13 21:34:19,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutting down flow executor
2015-08-13 21:34:19,131 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutdown complete
2015-08-13 21:34:19,131 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-450/first-nondeterministic
2015-08-13 21:34:19,136 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-300/first-nondeterministic
2015-08-13 21:34:19,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-150/first-nondeterministic
2015-08-13 21:34:19,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-250/first-nondeterministic
2015-08-13 21:34:19,149 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-0/first-nondeterministic
2015-08-13 21:34:19,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-100/first-nondeterministic
2015-08-13 21:34:19,154 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-50/first-nondeterministic
2015-08-13 21:34:19,158 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-500/first-nondeterministic
2015-08-13 21:34:19,164 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-400/first-nondeterministic
2015-08-13 21:34:19,168 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-350/first-nondeterministic
2015-08-13 21:34:19,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/race-200/first-nondeterministic
2015-08-13 21:34:19,193 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:19,193 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 21:34:19,221 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:19,222 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 21:34:19,259 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:19,260 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 21:34:19,288 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:19,288 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 21:34:19,322 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:34:19,323 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 21:34:19,364 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting
2015-08-13 21:34:19,365 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] parallel execution is enabled: true
2015-08-13 21:34:19,365 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flows: 5
2015-08-13 21:34:19,365 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] allocating threads: 5
2015-08-13 21:34:19,365 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first2
2015-08-13 21:34:19,366 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first1
2015-08-13 21:34:19,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] at least one sink is marked for delete
2015-08-13 21:34:19,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] at least one sink is marked for delete
2015-08-13 21:34:19,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 21:34:19,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 21:34:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting
2015-08-13 21:34:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting
2015-08-13 21:34:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-08-13 21:34:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first1"]
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first2"]
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] parallel execution is enabled: true
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting jobs: 1
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] parallel execution is enabled: true
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting jobs: 1
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] allocating threads: 1
2015-08-13 21:34:19,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] allocating threads: 1
2015-08-13 21:34:19,375 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] starting step: (1/1) ...lelcascadeplatform/first1
2015-08-13 21:34:19,376 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] starting step: (1/1) ...lelcascadeplatform/first2
2015-08-13 21:34:19,963 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] submitted hadoop job: job_20150813213408963_0011
2015-08-13 21:34:19,963 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0011
2015-08-13 21:34:20,423 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] submitted hadoop job: job_20150813213408963_0012
2015-08-13 21:34:20,424 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0012
2015-08-13 21:34:22,631 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:23,131 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0004 being deleted.
2015-08-13 21:34:23,155 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0004 being deleted.
2015-08-13 21:34:23,158 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0005 being deleted.
2015-08-13 21:34:23,265 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:23,376 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:23,757 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0004 being deleted.
2015-08-13 21:34:23,758 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0006 being deleted.
2015-08-13 21:34:23,758 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0005 being deleted.
2015-08-13 21:34:23,803 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:25,489 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0007 being deleted.
2015-08-13 21:34:25,489 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0006 being deleted.
2015-08-13 21:34:25,489 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0005 being deleted.
2015-08-13 21:34:26,140 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0007 being deleted.
2015-08-13 21:34:26,141 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0006 being deleted.
2015-08-13 21:34:26,161 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0007 being deleted.
2015-08-13 21:34:26,334 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:26,350 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:26,937 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:28,704 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:29,183 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:29,566 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:29,966 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:31,023 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:31,025 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:31,579 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:32,673 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:33,430 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:34,210 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:34,430 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:34,973 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:36,354 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:36,716 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:39,126 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:39,193 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:39,501 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:40,036 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:40,527 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:41,578 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:43,919 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:44,558 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:44,773 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:44,799 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0002 being deleted.
2015-08-13 21:34:45,521 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:46,862 WARN mapred.TaskTracker (TaskTracker.java:statusUpdate(3350)) - Failed validating JVM
java.io.IOException: JvmValidate Failed. Ignoring request from task: attempt_20150813213408963_0009_m_000001_0, with JvmId: jvm_20150813213408963_0009_m_212273002
at org.apache.hadoop.mapred.TaskTracker.validateJVM(TaskTracker.java:3278)
at org.apache.hadoop.mapred.TaskTracker.statusUpdate(TaskTracker.java:3348)
at sun.reflect.GeneratedMethodAccessor30.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:563)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1388)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1384)
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:1121)
at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1382)
2015-08-13 21:34:46,889 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:47,369 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:48,243 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:48,446 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:48,668 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:49,436 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:49,797 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:50,604 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0003 being deleted.
2015-08-13 21:34:51,137 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:53,864 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:54,546 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:34:57,829 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:00,103 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first1/_temporary
2015-08-13 21:35:00,104 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first1
2015-08-13 21:35:00,104 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second1
2015-08-13 21:35:00,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] at least one sink is marked for delete
2015-08-13 21:35:00,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 21:35:00,108 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting
2015-08-13 21:35:00,109 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first1"]
2015-08-13 21:35:00,109 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second1"]
2015-08-13 21:35:00,109 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] parallel execution is enabled: true
2015-08-13 21:35:00,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting jobs: 1
2015-08-13 21:35:00,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] allocating threads: 1
2015-08-13 21:35:00,111 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] starting step: (1/1) ...elcascadeplatform/second1
2015-08-13 21:35:00,266 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:00,706 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] submitted hadoop job: job_20150813213408963_0013
2015-08-13 21:35:00,706 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0013
2015-08-13 21:35:01,133 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:01,703 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0011 being deleted.
2015-08-13 21:35:02,640 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first2/_temporary
2015-08-13 21:35:02,642 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first2
2015-08-13 21:35:02,642 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second2
2015-08-13 21:35:02,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] at least one sink is marked for delete
2015-08-13 21:35:02,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 21:35:02,645 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting
2015-08-13 21:35:02,646 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/first2"]
2015-08-13 21:35:02,646 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second2"]
2015-08-13 21:35:02,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] parallel execution is enabled: true
2015-08-13 21:35:02,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting jobs: 1
2015-08-13 21:35:02,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] allocating threads: 1
2015-08-13 21:35:02,648 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] starting step: (1/1) ...elcascadeplatform/second2
2015-08-13 21:35:03,069 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0012 being deleted.
2015-08-13 21:35:03,375 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:03,569 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] submitted hadoop job: job_20150813213408963_0014
2015-08-13 21:35:03,569 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0014
2015-08-13 21:35:03,937 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:04,141 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:04,870 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:13,795 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:13,806 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:14,378 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:14,388 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:16,760 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:22,755 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second1/_temporary
2015-08-13 21:35:22,756 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second1
2015-08-13 21:35:22,903 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:24,509 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0013 being deleted.
2015-08-13 21:35:25,370 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:27,522 WARN mapred.TaskTracker (TaskTracker.java:purgeJob(2062)) - Unknown job job_20150813213408963_0014 being deleted.
2015-08-13 21:35:27,526 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second2/_temporary
2015-08-13 21:35:27,527 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second2
2015-08-13 21:35:27,527 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-08-13 21:35:27,528 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] at least one sink is marked for delete
2015-08-13 21:35:27,528 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-13 21:35:27,531 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-13 21:35:27,531 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second2"]
2015-08-13 21:35:27,532 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/second1"]
2015-08-13 21:35:27,532 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/third"]
2015-08-13 21:35:27,533 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-13 21:35:27,533 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-08-13 21:35:27,534 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-08-13 21:35:27,535 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...llelcascadeplatform/third
2015-08-13 21:35:27,813 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:28,455 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_20150813213408963_0015
2015-08-13 21:35:28,455 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://localhost:47457/jobdetails.jsp?jobid=job_20150813213408963_0015
2015-08-13 21:35:29,834 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:29,984 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:35:31,262 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:36:06,138 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/parallelcascadeplatform/third/_temporary
2015-08-13 21:36:06,139 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-08-13 21:36:06,212 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/first1
2015-08-13 21:36:06,214 WARN mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143
2015-08-13 21:36:06,228 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/second2
2015-08-13 21:36:06,244 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/third
2015-08-13 21:36:06,250 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/second1
2015-08-13 21:36:06,266 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/parallelcascadeplatform/first2