2016-05-17 21:43:16,954 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 21:43:16,977 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-17 21:43:17,006 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 21:43:17,737 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
2016-05-17 21:43:18,312 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 21:43:23,153 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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.
2016-05-17 21:43:24,387 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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.
2016-05-17 21:43:25,525 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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.
2016-05-17 21:43:26,661 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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.
2016-05-17 21:43:29,208 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 21:43:29,297 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:43:29,299 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:43:29,369 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: A1120F38F07D45BDA681C0C93CC821CA
2016-05-17 21:43:29,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.107
2016-05-17 21:43:29,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:43:29,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:43:29,689 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 21:43:29,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:43:29,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:43:29,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-05-17 21:43:29,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:43:29,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:43:29,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:43:29,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-05-17 21:43:31,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0001
2016-05-17 21:43:31,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0001/
2016-05-17 21:43:48,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000006 is : 143
2016-05-17 21:43:49,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000002 is : 143
2016-05-17 21:43:49,311 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000005 is : 143
2016-05-17 21:43:49,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000004 is : 143
2016-05-17 21:43:58,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000009 is : 143
2016-05-17 21:43:58,830 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000007 is : 143
2016-05-17 21:43:59,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0001_01_000008 is : 143
2016-05-17 21:44:00,329 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2016-05-17 21:44:00,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:30.636, using cpu time: 00:08.650
2016-05-17 21:44:00,383 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-05-17 21:44:00,418 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:44:00,418 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:44:00,490 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-05-17 21:44:00,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:44:00,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:44:00,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:44:00,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:44:00,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-05-17 21:44:00,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:44:00,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:44:00,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:44:00,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-05-17 21:44:00,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0002
2016-05-17 21:44:00,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0002/
2016-05-17 21:44:18,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000006 is : 143
2016-05-17 21:44:18,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000004 is : 143
2016-05-17 21:44:18,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000003 is : 143
2016-05-17 21:44:18,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000002 is : 143
2016-05-17 21:44:28,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000007 is : 143
2016-05-17 21:44:29,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000009 is : 143
2016-05-17 21:44:29,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0002_01_000008 is : 143
2016-05-17 21:44:30,369 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2016-05-17 21:44:30,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:29.839, using cpu time: 00:09.410
2016-05-17 21:44:30,396 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain
2016-05-17 21:44:30,424 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:44:30,424 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:44:30,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-17 21:44:30,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:44:30,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:44:30,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:44:30,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:44:30,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2016-05-17 21:44:30,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:44:30,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:44:30,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:44:30,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-05-17 21:44:30,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0003
2016-05-17 21:44:30,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0003/
2016-05-17 21:44:48,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000002 is : 143
2016-05-17 21:44:48,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000006 is : 143
2016-05-17 21:44:48,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000005 is : 143
2016-05-17 21:44:48,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000003 is : 143
2016-05-17 21:44:58,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000007 is : 143
2016-05-17 21:44:59,132 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000008 is : 143
2016-05-17 21:44:59,209 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0003_01_000009 is : 143
2016-05-17 21:45:00,493 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2016-05-17 21:45:00,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:29.978, using cpu time: 00:09.610
2016-05-17 21:45:00,551 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple
2016-05-17 21:45:00,629 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:45:00,629 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:45:00,695 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-17 21:45:00,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:45:00,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:45:00,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:45:00,721 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:45:00,722 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:45:00,722 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-05-17 21:45:00,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 21:45:00,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 21:45:00,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 21:45:00,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-17 21:45:00,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463521401294_0004
2016-05-17 21:45:00,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0004/
2016-05-17 21:45:24,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000007 is : 143
2016-05-17 21:45:25,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000006 is : 143
2016-05-17 21:45:25,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000002 is : 143
2016-05-17 21:45:25,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000008 is : 143
2016-05-17 21:45:25,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000004 is : 143
2016-05-17 21:45:26,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000005 is : 143
2016-05-17 21:45:26,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000009 is : 143
2016-05-17 21:45:26,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000003 is : 143
2016-05-17 21:45:34,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000010 is : 143
2016-05-17 21:45:34,908 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000012 is : 143
2016-05-17 21:45:35,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0004_01_000011 is : 143
2016-05-17 21:45:36,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-17 21:45:36,861 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:36.135, using cpu time: 00:12.850
2016-05-17 21:45:36,897 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-05-17 21:45:37,023 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:45:37,023 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:45:37,072 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 21:45:37,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:45:37,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:45:37,096 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:45:37,097 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:45:37,097 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-05-17 21:45:37,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:45:37,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:45:37,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:45:37,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-05-17 21:45:37,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0005
2016-05-17 21:45:37,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0005/
2016-05-17 21:45:54,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000005 is : 143
2016-05-17 21:45:55,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000003 is : 143
2016-05-17 21:45:55,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000002 is : 143
2016-05-17 21:45:55,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000004 is : 143
2016-05-17 21:45:55,827 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000006 is : 143
2016-05-17 21:46:04,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000008 is : 143
2016-05-17 21:46:04,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000007 is : 143
2016-05-17 21:46:04,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0005_01_000009 is : 143
2016-05-17 21:46:06,051 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2016-05-17 21:46:06,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:28.952, using cpu time: 00:10.660
2016-05-17 21:46:06,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-05-17 21:46:06,099 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:06,099 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:46:06,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 21:46:06,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:06,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:06,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:06,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:46:06,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-05-17 21:46:06,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:46:06,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:46:06,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:46:06,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-05-17 21:46:06,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0006
2016-05-17 21:46:06,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0006/
2016-05-17 21:46:23,864 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000006 is : 143
2016-05-17 21:46:23,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000003 is : 143
2016-05-17 21:46:24,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000004 is : 143
2016-05-17 21:46:24,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000005 is : 143
2016-05-17 21:46:24,528 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000002 is : 143
2016-05-17 21:46:33,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000007 is : 143
2016-05-17 21:46:33,624 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000008 is : 143
2016-05-17 21:46:33,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0006_01_000009 is : 143
2016-05-17 21:46:35,092 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2016-05-17 21:46:35,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:28.914, using cpu time: 00:09.430
2016-05-17 21:46:35,113 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-05-17 21:46:35,162 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:35,162 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:46:35,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-17 21:46:35,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:35,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:35,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:46:35,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:46:35,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:46:35,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:46:35,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-17 21:46:35,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 21:46:35,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 21:46:35,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 21:46:35,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-17 21:46:35,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463521401294_0007
2016-05-17 21:46:35,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0007/
2016-05-17 21:47:02,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000005 is : 143
2016-05-17 21:47:02,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000003 is : 143
2016-05-17 21:47:02,506 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000008 is : 143
2016-05-17 21:47:02,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000004 is : 143
2016-05-17 21:47:02,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000009 is : 143
2016-05-17 21:47:02,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000002 is : 143
2016-05-17 21:47:02,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000006 is : 143
2016-05-17 21:47:03,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000007 is : 143
2016-05-17 21:47:03,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000010 is : 143
2016-05-17 21:47:12,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000012 is : 143
2016-05-17 21:47:12,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000011 is : 143
2016-05-17 21:47:12,691 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0007_01_000013 is : 143
2016-05-17 21:47:13,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-17 21:47:13,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:38.624, using cpu time: 00:14.060
2016-05-17 21:47:13,953 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-05-17 21:47:13,975 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:13,975 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:47:14,034 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-17 21:47:14,036 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:47:14,036 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:14,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-17 21:47:14,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:47:14,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-05-17 21:47:14,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-05-17 21:47:14,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-17 21:47:14,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-17 21:47:14,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-17 21:47:14,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-17 21:47:14,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0008
2016-05-17 21:47:14,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0008/
2016-05-17 21:47:31,486 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0008_01_000002 is : 143
2016-05-17 21:47:31,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0008_01_000003 is : 143
2016-05-17 21:47:32,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0008_01_000005 is : 143
2016-05-17 21:47:32,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0008_01_000004 is : 143
2016-05-17 21:47:32,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0008_01_000006 is : 143
2016-05-17 21:47:33,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2016-05-17 21:47:33,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2016-05-17 21:47:33,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0009
2016-05-17 21:47:33,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0009/
2016-05-17 21:47:34,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0010
2016-05-17 21:47:34,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0010/
2016-05-17 21:47:54,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0009_01_000004 is : 143
2016-05-17 21:47:54,194 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0009_01_000005 is : 143
2016-05-17 21:47:54,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0009_01_000003 is : 143
2016-05-17 21:47:54,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0009_01_000006 is : 143
2016-05-17 21:48:09,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0010_01_000006 is : 143
2016-05-17 21:48:09,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0010_01_000003 is : 143
2016-05-17 21:48:09,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0010_01_000005 is : 143
2016-05-17 21:48:09,845 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0010_01_000007 is : 143
2016-05-17 21:48:10,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0010_01_000004 is : 143
2016-05-17 21:48:11,488 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2016-05-17 21:48:11,489 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2016-05-17 21:48:11,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:57.406, using cpu time: 00:14.240
2016-05-17 21:48:11,526 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-05-17 21:48:11,541 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-05-17 21:48:11,563 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:48:11,563 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:48:11,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:48:11,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-17 21:48:11,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:48:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting
2016-05-17 21:48:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:48:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2016-05-17 21:48:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2016-05-17 21:48:11,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] parallel execution of steps is enabled: true
2016-05-17 21:48:11,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executing total steps: 3
2016-05-17 21:48:11,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] allocating management threads: 3
2016-05-17 21:48:11,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (1/3)
2016-05-17 21:48:11,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463521401294_0011
2016-05-17 21:48:11,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0011/
2016-05-17 21:48:29,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000003 is : 143
2016-05-17 21:48:29,528 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000004 is : 143
2016-05-17 21:48:29,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000005 is : 143
2016-05-17 21:48:29,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000006 is : 143
2016-05-17 21:48:30,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000002 is : 143
2016-05-17 21:48:39,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000009 is : 143
2016-05-17 21:48:39,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000008 is : 143
2016-05-17 21:48:39,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0011_01_000007 is : 143
2016-05-17 21:48:40,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout2
2016-05-17 21:48:40,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout1
2016-05-17 21:48:40,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463521401294_0012
2016-05-17 21:48:40,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0012/
2016-05-17 21:48:40,997 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463521401294_0013
2016-05-17 21:48:40,997 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0013/
2016-05-17 21:48:56,993 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0012_01_000002 is : 143
2016-05-17 21:48:57,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0012_01_000003 is : 143
2016-05-17 21:49:11,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0013_01_000003 is : 143
2016-05-17 21:49:12,313 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0013_01_000002 is : 143
2016-05-17 21:49:12,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0013_01_000004 is : 143
2016-05-17 21:49:13,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0012_01_000006 is : 143
2016-05-17 21:49:14,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0012_01_000007 is : 143
2016-05-17 21:49:14,247 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0012_01_000005 is : 143
2016-05-17 21:49:15,495 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2016-05-17 21:49:15,497 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2016-05-17 21:49:15,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] completed in: 01:03.830, using cpu time: 00:19.720
2016-05-17 21:49:15,578 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1
2016-05-17 21:49:15,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2
2016-05-17 21:49:15,606 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:49:15,607 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:49:15,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 21:49:15,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:49:15,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:49:15,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-17 21:49:15,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:49:15,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2016-05-17 21:49:15,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2016-05-17 21:49:15,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-17 21:49:15,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 2
2016-05-17 21:49:15,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 2
2016-05-17 21:49:15,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/2) ...platform/testSplit/split1
2016-05-17 21:49:15,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/2) ...platform/testSplit/split2
2016-05-17 21:49:15,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0014
2016-05-17 21:49:15,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0014/
2016-05-17 21:49:15,852 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0015
2016-05-17 21:49:15,852 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0015/
2016-05-17 21:49:43,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0014_01_000002 is : 143
2016-05-17 21:49:44,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0014_01_000003 is : 143
2016-05-17 21:49:46,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0014_01_000005 is : 143
2016-05-17 21:49:46,972 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0014_01_000006 is : 143
2016-05-17 21:49:47,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0014_01_000004 is : 143
2016-05-17 21:49:50,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0015_01_000003 is : 143
2016-05-17 21:49:51,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0015_01_000004 is : 143
2016-05-17 21:49:52,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0015_01_000006 is : 143
2016-05-17 21:49:52,270 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0015_01_000002 is : 143
2016-05-17 21:49:53,498 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2/_temporary
2016-05-17 21:49:53,499 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1/_temporary
2016-05-17 21:49:53,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:37.831, using cpu time: 00:09.040
2016-05-17 21:49:53,534 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split2
2016-05-17 21:49:53,545 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split1
2016-05-17 21:49:53,566 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:49:53,566 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:49:53,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 21:49:53,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:49:53,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:49:53,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-17 21:49:53,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:49:53,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-17 21:49:53,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-17 21:49:53,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-17 21:49:53,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-17 21:49:53,632 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-17 21:49:53,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463521401294_0016
2016-05-17 21:49:53,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0016/
2016-05-17 21:50:13,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000006 is : 143
2016-05-17 21:50:13,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000004 is : 143
2016-05-17 21:50:13,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000003 is : 143
2016-05-17 21:50:13,191 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000002 is : 143
2016-05-17 21:50:22,486 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000007 is : 143
2016-05-17 21:50:22,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000008 is : 143
2016-05-17 21:50:22,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0016_01_000009 is : 143
2016-05-17 21:50:24,199 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-17 21:50:24,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:30.566, using cpu time: 00:09.660
2016-05-17 21:50:24,219 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-17 21:50:24,255 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:50:24,256 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:50:24,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 21:50:24,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:50:24,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:50:24,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:50:24,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:50:24,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2016-05-17 21:50:24,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:50:24,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:50:24,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:50:24,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-05-17 21:50:24,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0017
2016-05-17 21:50:24,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0017/
2016-05-17 21:50:41,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0017_01_000004 is : 143
2016-05-17 21:50:41,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0017_01_000005 is : 143
2016-05-17 21:50:42,107 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0017_01_000003 is : 143
2016-05-17 21:50:42,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0017_01_000006 is : 143
2016-05-17 21:50:42,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0017_01_000002 is : 143
2016-05-17 21:50:43,724 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy/_temporary
2016-05-17 21:50:43,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.435, using cpu time: 00:04.300
2016-05-17 21:50:43,748 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testCopy/copy
2016-05-17 21:50:43,781 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:50:43,781 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:50:43,831 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-17 21:50:43,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:50:43,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:50:43,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:50:43,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:50:43,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2016-05-17 21:50:43,852 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:50:43,853 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:50:43,853 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:50:43,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-05-17 21:50:43,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0018
2016-05-17 21:50:43,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0018/
2016-05-17 21:51:00,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000002 is : 143
2016-05-17 21:51:01,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000005 is : 143
2016-05-17 21:51:01,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000004 is : 143
2016-05-17 21:51:01,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000006 is : 143
2016-05-17 21:51:10,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000007 is : 143
2016-05-17 21:51:10,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000009 is : 143
2016-05-17 21:51:11,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0018_01_000008 is : 143
2016-05-17 21:51:12,273 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none/_temporary
2016-05-17 21:51:12,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:28.421, using cpu time: 00:09.310
2016-05-17 21:51:12,301 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNone/none
2016-05-17 21:51:12,322 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:51:12,322 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:51:12,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 21:51:12,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:51:12,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:51:12,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:51:12,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:51:12,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2016-05-17 21:51:12,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:51:12,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:51:12,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:51:12,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-05-17 21:51:12,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0019
2016-05-17 21:51:12,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0019/
2016-05-17 21:51:30,049 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000004 is : 143
2016-05-17 21:51:30,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000003 is : 143
2016-05-17 21:51:30,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000002 is : 143
2016-05-17 21:51:30,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000005 is : 143
2016-05-17 21:51:30,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000006 is : 143
2016-05-17 21:51:40,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000007 is : 143
2016-05-17 21:51:40,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000008 is : 143
2016-05-17 21:51:40,470 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0019_01_000009 is : 143
2016-05-17 21:51:41,698 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap/_temporary
2016-05-17 21:51:41,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:29.322, using cpu time: 00:09.330
2016-05-17 21:51:41,717 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSwap/swap
2016-05-17 21:51:41,738 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:51:41,738 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:51:41,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 21:51:41,767 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:51:41,767 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:51:41,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:51:41,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:51:41,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-05-17 21:51:41,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:51:41,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:51:41,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:51:41,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-05-17 21:51:41,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0020
2016-05-17 21:51:41,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0020/
2016-05-17 21:51:59,557 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0020_01_000004 is : 143
2016-05-17 21:51:59,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0020_01_000006 is : 143
2016-05-17 21:51:59,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0020_01_000005 is : 143
2016-05-17 21:51:59,639 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0020_01_000003 is : 143
2016-05-17 21:51:59,943 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0020_01_000002 is : 143
2016-05-17 21:52:01,151 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2016-05-17 21:52:01,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.363, using cpu time: 00:04.290
2016-05-17 21:52:01,186 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter
2016-05-17 21:52:01,228 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:52:01,228 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:52:01,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 21:52:01,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:52:01,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:52:01,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:52:01,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:52:01,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-05-17 21:52:01,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:52:01,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:52:01,268 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:52:01,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-05-17 21:52:01,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0021
2016-05-17 21:52:01,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0021/
2016-05-17 21:52:19,201 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0021_01_000006 is : 143
2016-05-17 21:52:19,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0021_01_000004 is : 143
2016-05-17 21:52:19,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0021_01_000005 is : 143
2016-05-17 21:52:19,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0021_01_000002 is : 143
2016-05-17 21:52:20,941 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2016-05-17 21:52:20,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.673, using cpu time: 00:04.700
2016-05-17 21:52:20,964 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped
2016-05-17 21:52:20,987 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:52:20,987 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:52:21,052 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-17 21:52:21,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:52:21,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:52:21,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:52:21,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:52:21,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2016-05-17 21:52:21,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:52:21,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-17 21:52:21,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-17 21:52:21,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-17 21:52:21,207 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0022
2016-05-17 21:52:21,207 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0022/
2016-05-17 21:52:38,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000003 is : 143
2016-05-17 21:52:39,092 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000002 is : 143
2016-05-17 21:52:39,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000006 is : 143
2016-05-17 21:52:39,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000004 is : 143
2016-05-17 21:52:39,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000005 is : 143
2016-05-17 21:52:48,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000009 is : 143
2016-05-17 21:52:48,561 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000008 is : 143
2016-05-17 21:52:48,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0022_01_000007 is : 143
2016-05-17 21:52:49,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2016-05-17 21:52:49,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0023
2016-05-17 21:52:49,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0023/
2016-05-17 21:53:03,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000003 is : 143
2016-05-17 21:53:03,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000002 is : 143
2016-05-17 21:53:03,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000004 is : 143
2016-05-17 21:53:12,105 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000005 is : 143
2016-05-17 21:53:12,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000007 is : 143
2016-05-17 21:53:12,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0023_01_000006 is : 143
2016-05-17 21:53:13,971 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall/_temporary
2016-05-17 21:53:13,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:52.880, using cpu time: 00:15.710
2016-05-17 21:53:13,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall
2016-05-17 21:53:14,003 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:53:14,003 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:53:14,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 21:53:14,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:53:14,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:53:14,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-17 21:53:14,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:53:14,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-05-17 21:53:14,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-17 21:53:14,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-17 21:53:14,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-17 21:53:14,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-05-17 21:53:14,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463521401294_0024
2016-05-17 21:53:14,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0024/
2016-05-17 21:53:32,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000003 is : 143
2016-05-17 21:53:32,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000005 is : 143
2016-05-17 21:53:32,359 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000002 is : 143
2016-05-17 21:53:32,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000004 is : 143
2016-05-17 21:53:32,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000006 is : 143
2016-05-17 21:53:42,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000007 is : 143
2016-05-17 21:53:43,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000008 is : 143
2016-05-17 21:53:43,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0024_01_000009 is : 143
2016-05-17 21:53:44,768 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2016-05-17 21:53:44,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:30.709, using cpu time: 00:10.050
2016-05-17 21:53:44,789 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-05-17 21:53:44,817 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:53:44,818 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:53:44,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 21:53:44,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:53:44,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:53:44,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting
2016-05-17 21:53:44,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:53:44,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:53:44,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-05-17 21:53:44,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] parallel execution of steps is enabled: true
2016-05-17 21:53:44,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executing total steps: 1
2016-05-17 21:53:44,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] allocating management threads: 1
2016-05-17 21:53:44,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-05-17 21:53:44,998 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] submitted hadoop job: job_1463521401294_0025
2016-05-17 21:53:44,998 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0025/
2016-05-17 21:54:09,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000003 is : 143
2016-05-17 21:54:09,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000002 is : 143
2016-05-17 21:54:09,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000005 is : 143
2016-05-17 21:54:09,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000004 is : 143
2016-05-17 21:54:09,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000009 is : 143
2016-05-17 21:54:09,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000007 is : 143
2016-05-17 21:54:10,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000008 is : 143
2016-05-17 21:54:10,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000006 is : 143
2016-05-17 21:54:18,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000010 is : 143
2016-05-17 21:54:18,434 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000012 is : 143
2016-05-17 21:54:18,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0025_01_000011 is : 143
2016-05-17 21:54:19,923 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2016-05-17 21:54:19,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] completed in: 00:35.046, using cpu time: 00:12.170
2016-05-17 21:54:19,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-05-17 21:54:19,975 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:54:19,976 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:54:20,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 21:54:20,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:54:20,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:54:20,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:54:20,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:54:20,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-05-17 21:54:20,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:54:20,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:54:20,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:54:20,022 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-05-17 21:54:20,143 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0026
2016-05-17 21:54:20,143 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0026/
2016-05-17 21:54:37,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0026_01_000005 is : 143
2016-05-17 21:54:37,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0026_01_000002 is : 143
2016-05-17 21:54:38,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0026_01_000004 is : 143
2016-05-17 21:54:38,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0026_01_000003 is : 143
2016-05-17 21:54:39,867 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2016-05-17 21:54:39,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.846, using cpu time: 00:04.790
2016-05-17 21:54:39,890 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-05-17 21:54:39,913 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:54:39,914 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:54:39,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-17 21:54:39,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:54:39,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:54:40,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:54:40,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:54:40,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-05-17 21:54:40,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:54:40,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-17 21:54:40,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-17 21:54:40,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-17 21:54:40,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0027
2016-05-17 21:54:40,132 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0027/
2016-05-17 21:54:57,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000006 is : 143
2016-05-17 21:54:57,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000005 is : 143
2016-05-17 21:54:57,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000003 is : 143
2016-05-17 21:54:57,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000004 is : 143
2016-05-17 21:54:58,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000002 is : 143
2016-05-17 21:55:07,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000008 is : 143
2016-05-17 21:55:07,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000007 is : 143
2016-05-17 21:55:07,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0027_01_000009 is : 143
2016-05-17 21:55:08,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2016-05-17 21:55:08,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0028
2016-05-17 21:55:08,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0028/
2016-05-17 21:55:22,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000003 is : 143
2016-05-17 21:55:22,795 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000004 is : 143
2016-05-17 21:55:22,919 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000002 is : 143
2016-05-17 21:55:32,827 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000006 is : 143
2016-05-17 21:55:32,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000007 is : 143
2016-05-17 21:55:33,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0028_01_000005 is : 143
2016-05-17 21:55:34,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2016-05-17 21:55:34,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:54.403, using cpu time: 00:17.380
2016-05-17 21:55:34,431 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup
2016-05-17 21:55:34,451 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:55:34,451 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:55:34,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-17 21:55:34,530 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:55:34,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:55:34,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting
2016-05-17 21:55:34,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:55:34,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-17 21:55:34,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] parallel execution of steps is enabled: true
2016-05-17 21:55:34,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executing total steps: 2
2016-05-17 21:55:34,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] allocating management threads: 2
2016-05-17 21:55:34,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (1/2)
2016-05-17 21:55:34,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463521401294_0029
2016-05-17 21:55:34,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0029/
2016-05-17 21:55:56,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000003 is : 143
2016-05-17 21:55:56,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000008 is : 143
2016-05-17 21:55:56,818 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000002 is : 143
2016-05-17 21:55:57,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000006 is : 143
2016-05-17 21:55:57,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000007 is : 143
2016-05-17 21:55:57,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000005 is : 143
2016-05-17 21:55:57,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000004 is : 143
2016-05-17 21:56:06,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000010 is : 143
2016-05-17 21:56:06,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000009 is : 143
2016-05-17 21:56:06,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0029_01_000011 is : 143
2016-05-17 21:56:07,778 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-17 21:56:07,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463521401294_0030
2016-05-17 21:56:07,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0030/
2016-05-17 21:56:32,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000009 is : 143
2016-05-17 21:56:32,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000008 is : 143
2016-05-17 21:56:32,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000007 is : 143
2016-05-17 21:56:33,015 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000004 is : 143
2016-05-17 21:56:33,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000003 is : 143
2016-05-17 21:56:33,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000006 is : 143
2016-05-17 21:56:33,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000002 is : 143
2016-05-17 21:56:33,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000005 is : 143
2016-05-17 21:56:41,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000010 is : 143
2016-05-17 21:56:41,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000011 is : 143
2016-05-17 21:56:42,119 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0030_01_000012 is : 143
2016-05-17 21:56:43,362 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-17 21:56:43,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] completed in: 01:08.804, using cpu time: 00:23.670
2016-05-17 21:56:43,382 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-17 21:56:43,402 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:56:43,402 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:56:43,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 21:56:43,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:56:43,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:56:43,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:56:43,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:56:43,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2016-05-17 21:56:43,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:56:43,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:56:43,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:56:43,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-05-17 21:56:43,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0031
2016-05-17 21:56:43,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0031/
2016-05-17 21:57:01,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0031_01_000006 is : 143
2016-05-17 21:57:01,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0031_01_000003 is : 143
2016-05-17 21:57:01,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0031_01_000005 is : 143
2016-05-17 21:57:01,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0031_01_000002 is : 143
2016-05-17 21:57:01,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0031_01_000004 is : 143
2016-05-17 21:57:03,116 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2016-05-17 21:57:03,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.673, using cpu time: 00:04.540
2016-05-17 21:57:03,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testReplace/replace
2016-05-17 21:57:03,177 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:57:03,178 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:57:03,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-17 21:57:03,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:57:03,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:57:03,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:57:03,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/extra+lower+upper.txt"]
2016-05-17 21:57:03,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-05-17 21:57:03,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:57:03,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:57:03,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:57:03,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-05-17 21:57:03,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0032
2016-05-17 21:57:03,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0032/
2016-05-17 21:57:20,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0032_01_000006 is : 143
2016-05-17 21:57:21,400 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0032_01_000005 is : 143
2016-05-17 21:57:21,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0032_01_000002 is : 143
2016-05-17 21:57:21,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0032_01_000003 is : 143
2016-05-17 21:57:23,181 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2016-05-17 21:57:23,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.967, using cpu time: 00:04.780
2016-05-17 21:57:23,204 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-05-17 21:57:23,236 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:57:23,237 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:57:23,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 21:57:23,261 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:57:23,261 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:57:23,268 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:57:23,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:57:23,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2016-05-17 21:57:23,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 21:57:23,274 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:57:23,274 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:57:23,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-05-17 21:57:23,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0033
2016-05-17 21:57:23,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0033/
2016-05-17 21:57:40,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0033_01_000002 is : 143
2016-05-17 21:57:41,232 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0033_01_000003 is : 143
2016-05-17 21:57:41,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0033_01_000005 is : 143
2016-05-17 21:57:41,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0033_01_000004 is : 143
2016-05-17 21:57:41,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0033_01_000006 is : 143
2016-05-17 21:57:43,053 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter/_temporary
2016-05-17 21:57:43,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.782, using cpu time: 00:04.530
2016-05-17 21:57:43,073 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilter/filter
2016-05-17 21:57:43,097 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:57:43,097 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:57:43,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.109
2016-05-17 21:57:43,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2016-05-17 21:57:43,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:57:43,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting
2016-05-17 21:57:43,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:57:43,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2016-05-17 21:57:43,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-05-17 21:57:43,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-05-17 21:57:43,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] parallel execution of steps is enabled: true
2016-05-17 21:57:43,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executing total steps: 5
2016-05-17 21:57:43,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] allocating management threads: 5
2016-05-17 21:57:43,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (1/5)
2016-05-17 21:57:43,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463521401294_0034
2016-05-17 21:57:43,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0034/
2016-05-17 21:58:00,818 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000006 is : 143
2016-05-17 21:58:01,478 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000002 is : 143
2016-05-17 21:58:01,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000005 is : 143
2016-05-17 21:58:01,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000004 is : 143
2016-05-17 21:58:10,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000007 is : 143
2016-05-17 21:58:10,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000008 is : 143
2016-05-17 21:58:10,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0034_01_000009 is : 143
2016-05-17 21:58:12,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (2/5)
2016-05-17 21:58:12,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (3/5) ...rm/testSplitMultiple/left
2016-05-17 21:58:12,303 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2016-05-17 21:58:12,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463521401294_0035
2016-05-17 21:58:12,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0035/
2016-05-17 21:58:12,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463521401294_0036
2016-05-17 21:58:12,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0036/
2016-05-17 21:58:13,286 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2016-05-17 21:58:13,287 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2016-05-17 21:58:27,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000002 is : 143
2016-05-17 21:58:27,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000003 is : 143
2016-05-17 21:58:27,688 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000004 is : 143
2016-05-17 21:58:41,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000007 is : 143
2016-05-17 21:58:41,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000005 is : 143
2016-05-17 21:58:42,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0035_01_000006 is : 143
2016-05-17 21:58:44,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (4/5) ...tSplitMultiple/rightright
2016-05-17 21:58:44,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (5/5) ...stSplitMultiple/rightleft
2016-05-17 21:58:44,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463521401294_0038
2016-05-17 21:58:44,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0038/
2016-05-17 21:58:44,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463521401294_0037
2016-05-17 21:58:44,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0037/
2016-05-17 21:58:45,240 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0036_01_000005 is : 143
2016-05-17 21:58:45,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0036_01_000004 is : 143
2016-05-17 21:58:45,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0036_01_000003 is : 143
2016-05-17 21:59:08,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0037_01_000004 is : 143
2016-05-17 21:59:11,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0038_01_000003 is : 143
2016-05-17 21:59:11,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0038_01_000004 is : 143
2016-05-17 21:59:11,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0038_01_000002 is : 143
2016-05-17 21:59:13,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left/_temporary
2016-05-17 21:59:13,173 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2016-05-17 21:59:13,177 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2016-05-17 21:59:13,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] completed in: 01:29.916, using cpu time: 00:25.230
2016-05-17 21:59:13,221 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left
2016-05-17 21:59:13,228 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright
2016-05-17 21:59:13,235 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft
2016-05-17 21:59:13,258 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:59:13,258 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:59:13,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 21:59:13,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:59:13,304 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:59:13,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting
2016-05-17 21:59:13,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]]]
2016-05-17 21:59:13,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-05-17 21:59:13,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] parallel execution of steps is enabled: true
2016-05-17 21:59:13,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executing total steps: 1
2016-05-17 21:59:13,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] allocating management threads: 1
2016-05-17 21:59:13,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-05-17 21:59:13,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] submitted hadoop job: job_1463521401294_0039
2016-05-17 21:59:13,438 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0039/
2016-05-17 21:59:35,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000004 is : 143
2016-05-17 21:59:35,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000006 is : 143
2016-05-17 21:59:36,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000007 is : 143
2016-05-17 21:59:36,241 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000005 is : 143
2016-05-17 21:59:36,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000003 is : 143
2016-05-17 21:59:36,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000002 is : 143
2016-05-17 21:59:45,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000008 is : 143
2016-05-17 21:59:45,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000010 is : 143
2016-05-17 21:59:45,697 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0039_01_000009 is : 143
2016-05-17 21:59:46,889 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2016-05-17 21:59:46,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] completed in: 00:33.570, using cpu time: 00:10.000
2016-05-17 21:59:46,907 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat
2016-05-17 21:59:46,925 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:59:46,926 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 21:59:46,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:59:46,990 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-17 21:59:46,990 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:59:47,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-17 21:59:47,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:59:47,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-05-17 21:59:47,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-05-17 21:59:47,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-17 21:59:47,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-17 21:59:47,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-17 21:59:47,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-17 21:59:47,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0040
2016-05-17 21:59:47,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0040/
2016-05-17 22:00:05,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000005 is : 143
2016-05-17 22:00:06,506 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000004 is : 143
2016-05-17 22:00:06,555 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000003 is : 143
2016-05-17 22:00:06,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000002 is : 143
2016-05-17 22:00:16,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000008 is : 143
2016-05-17 22:00:16,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000009 is : 143
2016-05-17 22:00:16,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0040_01_000007 is : 143
2016-05-17 22:00:18,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2016-05-17 22:00:18,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2016-05-17 22:00:18,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0041
2016-05-17 22:00:18,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0041/
2016-05-17 22:00:18,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463521401294_0042
2016-05-17 22:00:18,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0042/
2016-05-17 22:00:33,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0041_01_000002 is : 143
2016-05-17 22:00:33,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0041_01_000003 is : 143
2016-05-17 22:00:34,657 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0041_01_000004 is : 143
2016-05-17 22:00:40,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0042_01_000002 is : 143
2016-05-17 22:00:41,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0042_01_000004 is : 143
2016-05-17 22:00:41,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0042_01_000003 is : 143
2016-05-17 22:00:42,822 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2016-05-17 22:00:42,824 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2016-05-17 22:00:42,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:55.800, using cpu time: 00:15.260
2016-05-17 22:00:42,858 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-05-17 22:00:42,863 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-05-17 22:00:42,879 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:00:42,880 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:00:42,913 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:00:42,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:00:42,914 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:00:42,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:00:42,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 22:00:42,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2016-05-17 22:00:42,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-17 22:00:42,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 22:00:42,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 22:00:42,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-05-17 22:00:43,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463521401294_0043
2016-05-17 22:00:43,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:47997/proxy/application_1463521401294_0043/
2016-05-17 22:01:00,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0043_01_000002 is : 143
2016-05-17 22:01:00,506 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0043_01_000003 is : 143
2016-05-17 22:01:00,931 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463521401294_0043_01_000005 is : 143
2016-05-17 22:01:02,158 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2016-05-17 22:01:02,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.234, using cpu time: 00:04.930
2016-05-17 22:01:02,200 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup