2016-05-18 07:41:19,003 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 07:41:19,034 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 07:41:19,071 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 07:41:20,072 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-18 07:41:20,759 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 07:41:25,327 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 07:41:25,544 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 07:41:25,713 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 07:41:25,881 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 07:41:42,974 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 07:41:43,070 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:41:43,072 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-18 07:41:43,136 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 28B0E23A961C4540BCA8992979AB7663
2016-05-18 07:41:43,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.117
2016-05-18 07:41:43,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:41:43,295 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-18 07:41:43,437 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 07:41:43,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:41:43,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:41:43,447 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-05-18 07:41:43,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:41:43,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:41:43,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:41:43,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-05-18 07:41:44,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0001
2016-05-18 07:41:44,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0001/
2016-05-18 07:42:03,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000006 is : 143
2016-05-18 07:42:04,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000005 is : 143
2016-05-18 07:42:04,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000004 is : 143
2016-05-18 07:42:04,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000003 is : 143
2016-05-18 07:42:13,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000008 is : 143
2016-05-18 07:42:13,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000007 is : 143
2016-05-18 07:42:13,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0001_01_000009 is : 143
2016-05-18 07:42:15,261 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2016-05-18 07:42:15,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:31.812, using cpu time: 00:09.940
2016-05-18 07:42:15,307 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-05-18 07:42:15,346 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:42:15,346 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-18 07:42:15,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-05-18 07:42:15,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:42:15,419 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-18 07:42:15,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:42:15,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:42:15,454 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-05-18 07:42:15,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:42:15,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:42:15,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:42:15,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-05-18 07:42:15,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0002
2016-05-18 07:42:15,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0002/
2016-05-18 07:42:38,284 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000006 is : 143
2016-05-18 07:42:39,349 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000004 is : 143
2016-05-18 07:42:39,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000003 is : 143
2016-05-18 07:42:39,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000002 is : 143
2016-05-18 07:42:39,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000005 is : 143
2016-05-18 07:42:49,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000008 is : 143
2016-05-18 07:42:49,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000007 is : 143
2016-05-18 07:42:49,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0002_01_000009 is : 143
2016-05-18 07:42:51,108 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2016-05-18 07:42:51,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:35.652, using cpu time: 00:11.610
2016-05-18 07:42:51,144 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain
2016-05-18 07:42:51,178 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:42:51,179 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-18 07:42:51,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 07:42:51,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:42:51,241 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-18 07:42:51,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:42:51,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:42:51,260 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2016-05-18 07:42:51,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:42:51,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:42:51,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:42:51,262 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-05-18 07:42:51,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0003
2016-05-18 07:42:51,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0003/
2016-05-18 07:43:14,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000003 is : 143
2016-05-18 07:43:15,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000002 is : 143
2016-05-18 07:43:15,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000006 is : 143
2016-05-18 07:43:15,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000004 is : 143
2016-05-18 07:43:15,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000005 is : 143
2016-05-18 07:43:25,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000007 is : 143
2016-05-18 07:43:25,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000009 is : 143
2016-05-18 07:43:25,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0003_01_000008 is : 143
2016-05-18 07:43:26,905 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2016-05-18 07:43:26,907 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:35.644, using cpu time: 00:10.790
2016-05-18 07:43:26,950 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple
2016-05-18 07:43:27,006 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:43:27,006 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-18 07:43:27,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 07:43:27,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:43:27,069 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-18 07:43:27,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 07:43:27,100 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.6.x/build/classes/test/data/upper.txt"]
2016-05-18 07:43:27,100 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.6.x/build/classes/test/data/lower.txt"]
2016-05-18 07:43:27,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-05-18 07:43:27,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 07:43:27,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 07:43:27,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 07:43:27,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-18 07:43:27,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463557297472_0004
2016-05-18 07:43:27,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0004/
2016-05-18 07:43:58,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000002 is : 143
2016-05-18 07:43:59,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000008 is : 143
2016-05-18 07:43:59,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000009 is : 143
2016-05-18 07:43:59,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000004 is : 143
2016-05-18 07:43:59,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000006 is : 143
2016-05-18 07:43:59,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000007 is : 143
2016-05-18 07:43:59,645 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000003 is : 143
2016-05-18 07:44:08,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000011 is : 143
2016-05-18 07:44:08,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000010 is : 143
2016-05-18 07:44:09,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0004_01_000012 is : 143
2016-05-18 07:44:10,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-18 07:44:10,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:43.309, using cpu time: 00:13.720
2016-05-18 07:44:10,456 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-05-18 07:44:10,602 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:44:10,602 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-18 07:44:10,658 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 07:44:10,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:44:10,661 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-18 07:44:10,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:44:10,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:44:10,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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-05-18 07:44:10,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:44:10,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:44:10,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:44:10,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-05-18 07:44:10,887 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0005
2016-05-18 07:44:10,887 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0005/
2016-05-18 07:44:34,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000002 is : 143
2016-05-18 07:44:34,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000003 is : 143
2016-05-18 07:44:34,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000006 is : 143
2016-05-18 07:44:35,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000004 is : 143
2016-05-18 07:44:35,172 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000005 is : 143
2016-05-18 07:44:44,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000008 is : 143
2016-05-18 07:44:45,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000007 is : 143
2016-05-18 07:44:45,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0005_01_000009 is : 143
2016-05-18 07:44:46,882 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2016-05-18 07:44:46,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:36.189, using cpu time: 00:12.320
2016-05-18 07:44:46,906 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-05-18 07:44:46,934 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:44:46,935 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-18 07:44:46,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 07:44:46,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:44:46,978 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-18 07:44:47,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:44:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:44:47,003 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-05-18 07:44:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:44:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:44:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:44:47,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-05-18 07:44:47,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0006
2016-05-18 07:44:47,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0006/
2016-05-18 07:45:11,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000005 is : 143
2016-05-18 07:45:11,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000006 is : 143
2016-05-18 07:45:12,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000003 is : 143
2016-05-18 07:45:12,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000002 is : 143
2016-05-18 07:45:12,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000004 is : 143
2016-05-18 07:45:22,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000007 is : 143
2016-05-18 07:45:22,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000008 is : 143
2016-05-18 07:45:22,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0006_01_000009 is : 143
2016-05-18 07:45:24,184 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2016-05-18 07:45:24,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:37.180, using cpu time: 00:12.250
2016-05-18 07:45:24,211 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-05-18 07:45:24,249 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:45:24,249 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-18 07:45:24,324 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 07:45:24,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:45:24,326 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-18 07:45:24,355 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 07:45:24,355 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.6.x/build/classes/test/data/upper.txt"]
2016-05-18 07:45:24,355 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.6.x/build/classes/test/data/lower.txt"]
2016-05-18 07:45:24,355 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.6.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 07:45:24,355 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-18 07:45:24,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 07:45:24,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 07:45:24,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 07:45:24,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-18 07:45:24,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463557297472_0007
2016-05-18 07:45:24,511 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0007/
2016-05-18 07:45:55,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000010 is : 143
2016-05-18 07:45:58,389 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000003 is : 143
2016-05-18 07:45:58,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000008 is : 143
2016-05-18 07:45:58,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000005 is : 143
2016-05-18 07:45:58,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000002 is : 143
2016-05-18 07:45:58,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000009 is : 143
2016-05-18 07:45:59,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000004 is : 143
2016-05-18 07:45:59,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000006 is : 143
2016-05-18 07:45:59,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000007 is : 143
2016-05-18 07:46:06,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000011 is : 143
2016-05-18 07:46:07,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000013 is : 143
2016-05-18 07:46:07,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0007_01_000012 is : 143
2016-05-18 07:46:08,510 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-18 07:46:08,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:44.149, using cpu time: 00:15.630
2016-05-18 07:46:08,555 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-05-18 07:46:08,579 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:46:08,580 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-18 07:46:08,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-18 07:46:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 07:46:08,642 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-18 07:46:08,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 07:46:08,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:46:08,672 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-05-18 07:46:08,672 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-05-18 07:46:08,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 07:46:08,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-18 07:46:08,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-18 07:46:08,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-18 07:46:08,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0008
2016-05-18 07:46:08,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0008/
2016-05-18 07:46:33,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0008_01_000003 is : 143
2016-05-18 07:46:33,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0008_01_000005 is : 143
2016-05-18 07:46:33,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0008_01_000004 is : 143
2016-05-18 07:46:34,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0008_01_000002 is : 143
2016-05-18 07:46:34,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0008_01_000006 is : 143
2016-05-18 07:46:35,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2016-05-18 07:46:35,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2016-05-18 07:46:35,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0009
2016-05-18 07:46:35,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0010
2016-05-18 07:46:35,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0010/
2016-05-18 07:46:35,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0009/
2016-05-18 07:47:00,476 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0009_01_000005 is : 143
2016-05-18 07:47:00,583 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0009_01_000002 is : 143
2016-05-18 07:47:00,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0009_01_000006 is : 143
2016-05-18 07:47:01,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0009_01_000003 is : 143
2016-05-18 07:47:02,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0009_01_000004 is : 143
2016-05-18 07:47:26,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0010_01_000003 is : 143
2016-05-18 07:47:27,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0010_01_000006 is : 143
2016-05-18 07:47:27,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0010_01_000005 is : 143
2016-05-18 07:47:27,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0010_01_000002 is : 143
2016-05-18 07:47:27,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0010_01_000004 is : 143
2016-05-18 07:47:28,948 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2016-05-18 07:47:28,949 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2016-05-18 07:47:28,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 01:20.272, using cpu time: 00:17.470
2016-05-18 07:47:28,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-05-18 07:47:28,995 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-05-18 07:47:29,019 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:47:29,020 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-18 07:47:29,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-18 07:47:29,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 07:47:29,087 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-18 07:47:29,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting
2016-05-18 07:47:29,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:47:29,117 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2016-05-18 07:47:29,117 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2016-05-18 07:47:29,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] parallel execution of steps is enabled: true
2016-05-18 07:47:29,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executing total steps: 3
2016-05-18 07:47:29,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] allocating management threads: 3
2016-05-18 07:47:29,120 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (1/3)
2016-05-18 07:47:29,235 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463557297472_0011
2016-05-18 07:47:29,235 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0011/
2016-05-18 07:47:52,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000003 is : 143
2016-05-18 07:47:53,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000002 is : 143
2016-05-18 07:47:53,239 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000006 is : 143
2016-05-18 07:47:53,866 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000005 is : 143
2016-05-18 07:47:53,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000004 is : 143
2016-05-18 07:48:03,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000009 is : 143
2016-05-18 07:48:03,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000007 is : 143
2016-05-18 07:48:03,845 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0011_01_000008 is : 143
2016-05-18 07:48:04,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout1
2016-05-18 07:48:04,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout2
2016-05-18 07:48:05,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463557297472_0012
2016-05-18 07:48:05,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0012/
2016-05-18 07:48:05,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463557297472_0013
2016-05-18 07:48:05,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0013/
2016-05-18 07:48:10,351 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463557297472_0011_01_000001
2016-05-18 07:48:25,396 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0012_01_000003 is : 143
2016-05-18 07:48:25,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0012_01_000002 is : 143
2016-05-18 07:48:46,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000003 is : 143
2016-05-18 07:48:46,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000002 is : 143
2016-05-18 07:48:46,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000004 is : 143
2016-05-18 07:48:56,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000007 is : 143
2016-05-18 07:48:56,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000005 is : 143
2016-05-18 07:48:57,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0013_01_000006 is : 143
2016-05-18 07:48:58,805 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2016-05-18 07:48:58,807 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2016-05-18 07:48:58,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] completed in: 01:29.685, using cpu time: 00:22.560
2016-05-18 07:48:58,893 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1
2016-05-18 07:48:58,904 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2
2016-05-18 07:48:58,938 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:48:58,938 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-18 07:48:58,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 07:48:58,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 07:48:58,983 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-18 07:48:59,000 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 07:48:59,000 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.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:48:59,000 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2016-05-18 07:48:59,000 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2016-05-18 07:48:59,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 07:48:59,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 2
2016-05-18 07:48:59,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 2
2016-05-18 07:48:59,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/2) ...platform/testSplit/split2
2016-05-18 07:48:59,002 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/2) ...platform/testSplit/split1
2016-05-18 07:48:59,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0014
2016-05-18 07:48:59,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0014/
2016-05-18 07:48:59,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0015
2016-05-18 07:48:59,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0015/
2016-05-18 07:49:22,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0014_01_000002 is : 143
2016-05-18 07:49:22,852 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0014_01_000003 is : 143
2016-05-18 07:49:22,989 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0014_01_000004 is : 143
2016-05-18 07:49:23,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0014_01_000006 is : 143
2016-05-18 07:49:23,682 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0014_01_000005 is : 143
2016-05-18 07:49:49,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0015_01_000004 is : 143
2016-05-18 07:49:49,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0015_01_000002 is : 143
2016-05-18 07:49:49,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0015_01_000005 is : 143
2016-05-18 07:49:49,540 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0015_01_000003 is : 143
2016-05-18 07:49:49,564 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0015_01_000006 is : 143
2016-05-18 07:49:50,762 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2/_temporary
2016-05-18 07:49:50,763 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1/_temporary
2016-05-18 07:49:50,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:51.760, using cpu time: 00:09.520
2016-05-18 07:49:50,801 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split2
2016-05-18 07:49:50,810 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split1
2016-05-18 07:49:50,833 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:49:50,833 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-18 07:49:50,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 07:49:50,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:49:50,875 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-18 07:49:50,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 07:49:50,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:49:50,901 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-18 07:49:50,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-18 07:49:50,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-18 07:49:50,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-18 07:49:50,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-18 07:49:51,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463557297472_0016
2016-05-18 07:49:51,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0016/
2016-05-18 07:50:15,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000005 is : 143
2016-05-18 07:50:15,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000003 is : 143
2016-05-18 07:50:15,730 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000002 is : 143
2016-05-18 07:50:16,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000004 is : 143
2016-05-18 07:50:24,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000009 is : 143
2016-05-18 07:50:25,572 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000008 is : 143
2016-05-18 07:50:25,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0016_01_000007 is : 143
2016-05-18 07:50:26,865 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-18 07:50:26,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:35.962, using cpu time: 00:11.820
2016-05-18 07:50:26,887 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-18 07:50:26,919 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:50:26,920 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-18 07:50:26,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 07:50:26,945 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:50:26,945 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-18 07:50:26,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:50:26,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:50:26,956 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2016-05-18 07:50:26,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:50:26,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:50:26,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:50:26,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-05-18 07:50:27,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0017
2016-05-18 07:50:27,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0017/
2016-05-18 07:50:50,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0017_01_000006 is : 143
2016-05-18 07:50:51,682 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0017_01_000004 is : 143
2016-05-18 07:50:51,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0017_01_000005 is : 143
2016-05-18 07:50:51,982 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0017_01_000002 is : 143
2016-05-18 07:50:53,159 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy/_temporary
2016-05-18 07:50:53,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:26.201, using cpu time: 00:05.610
2016-05-18 07:50:53,195 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testCopy/copy
2016-05-18 07:50:53,230 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:50:53,231 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-18 07:50:53,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-18 07:50:53,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:50:53,295 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-18 07:50:53,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:50:53,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:50:53,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2016-05-18 07:50:53,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:50:53,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:50:53,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:50:53,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-05-18 07:50:53,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0018
2016-05-18 07:50:53,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0018/
2016-05-18 07:51:16,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000006 is : 143
2016-05-18 07:51:17,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000003 is : 143
2016-05-18 07:51:17,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000004 is : 143
2016-05-18 07:51:17,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000002 is : 143
2016-05-18 07:51:17,561 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000005 is : 143
2016-05-18 07:51:27,211 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000007 is : 143
2016-05-18 07:51:27,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000008 is : 143
2016-05-18 07:51:27,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0018_01_000009 is : 143
2016-05-18 07:51:28,794 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none/_temporary
2016-05-18 07:51:28,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:35.479, using cpu time: 00:11.210
2016-05-18 07:51:28,818 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNone/none
2016-05-18 07:51:28,841 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:51:28,841 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-18 07:51:28,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 07:51:28,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:51:28,877 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-18 07:51:28,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:51:28,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:51:28,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2016-05-18 07:51:28,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:51:28,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:51:28,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:51:28,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-05-18 07:51:28,996 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0019
2016-05-18 07:51:28,997 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0019/
2016-05-18 07:51:53,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000005 is : 143
2016-05-18 07:51:53,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000006 is : 143
2016-05-18 07:51:53,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000003 is : 143
2016-05-18 07:51:53,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000002 is : 143
2016-05-18 07:51:53,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000004 is : 143
2016-05-18 07:52:03,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000008 is : 143
2016-05-18 07:52:03,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000007 is : 143
2016-05-18 07:52:03,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0019_01_000009 is : 143
2016-05-18 07:52:04,448 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap/_temporary
2016-05-18 07:52:04,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:35.554, using cpu time: 00:11.500
2016-05-18 07:52:04,472 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSwap/swap
2016-05-18 07:52:04,507 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:52:04,508 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-18 07:52:04,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 07:52:04,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:52:04,535 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-18 07:52:04,547 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:52:04,548 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.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:52:04,548 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-05-18 07:52:04,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:52:04,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:52:04,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:52:04,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-05-18 07:52:04,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0020
2016-05-18 07:52:04,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0020/
2016-05-18 07:52:28,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0020_01_000002 is : 143
2016-05-18 07:52:28,730 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0020_01_000005 is : 143
2016-05-18 07:52:28,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0020_01_000003 is : 143
2016-05-18 07:52:29,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0020_01_000006 is : 143
2016-05-18 07:52:29,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0020_01_000004 is : 143
2016-05-18 07:52:30,390 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2016-05-18 07:52:30,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:25.841, using cpu time: 00:05.080
2016-05-18 07:52:30,417 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter
2016-05-18 07:52:30,452 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:52:30,452 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-18 07:52:30,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 07:52:30,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:52:30,496 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-18 07:52:30,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:52:30,515 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.6.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 07:52:30,515 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-05-18 07:52:30,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:52:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:52:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:52:30,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-05-18 07:52:30,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0021
2016-05-18 07:52:30,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0021/
2016-05-18 07:52:54,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0021_01_000004 is : 143
2016-05-18 07:52:54,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0021_01_000005 is : 143
2016-05-18 07:52:54,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0021_01_000002 is : 143
2016-05-18 07:52:54,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0021_01_000003 is : 143
2016-05-18 07:52:55,819 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2016-05-18 07:52:55,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:25.299, using cpu time: 00:05.630
2016-05-18 07:52:55,845 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped
2016-05-18 07:52:55,870 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:52:55,871 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-18 07:52:55,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-18 07:52:55,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 07:52:55,926 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-18 07:52:55,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:52:55,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:52:55,959 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2016-05-18 07:52:55,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:52:55,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 07:52:55,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-18 07:52:55,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 07:52:56,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0022
2016-05-18 07:52:56,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0022/
2016-05-18 07:53:19,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000005 is : 143
2016-05-18 07:53:20,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000006 is : 143
2016-05-18 07:53:20,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000002 is : 143
2016-05-18 07:53:20,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000004 is : 143
2016-05-18 07:53:20,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000003 is : 143
2016-05-18 07:53:29,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000008 is : 143
2016-05-18 07:53:30,232 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000009 is : 143
2016-05-18 07:53:30,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0022_01_000007 is : 143
2016-05-18 07:53:31,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2016-05-18 07:53:31,848 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0023
2016-05-18 07:53:31,848 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0023/
2016-05-18 07:53:51,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000002 is : 143
2016-05-18 07:53:51,280 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000003 is : 143
2016-05-18 07:53:51,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000004 is : 143
2016-05-18 07:54:00,512 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000005 is : 143
2016-05-18 07:54:00,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000007 is : 143
2016-05-18 07:54:00,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0023_01_000006 is : 143
2016-05-18 07:54:02,128 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall/_temporary
2016-05-18 07:54:02,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 01:06.166, using cpu time: 00:17.270
2016-05-18 07:54:02,155 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall
2016-05-18 07:54:02,173 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:54:02,173 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-18 07:54:02,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 07:54:02,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:54:02,211 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-18 07:54:02,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 07:54:02,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:54:02,225 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-05-18 07:54:02,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-18 07:54:02,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-18 07:54:02,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-18 07:54:02,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-05-18 07:54:02,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463557297472_0024
2016-05-18 07:54:02,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0024/
2016-05-18 07:54:25,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000006 is : 143
2016-05-18 07:54:26,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000005 is : 143
2016-05-18 07:54:26,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000004 is : 143
2016-05-18 07:54:26,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000002 is : 143
2016-05-18 07:54:35,969 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000007 is : 143
2016-05-18 07:54:36,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000008 is : 143
2016-05-18 07:54:36,558 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0024_01_000009 is : 143
2016-05-18 07:54:37,765 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2016-05-18 07:54:37,767 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:35.539, using cpu time: 00:11.110
2016-05-18 07:54:37,787 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-05-18 07:54:37,810 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:54:37,810 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-18 07:54:37,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 07:54:37,851 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 07:54:37,851 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-18 07:54:37,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting
2016-05-18 07:54:37,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-05-18 07:54:37,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-05-18 07:54:37,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-05-18 07:54:37,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] parallel execution of steps is enabled: true
2016-05-18 07:54:37,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executing total steps: 1
2016-05-18 07:54:37,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] allocating management threads: 1
2016-05-18 07:54:37,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-05-18 07:54:37,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] submitted hadoop job: job_1463557297472_0025
2016-05-18 07:54:37,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0025/
2016-05-18 07:55:07,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000003 is : 143
2016-05-18 07:55:09,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000002 is : 143
2016-05-18 07:55:09,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000008 is : 143
2016-05-18 07:55:10,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000006 is : 143
2016-05-18 07:55:10,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000009 is : 143
2016-05-18 07:55:10,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000004 is : 143
2016-05-18 07:55:10,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000007 is : 143
2016-05-18 07:55:10,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000005 is : 143
2016-05-18 07:55:18,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000011 is : 143
2016-05-18 07:55:18,684 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000012 is : 143
2016-05-18 07:55:18,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0025_01_000010 is : 143
2016-05-18 07:55:20,012 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2016-05-18 07:55:20,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] completed in: 00:42.141, using cpu time: 00:16.390
2016-05-18 07:55:20,033 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-05-18 07:55:20,055 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:55:20,055 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-18 07:55:20,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 07:55:20,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:55:20,085 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-18 07:55:20,096 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:55:20,097 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.6.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 07:55:20,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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-05-18 07:55:20,097 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:55:20,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:55:20,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:55:20,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-05-18 07:55:20,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0026
2016-05-18 07:55:20,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0026/
2016-05-18 07:55:43,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0026_01_000006 is : 143
2016-05-18 07:55:44,278 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0026_01_000002 is : 143
2016-05-18 07:55:44,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0026_01_000004 is : 143
2016-05-18 07:55:44,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0026_01_000003 is : 143
2016-05-18 07:55:45,703 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2016-05-18 07:55:45,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:25.605, using cpu time: 00:05.670
2016-05-18 07:55:45,729 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-05-18 07:55:45,753 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:55:45,753 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-18 07:55:45,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 07:55:45,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 07:55:45,802 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-18 07:55:45,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:55:45,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:55:45,828 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-05-18 07:55:45,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:55:45,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 07:55:45,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-18 07:55:45,831 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 07:55:45,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0027
2016-05-18 07:55:45,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0027/
2016-05-18 07:56:09,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000002 is : 143
2016-05-18 07:56:09,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000006 is : 143
2016-05-18 07:56:10,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000003 is : 143
2016-05-18 07:56:10,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000004 is : 143
2016-05-18 07:56:10,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000005 is : 143
2016-05-18 07:56:20,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000009 is : 143
2016-05-18 07:56:20,086 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000007 is : 143
2016-05-18 07:56:20,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0027_01_000008 is : 143
2016-05-18 07:56:21,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2016-05-18 07:56:21,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0028
2016-05-18 07:56:21,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0028/
2016-05-18 07:56:40,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000002 is : 143
2016-05-18 07:56:41,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000003 is : 143
2016-05-18 07:56:41,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000004 is : 143
2016-05-18 07:56:51,653 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000006 is : 143
2016-05-18 07:56:51,749 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000005 is : 143
2016-05-18 07:56:52,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0028_01_000007 is : 143
2016-05-18 07:56:53,237 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2016-05-18 07:56:53,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 01:07.407, using cpu time: 00:19.840
2016-05-18 07:56:53,258 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup
2016-05-18 07:56:53,280 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:56:53,281 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-18 07:56:53,349 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-05-18 07:56:53,350 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 07:56:53,351 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-18 07:56:53,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting
2016-05-18 07:56:53,392 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.6.x/build/classes/test/data/lower.txt"]
2016-05-18 07:56:53,392 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-18 07:56:53,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] parallel execution of steps is enabled: true
2016-05-18 07:56:53,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executing total steps: 2
2016-05-18 07:56:53,393 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] allocating management threads: 2
2016-05-18 07:56:53,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (1/2)
2016-05-18 07:56:53,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463557297472_0029
2016-05-18 07:56:53,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0029/
2016-05-18 07:57:21,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000006 is : 143
2016-05-18 07:57:21,313 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000007 is : 143
2016-05-18 07:57:22,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000008 is : 143
2016-05-18 07:57:22,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000004 is : 143
2016-05-18 07:57:22,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000002 is : 143
2016-05-18 07:57:22,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000003 is : 143
2016-05-18 07:57:31,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000009 is : 143
2016-05-18 07:57:31,991 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000011 is : 143
2016-05-18 07:57:32,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0029_01_000010 is : 143
2016-05-18 07:57:33,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-18 07:57:33,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463557297472_0030
2016-05-18 07:57:33,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0030/
2016-05-18 07:58:03,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000003 is : 143
2016-05-18 07:58:04,019 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000002 is : 143
2016-05-18 07:58:05,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000007 is : 143
2016-05-18 07:58:05,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000005 is : 143
2016-05-18 07:58:05,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000006 is : 143
2016-05-18 07:58:05,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000009 is : 143
2016-05-18 07:58:05,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000008 is : 143
2016-05-18 07:58:13,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000010 is : 143
2016-05-18 07:58:13,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000011 is : 143
2016-05-18 07:58:13,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0030_01_000012 is : 143
2016-05-18 07:58:14,999 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-18 07:58:15,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] completed in: 01:21.605, using cpu time: 00:28.220
2016-05-18 07:58:15,020 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-18 07:58:15,041 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:58:15,042 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-18 07:58:15,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 07:58:15,072 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:58:15,072 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-18 07:58:15,080 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:58:15,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:58:15,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2016-05-18 07:58:15,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:58:15,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:58:15,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:58:15,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-05-18 07:58:15,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0031
2016-05-18 07:58:15,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0031/
2016-05-18 07:58:39,139 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0031_01_000003 is : 143
2016-05-18 07:58:40,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0031_01_000006 is : 143
2016-05-18 07:58:40,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0031_01_000005 is : 143
2016-05-18 07:58:40,301 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0031_01_000004 is : 143
2016-05-18 07:58:41,482 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2016-05-18 07:58:41,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:26.400, using cpu time: 00:05.670
2016-05-18 07:58:41,508 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testReplace/replace
2016-05-18 07:58:41,542 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:58:41,542 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-18 07:58:41,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 07:58:41,569 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:58:41,569 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-18 07:58:41,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:58:41,577 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.6.x/build/classes/test/data/extra+lower+upper.txt"]
2016-05-18 07:58:41,578 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-05-18 07:58:41,579 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:58:41,579 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:58:41,579 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:58:41,580 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-05-18 07:58:41,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0032
2016-05-18 07:58:41,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0032/
2016-05-18 07:58:47,234 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463557297472_0031_01_000001
2016-05-18 07:59:05,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0032_01_000003 is : 143
2016-05-18 07:59:05,981 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0032_01_000006 is : 143
2016-05-18 07:59:06,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0032_01_000004 is : 143
2016-05-18 07:59:06,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0032_01_000005 is : 143
2016-05-18 07:59:06,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0032_01_000002 is : 143
2016-05-18 07:59:07,582 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2016-05-18 07:59:07,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:26.003, using cpu time: 00:05.450
2016-05-18 07:59:07,607 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-05-18 07:59:07,630 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:59:07,630 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-18 07:59:07,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 07:59:07,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 07:59:07,653 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-18 07:59:07,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 07:59:07,670 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.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:59:07,670 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2016-05-18 07:59:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 07:59:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 07:59:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 07:59:07,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-05-18 07:59:07,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0033
2016-05-18 07:59:07,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0033/
2016-05-18 07:59:32,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0033_01_000006 is : 143
2016-05-18 07:59:32,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0033_01_000005 is : 143
2016-05-18 07:59:32,140 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0033_01_000004 is : 143
2016-05-18 07:59:32,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0033_01_000002 is : 143
2016-05-18 07:59:32,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0033_01_000003 is : 143
2016-05-18 07:59:33,692 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter/_temporary
2016-05-18 07:59:33,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:26.018, using cpu time: 00:04.940
2016-05-18 07:59:33,728 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilter/filter
2016-05-18 07:59:33,754 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 07:59:33,756 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-18 07:59:33,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.089
2016-05-18 07:59:33,852 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2016-05-18 07:59:33,852 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-18 07:59:33,905 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting
2016-05-18 07:59:33,905 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.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 07:59:33,905 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2016-05-18 07:59:33,906 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-05-18 07:59:33,906 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-05-18 07:59:33,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] parallel execution of steps is enabled: true
2016-05-18 07:59:33,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executing total steps: 5
2016-05-18 07:59:33,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] allocating management threads: 5
2016-05-18 07:59:33,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (1/5)
2016-05-18 07:59:34,010 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463557297472_0034
2016-05-18 07:59:34,010 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0034/
2016-05-18 07:59:39,008 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463557297472_0033_01_000001
2016-05-18 07:59:57,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000006 is : 143
2016-05-18 07:59:57,730 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000003 is : 143
2016-05-18 07:59:57,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000004 is : 143
2016-05-18 07:59:58,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000002 is : 143
2016-05-18 08:00:07,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000007 is : 143
2016-05-18 08:00:07,921 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000008 is : 143
2016-05-18 08:00:08,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0034_01_000009 is : 143
2016-05-18 08:00:09,539 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (3/5) ...rm/testSplitMultiple/left
2016-05-18 08:00:09,539 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (2/5)
2016-05-18 08:00:09,714 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463557297472_0036
2016-05-18 08:00:09,715 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0036/
2016-05-18 08:00:09,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463557297472_0035
2016-05-18 08:00:09,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0035/
2016-05-18 08:00:29,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0035_01_000003 is : 143
2016-05-18 08:00:29,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0035_01_000004 is : 143
2016-05-18 08:00:49,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0036_01_000002 is : 143
2016-05-18 08:00:50,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0036_01_000004 is : 143
2016-05-18 08:01:00,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0036_01_000006 is : 143
2016-05-18 08:01:00,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0036_01_000005 is : 143
2016-05-18 08:01:01,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0036_01_000007 is : 143
2016-05-18 08:01:02,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (5/5) ...stSplitMultiple/rightleft
2016-05-18 08:01:02,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (4/5) ...tSplitMultiple/rightright
2016-05-18 08:01:02,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463557297472_0037
2016-05-18 08:01:02,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0037/
2016-05-18 08:01:02,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463557297472_0038
2016-05-18 08:01:02,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0038/
2016-05-18 08:01:22,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0037_01_000003 is : 143
2016-05-18 08:01:22,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0037_01_000004 is : 143
2016-05-18 08:01:22,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0037_01_000002 is : 143
2016-05-18 08:01:42,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0038_01_000003 is : 143
2016-05-18 08:01:42,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0038_01_000002 is : 143
2016-05-18 08:01:43,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0038_01_000004 is : 143
2016-05-18 08:01:44,226 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left/_temporary
2016-05-18 08:01:44,235 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2016-05-18 08:01:44,236 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2016-05-18 08:01:44,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] completed in: 02:10.317, using cpu time: 00:28.910
2016-05-18 08:01:44,288 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left
2016-05-18 08:01:44,294 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright
2016-05-18 08:01:44,299 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft
2016-05-18 08:01:44,323 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:01:44,323 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-18 08:01:44,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 08:01:44,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 08:01:44,358 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-18 08:01:44,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting
2016-05-18 08:01:44,372 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.6.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/upper.txt"]]]
2016-05-18 08:01:44,373 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-05-18 08:01:44,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] parallel execution of steps is enabled: true
2016-05-18 08:01:44,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executing total steps: 1
2016-05-18 08:01:44,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] allocating management threads: 1
2016-05-18 08:01:44,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-05-18 08:01:44,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] submitted hadoop job: job_1463557297472_0039
2016-05-18 08:01:44,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0039/
2016-05-18 08:02:10,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000002 is : 143
2016-05-18 08:02:10,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000003 is : 143
2016-05-18 08:02:11,034 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000004 is : 143
2016-05-18 08:02:11,209 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000007 is : 143
2016-05-18 08:02:11,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000006 is : 143
2016-05-18 08:02:11,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000005 is : 143
2016-05-18 08:02:20,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000010 is : 143
2016-05-18 08:02:20,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000008 is : 143
2016-05-18 08:02:20,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0039_01_000009 is : 143
2016-05-18 08:02:21,819 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2016-05-18 08:02:21,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] completed in: 00:37.445, using cpu time: 00:12.010
2016-05-18 08:02:21,840 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat
2016-05-18 08:02:21,863 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:02:21,863 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-18 08:02:21,950 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 08:02:21,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 08:02:21,952 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-18 08:02:21,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 08:02:21,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 08:02:21,979 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-05-18 08:02:21,979 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-05-18 08:02:21,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 08:02:21,980 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-18 08:02:21,980 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-18 08:02:21,984 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-18 08:02:22,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0040
2016-05-18 08:02:22,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0040/
2016-05-18 08:02:46,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000003 is : 143
2016-05-18 08:02:46,564 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000002 is : 143
2016-05-18 08:02:46,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000004 is : 143
2016-05-18 08:02:46,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000005 is : 143
2016-05-18 08:02:46,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000006 is : 143
2016-05-18 08:02:57,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000009 is : 143
2016-05-18 08:02:57,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000007 is : 143
2016-05-18 08:02:57,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0040_01_000008 is : 143
2016-05-18 08:02:58,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2016-05-18 08:02:58,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2016-05-18 08:02:59,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0041
2016-05-18 08:02:59,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0041/
2016-05-18 08:02:59,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463557297472_0042
2016-05-18 08:02:59,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0042/
2016-05-18 08:03:18,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0041_01_000002 is : 143
2016-05-18 08:03:18,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0041_01_000003 is : 143
2016-05-18 08:03:18,668 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0041_01_000004 is : 143
2016-05-18 08:03:39,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0042_01_000002 is : 143
2016-05-18 08:03:39,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0042_01_000003 is : 143
2016-05-18 08:03:40,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0042_01_000004 is : 143
2016-05-18 08:03:41,445 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2016-05-18 08:03:41,446 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2016-05-18 08:03:41,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 01:19.464, using cpu time: 00:17.060
2016-05-18 08:03:41,485 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-05-18 08:03:41,491 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-05-18 08:03:41,511 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:03:41,512 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-18 08:03:41,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 08:03:41,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:03:41,536 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-18 08:03:41,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 08:03:41,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-05-18 08:03:41,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2016-05-18 08:03:41,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 08:03:41,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 08:03:41,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 08:03:41,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-05-18 08:03:41,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463557297472_0043
2016-05-18 08:03:41,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:49410/proxy/application_1463557297472_0043/
2016-05-18 08:04:05,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0043_01_000002 is : 143
2016-05-18 08:04:05,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0043_01_000003 is : 143
2016-05-18 08:04:05,818 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0043_01_000004 is : 143
2016-05-18 08:04:06,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0043_01_000006 is : 143
2016-05-18 08:04:06,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463557297472_0043_01_000005 is : 143
2016-05-18 08:04:07,431 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2016-05-18 08:04:07,433 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:25.885, using cpu time: 00:05.730
2016-05-18 08:04:07,477 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup