2015-08-12 19:23:52,014 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 19:23:52,105 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.tap.TapPlatformTest, with platform: hadoop2-mr1
2015-08-12 19:23:52,163 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-08-12 19:23:53,696 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-12 19:23:54,382 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 19:24:00,434 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 19:24:00,914 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 19:24:01,159 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 19:24:01,425 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 19:24:18,673 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-08-12 19:24:18,861 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:24:18,863 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:24:19,050 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 607C4B0865184758B549B69A9A6AE9E8
2015-08-12 19:24:19,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.111
2015-08-12 19:24:19,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:24:19,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:24:19,420 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 19:24:19,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] starting
2015-08-12 19:24:19,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] source: Hfs["TextDelimited[['number', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-08-12 19:24:19,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/partitioned"]"]["cascading.tap.partition.DelimitedPartition@28b83264"]
2015-08-12 19:24:19,439 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] parallel execution of steps is enabled: true
2015-08-12 19:24:19,439 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] executing total steps: 1
2015-08-12 19:24:19,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] allocating management threads: 1
2015-08-12 19:24:19,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] starting step: (1/1) ...TextDelimited/partitioned
2015-08-12 19:24:20,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] submitted hadoop job: job_1439432653152_0001
2015-08-12 19:24:20,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0001/
2015-08-12 19:24:53,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0001_01_000002 is : 143
2015-08-12 19:24:55,990 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/partitioned/_temporary
2015-08-12 19:24:55,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] completed in: 00:36.540, using cpu time: 00:06.840
2015-08-12 19:24:56,051 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:24:56,052 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:24:56,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 19:24:56,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:24:56,105 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:24:56,171 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] starting
2015-08-12 19:24:56,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] source: PartitionTap["Hfs["TextDelimited[['upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/partitioned"]"]["cascading.tap.partition.DelimitedPartition@28b83264"]
2015-08-12 19:24:56,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] sink: Hfs["TextDelimited[['number', 'lower', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/final"]
2015-08-12 19:24:56,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] parallel execution of steps is enabled: true
2015-08-12 19:24:56,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] executing total steps: 1
2015-08-12 19:24:56,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] allocating management threads: 1
2015-08-12 19:24:56,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] starting step: (1/1) ...ionTapTextDelimited/final
2015-08-12 19:24:57,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] submitted hadoop job: job_1439432653152_0002
2015-08-12 19:24:57,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0002/
2015-08-12 19:26:03,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000015 is : 143
2015-08-12 19:26:41,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000006 is : 143
2015-08-12 19:26:46,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000005 is : 143
2015-08-12 19:26:56,349 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439432653152_0002_01_000028
2015-08-12 19:26:57,291 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439432653152_0002_01_000029
2015-08-12 19:27:15,634 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000017 is : 143
2015-08-12 19:27:16,993 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000016 is : 143
2015-08-12 19:27:48,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000019 is : 143
2015-08-12 19:27:52,728 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000024 is : 143
2015-08-12 19:27:53,043 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000026 is : 143
2015-08-12 19:27:53,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0002_01_000027 is : 143
2015-08-12 19:27:55,827 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/final/_temporary
2015-08-12 19:27:55,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] completed in: 02:59.652, using cpu time: 00:51.220
2015-08-12 19:27:56,765 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/partitioned
2015-08-12 19:27:56,788 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testPartitionTapTextDelimited/final
2015-08-12 19:27:57,281 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:27:57,288 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:27:57,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2015-08-12 19:27:57,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:27:57,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:27:57,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:27:57,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 19:27:57,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSideFileCollector/sidefile/direct"]
2015-08-12 19:27:57,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-08-12 19:27:57,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:27:57,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:27:57,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Collector/sidefile/direct
2015-08-12 19:27:57,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1439432653152_0003
2015-08-12 19:27:57,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0003/
2015-08-12 19:28:01,082 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439432653152_0002_01_000001
2015-08-12 19:28:25,939 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0003_01_000002 is : 143
2015-08-12 19:28:27,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0003_01_000003 is : 143
2015-08-12 19:28:28,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0003_01_000004 is : 143
2015-08-12 19:28:34,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0003_01_000006 is : 143
2015-08-12 19:28:36,089 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSideFileCollector/sidefile/direct/_temporary
2015-08-12 19:28:36,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:38.642, using cpu time: 00:06.240
2015-08-12 19:28:36,198 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testSideFileCollector/sidefile/indirect
2015-08-12 19:28:36,212 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testSideFileCollector/sidefile/direct
2015-08-12 19:28:36,295 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:28:36,296 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:28:36,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:28:36,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:28:36,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:28:36,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-08-12 19:28:36,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/unexpectedEndOfFile.gz"]
2015-08-12 19:28:36,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorExceptionHandling/testTupleEntrySchemeIteratorExceptionHandling"]
2015-08-12 19:28:36,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-08-12 19:28:36,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 1
2015-08-12 19:28:36,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 1
2015-08-12 19:28:36,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/1) ...IteratorExceptionHandling
2015-08-12 19:28:36,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439432653152_0004
2015-08-12 19:28:36,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0004/
2015-08-12 19:28:51,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0004_01_000002 is : 143
2015-08-12 19:28:52,640 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorExceptionHandling/testTupleEntrySchemeIteratorExceptionHandling/_temporary
2015-08-12 19:28:52,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:16.272, using cpu time: 00:01.130
2015-08-12 19:28:52,687 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorExceptionHandling/testTupleEntrySchemeIteratorExceptionHandling
2015-08-12 19:28:52,756 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:28:52,758 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:28:52,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-08-12 19:28:52,802 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:28:52,803 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:28:52,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:28:52,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 19:28:52,820 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->['second', 'first', 'third']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSinkDeclaredFields/declaredsinks"]
2015-08-12 19:28:52,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-08-12 19:28:52,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:28:52,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:28:52,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...laredFields/declaredsinks
2015-08-12 19:28:53,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1439432653152_0005
2015-08-12 19:28:53,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0005/
2015-08-12 19:29:23,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0005_01_000004 is : 143
2015-08-12 19:29:23,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0005_01_000005 is : 143
2015-08-12 19:29:24,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSinkDeclaredFields/declaredsinks/_temporary
2015-08-12 19:29:24,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:32.031, using cpu time: 00:04.560
2015-08-12 19:29:24,968 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testSinkDeclaredFields/declaredsinks
2015-08-12 19:29:25,067 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:29:25,069 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:29:25,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:29:25,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:29:25,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:29:25,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:29:25,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 19:29:25,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: MultiSinkTap[[Hfs["TextLine[['offset', 'line']->['number', 'lower']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testMultiSinkTap/multisink/lhs"], Hfs["TextLine[['offset', 'line']->['number', 'upper']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testMultiSinkTap/multisink/rhs"]]]
2015-08-12 19:29:25,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-08-12 19:29:25,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:29:25,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:29:25,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...0F70544D19690BACC1EDA628C
2015-08-12 19:29:25,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1439432653152_0006
2015-08-12 19:29:25,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0006/
2015-08-12 19:29:52,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0006_01_000006 is : 143
2015-08-12 19:29:55,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0006_01_000004 is : 143
2015-08-12 19:29:56,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0006_01_000005 is : 143
2015-08-12 19:29:56,682 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0006_01_000003 is : 143
2015-08-12 19:29:56,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0006_01_000002 is : 143
2015-08-12 19:29:58,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:32.992, using cpu time: 00:05.870
2015-08-12 19:29:58,233 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testMultiSinkTap/multisink/rhs
2015-08-12 19:29:58,282 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testMultiSinkTap/multisink/lhs
2015-08-12 19:29:58,339 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:29:58,341 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:29:58,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-08-12 19:29:58,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:29:58,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:29:58,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:29:58,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-08-12 19:29:58,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['first', 'second', 'third']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSinkUnknown/unknownsinks"]
2015-08-12 19:29:58,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-08-12 19:29:58,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:29:58,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:29:58,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tSinkUnknown/unknownsinks
2015-08-12 19:29:58,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1439432653152_0007
2015-08-12 19:29:58,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0007/
2015-08-12 19:30:26,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0007_01_000005 is : 143
2015-08-12 19:30:27,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0007_01_000003 is : 143
2015-08-12 19:30:28,746 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testSinkUnknown/unknownsinks/_temporary
2015-08-12 19:30:28,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:30.332, using cpu time: 00:04.580
2015-08-12 19:30:28,834 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testSinkUnknown/unknownsinks
2015-08-12 19:30:28,898 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:30:28,899 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:30:28,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2015-08-12 19:30:28,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:30:28,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:30:28,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-08-12 19:30:28,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/unexpectedEndOfFile.gz"]
2015-08-12 19:30:28,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorEOFException/testTupleEntrySchemeIteratorEOFException"]
2015-08-12 19:30:28,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-08-12 19:30:28,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 1
2015-08-12 19:30:28,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 1
2015-08-12 19:30:28,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/1) ...chemeIteratorEOFException
2015-08-12 19:30:29,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439432653152_0008
2015-08-12 19:30:29,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:36623/proxy/application_1439432653152_0008/
2015-08-12 19:30:49,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0008_01_000003 is : 143
2015-08-12 19:30:56,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439432653152_0008_01_000004 is : 143
2015-08-12 19:31:05,806 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] hadoop job job_1439432653152_0008 state at FAILED
2015-08-12 19:31:05,816 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] failure info: Task failed task_1439432653152_0008_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-08-12 19:31:05,857 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] task completion events identify failed tasks
2015-08-12 19:31:05,857 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] task completion events count: 4
2015-08-12 19:31:05,861 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_1439432653152_0008_m_000000_0, Status : FAILED
2015-08-12 19:31:05,862 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_1439432653152_0008_m_000000_1, Status : FAILED
2015-08-12 19:31:05,863 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_1439432653152_0008_m_000000_2, Status : FAILED
2015-08-12 19:31:05,864 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [] event = Task Id : attempt_1439432653152_0008_m_000000_3, Status : TIPFAILED
2015-08-12 19:31:05,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopping all jobs
2015-08-12 19:31:05,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopping: (1/1) ...chemeIteratorEOFException
2015-08-12 19:31:05,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] stopped all jobs
2015-08-12 19:31:05,939 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorEOFException/testTupleEntrySchemeIteratorEOFException/_temporary
2015-08-12 19:31:05,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:36.967
2015-08-12 19:31:05,952 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/tapplatform/testTupleEntrySchemeIteratorEOFException/testTupleEntrySchemeIteratorEOFException