2016-05-18 04:54:54,126 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 04:54:54,146 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 04:54:54,172 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 04:54:54,920 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 04:54:55,553 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 04:54:56,035 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:54:59,270 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 04:54:59,413 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 04:54:59,524 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 04:54:59,642 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 04:55:11,529 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:55:12,503 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:55:12,503 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:55:16,722 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 04:55:16,827 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:55:16,829 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 04:55:16,894 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: B6DEB5B59F0C4881A3708A2508CF24E0
2016-05-18 04:55:17,043 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.112
2016-05-18 04:55:17,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:55:17,049 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 04:55:17,191 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 04:55:17,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:55:17,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:55:17,194 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-05-18 04:55:17,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 04:55:17,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:55:17,196 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:55:17,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-05-18 04:55:18,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0001
2016-05-18 04:55:18,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0001/
2016-05-18 04:55:36,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000002 is : 143
2016-05-18 04:55:36,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000003 is : 143
2016-05-18 04:55:36,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000005 is : 143
2016-05-18 04:55:37,036 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000004 is : 143
2016-05-18 04:55:37,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000006 is : 143
2016-05-18 04:55:46,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000009 is : 143
2016-05-18 04:55:46,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000008 is : 143
2016-05-18 04:55:47,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0001_01_000007 is : 143
2016-05-18 04:55:48,479 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2016-05-18 04:55:48,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:31.283, using cpu time: 00:09.180
2016-05-18 04:55:48,530 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-05-18 04:55:48,570 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:55:48,571 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 04:55:48,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 04:55:48,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:55:48,648 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 04:55:48,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:55:48,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:55:48,678 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-05-18 04:55:48,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 04:55:48,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:55:48,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:55:48,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-05-18 04:55:48,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0002
2016-05-18 04:55:48,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0002/
2016-05-18 04:56:07,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000002 is : 143
2016-05-18 04:56:07,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000005 is : 143
2016-05-18 04:56:07,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000006 is : 143
2016-05-18 04:56:07,885 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000003 is : 143
2016-05-18 04:56:08,101 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000004 is : 143
2016-05-18 04:56:17,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000007 is : 143
2016-05-18 04:56:18,239 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000008 is : 143
2016-05-18 04:56:18,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0002_01_000009 is : 143
2016-05-18 04:56:19,607 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2016-05-18 04:56:19,608 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:30.926, using cpu time: 00:10.850
2016-05-18 04:56:19,636 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain
2016-05-18 04:56:19,667 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:56:19,668 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 04:56:19,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 04:56:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:56:19,727 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 04:56:19,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:56:19,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:56:19,748 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2016-05-18 04:56:19,748 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 04:56:19,748 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:56:19,748 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:56:19,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-05-18 04:56:19,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0003
2016-05-18 04:56:19,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0003/
2016-05-18 04:56:37,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000006 is : 143
2016-05-18 04:56:38,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000003 is : 143
2016-05-18 04:56:38,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000005 is : 143
2016-05-18 04:56:39,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000002 is : 143
2016-05-18 04:56:48,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000008 is : 143
2016-05-18 04:56:48,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000009 is : 143
2016-05-18 04:56:48,991 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0003_01_000007 is : 143
2016-05-18 04:56:50,269 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2016-05-18 04:56:50,271 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:30.520, using cpu time: 00:10.790
2016-05-18 04:56:50,316 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple
2016-05-18 04:56:50,379 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:56:50,380 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 04:56:50,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 04:56:50,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:56:50,446 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 04:56:50,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 04:56:50,470 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:56:50,470 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:56:50,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-05-18 04:56:50,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 04:56:50,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 04:56:50,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 04:56:50,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-18 04:56:50,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463547311221_0004
2016-05-18 04:56:50,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0004/
2016-05-18 04:57:16,121 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000006 is : 143
2016-05-18 04:57:16,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000009 is : 143
2016-05-18 04:57:16,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000003 is : 143
2016-05-18 04:57:16,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000007 is : 143
2016-05-18 04:57:16,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000005 is : 143
2016-05-18 04:57:17,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000004 is : 143
2016-05-18 04:57:17,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000008 is : 143
2016-05-18 04:57:17,064 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000002 is : 143
2016-05-18 04:57:25,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000010 is : 143
2016-05-18 04:57:25,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000011 is : 143
2016-05-18 04:57:26,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0004_01_000012 is : 143
2016-05-18 04:57:27,597 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-18 04:57:27,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:37.125, using cpu time: 00:13.240
2016-05-18 04:57:27,643 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-05-18 04:57:27,770 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:57:27,770 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 04:57:27,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 04:57:27,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:57:27,830 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 04:57:27,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:57:27,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:57:27,856 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-05-18 04:57:27,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 04:57:27,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:57:27,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:57:27,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-05-18 04:57:28,047 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0005
2016-05-18 04:57:28,047 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0005/
2016-05-18 04:57:46,146 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000003 is : 143
2016-05-18 04:57:46,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000004 is : 143
2016-05-18 04:57:46,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000002 is : 143
2016-05-18 04:57:46,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000005 is : 143
2016-05-18 04:57:46,987 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000006 is : 143
2016-05-18 04:57:56,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000009 is : 143
2016-05-18 04:57:56,351 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000007 is : 143
2016-05-18 04:57:56,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0005_01_000008 is : 143
2016-05-18 04:57:57,842 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2016-05-18 04:57:57,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:29.984, using cpu time: 00:11.920
2016-05-18 04:57:57,865 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-05-18 04:57:57,888 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:57:57,888 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 04:57:57,936 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-18 04:57:57,938 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:57:57,938 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 04:57:57,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:57:57,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:57:57,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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-05-18 04:57:57,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 04:57:57,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:57:57,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:57:57,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-05-18 04:57:58,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0006
2016-05-18 04:57:58,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0006/
2016-05-18 04:58:16,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000003 is : 143
2016-05-18 04:58:16,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000002 is : 143
2016-05-18 04:58:16,601 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000004 is : 143
2016-05-18 04:58:16,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000006 is : 143
2016-05-18 04:58:17,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000005 is : 143
2016-05-18 04:58:27,239 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000008 is : 143
2016-05-18 04:58:27,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000007 is : 143
2016-05-18 04:58:27,297 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0006_01_000009 is : 143
2016-05-18 04:58:28,561 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2016-05-18 04:58:28,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:30.600, using cpu time: 00:10.980
2016-05-18 04:58:28,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-05-18 04:58:28,630 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:58:28,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 04:58:28,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 04:58:28,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:58:28,698 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 04:58:28,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 04:58:28,728 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:58:28,728 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:58:28,729 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.5.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 04:58:28,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-18 04:58:28,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 04:58:28,730 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-18 04:58:28,730 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-18 04:58:28,731 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-18 04:58:28,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463547311221_0007
2016-05-18 04:58:28,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0007/
2016-05-18 04:58:55,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000002 is : 143
2016-05-18 04:58:55,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000003 is : 143
2016-05-18 04:58:57,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000004 is : 143
2016-05-18 04:58:57,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000009 is : 143
2016-05-18 04:58:57,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000008 is : 143
2016-05-18 04:58:57,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000005 is : 143
2016-05-18 04:58:57,301 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000006 is : 143
2016-05-18 04:58:57,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000010 is : 143
2016-05-18 04:58:57,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000007 is : 143
2016-05-18 04:59:05,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000012 is : 143
2016-05-18 04:59:05,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000011 is : 143
2016-05-18 04:59:05,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0007_01_000013 is : 143
2016-05-18 04:59:06,708 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-18 04:59:06,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:37.978, using cpu time: 00:15.220
2016-05-18 04:59:06,749 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-05-18 04:59:06,775 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:59:06,776 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 04:59:06,840 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-18 04:59:06,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 04:59:06,841 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 04:59:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 04:59:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:59:06,872 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-05-18 04:59:06,872 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-05-18 04:59:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 04:59:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-18 04:59:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-18 04:59:06,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-18 04:59:07,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0008
2016-05-18 04:59:07,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0008/
2016-05-18 04:59:25,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0008_01_000005 is : 143
2016-05-18 04:59:25,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0008_01_000006 is : 143
2016-05-18 04:59:25,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0008_01_000002 is : 143
2016-05-18 04:59:26,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0008_01_000003 is : 143
2016-05-18 04:59:26,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0008_01_000004 is : 143
2016-05-18 04:59:27,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2016-05-18 04:59:27,355 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2016-05-18 04:59:27,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0009
2016-05-18 04:59:27,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0009/
2016-05-18 04:59:27,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0010
2016-05-18 04:59:27,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0010/
2016-05-18 04:59:47,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0009_01_000004 is : 143
2016-05-18 04:59:48,331 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0009_01_000002 is : 143
2016-05-18 04:59:48,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0009_01_000005 is : 143
2016-05-18 04:59:49,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0009_01_000006 is : 143
2016-05-18 05:00:01,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0010_01_000002 is : 143
2016-05-18 05:00:01,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0010_01_000005 is : 143
2016-05-18 05:00:02,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0010_01_000004 is : 143
2016-05-18 05:00:02,092 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0010_01_000003 is : 143
2016-05-18 05:00:02,139 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0010_01_000006 is : 143
2016-05-18 05:00:03,408 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2016-05-18 05:00:03,409 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2016-05-18 05:00:03,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:56.525, using cpu time: 00:16.810
2016-05-18 05:00:03,455 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-05-18 05:00:03,466 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-05-18 05:00:03,492 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:00:03,493 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 05:00:03,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 05:00:03,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 05:00:03,556 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 05:00:03,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting
2016-05-18 05:00:03,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:00:03,588 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2016-05-18 05:00:03,588 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2016-05-18 05:00:03,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] parallel execution of steps is enabled: true
2016-05-18 05:00:03,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executing total steps: 3
2016-05-18 05:00:03,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] allocating management threads: 3
2016-05-18 05:00:03,591 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (1/3)
2016-05-18 05:00:03,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463547311221_0011
2016-05-18 05:00:03,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0011/
2016-05-18 05:00:21,881 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000003 is : 143
2016-05-18 05:00:22,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000002 is : 143
2016-05-18 05:00:22,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000005 is : 143
2016-05-18 05:00:22,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000004 is : 143
2016-05-18 05:00:32,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000009 is : 143
2016-05-18 05:00:32,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000007 is : 143
2016-05-18 05:00:32,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0011_01_000008 is : 143
2016-05-18 05:00:33,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout1
2016-05-18 05:00:33,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout2
2016-05-18 05:00:34,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463547311221_0012
2016-05-18 05:00:34,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0012/
2016-05-18 05:00:34,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] submitted hadoop job: job_1463547311221_0013
2016-05-18 05:00:34,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0013/
2016-05-18 05:00:50,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0012_01_000004 is : 143
2016-05-18 05:00:52,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0012_01_000003 is : 143
2016-05-18 05:00:58,572 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000004 is : 143
2016-05-18 05:00:58,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000002 is : 143
2016-05-18 05:00:58,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000003 is : 143
2016-05-18 05:01:08,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000006 is : 143
2016-05-18 05:01:08,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000005 is : 143
2016-05-18 05:01:08,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0013_01_000007 is : 143
2016-05-18 05:01:10,090 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2016-05-18 05:01:10,091 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2016-05-18 05:01:10,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] completed in: 01:06.499, using cpu time: 00:21.970
2016-05-18 05:01:10,180 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2
2016-05-18 05:01:10,189 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1
2016-05-18 05:01:10,213 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:01:10,213 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 05:01:10,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 05:01:10,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 05:01:10,258 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 05:01:10,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 05:01:10,275 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.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:01:10,276 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2016-05-18 05:01:10,276 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2016-05-18 05:01:10,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 05:01:10,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 2
2016-05-18 05:01:10,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 2
2016-05-18 05:01:10,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/2) ...platform/testSplit/split2
2016-05-18 05:01:10,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/2) ...platform/testSplit/split1
2016-05-18 05:01:10,464 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0014
2016-05-18 05:01:10,465 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0014/
2016-05-18 05:01:10,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0015
2016-05-18 05:01:10,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0015/
2016-05-18 05:01:30,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0014_01_000006 is : 143
2016-05-18 05:01:32,081 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0014_01_000003 is : 143
2016-05-18 05:01:32,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0014_01_000005 is : 143
2016-05-18 05:01:32,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0014_01_000004 is : 143
2016-05-18 05:01:32,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0014_01_000002 is : 143
2016-05-18 05:01:43,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0015_01_000004 is : 143
2016-05-18 05:01:43,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0015_01_000003 is : 143
2016-05-18 05:01:43,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0015_01_000005 is : 143
2016-05-18 05:01:44,073 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0015_01_000006 is : 143
2016-05-18 05:01:45,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0015_01_000002 is : 143
2016-05-18 05:01:46,392 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2/_temporary
2016-05-18 05:01:46,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1/_temporary
2016-05-18 05:01:46,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:36.115, using cpu time: 00:09.210
2016-05-18 05:01:46,430 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split2
2016-05-18 05:01:46,438 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split1
2016-05-18 05:01:46,461 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:01:46,461 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 05:01:46,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 05:01:46,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:01:46,504 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 05:01:46,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 05:01:46,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:01:46,521 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-18 05:01:46,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-18 05:01:46,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-18 05:01:46,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-18 05:01:46,522 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-18 05:01:46,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463547311221_0016
2016-05-18 05:01:46,650 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0016/
2016-05-18 05:02:05,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000005 is : 143
2016-05-18 05:02:05,246 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000004 is : 143
2016-05-18 05:02:05,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000002 is : 143
2016-05-18 05:02:05,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000003 is : 143
2016-05-18 05:02:05,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000006 is : 143
2016-05-18 05:02:14,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000007 is : 143
2016-05-18 05:02:15,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000009 is : 143
2016-05-18 05:02:15,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0016_01_000008 is : 143
2016-05-18 05:02:16,571 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-18 05:02:16,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:30.049, using cpu time: 00:10.700
2016-05-18 05:02:16,592 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-18 05:02:16,614 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:02:16,614 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 05:02:16,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:02:16,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:02:16,639 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 05:02:16,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:02:16,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:02:16,648 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2016-05-18 05:02:16,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:02:16,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:02:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:02:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-05-18 05:02:16,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0017
2016-05-18 05:02:16,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0017/
2016-05-18 05:02:34,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0017_01_000005 is : 143
2016-05-18 05:02:35,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0017_01_000003 is : 143
2016-05-18 05:02:35,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0017_01_000002 is : 143
2016-05-18 05:02:35,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0017_01_000006 is : 143
2016-05-18 05:02:37,256 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy/_temporary
2016-05-18 05:02:37,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.607, using cpu time: 00:05.210
2016-05-18 05:02:37,282 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testCopy/copy
2016-05-18 05:02:37,310 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:02:37,311 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 05:02:37,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-18 05:02:37,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:02:37,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:02:37,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:02:37,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:02:37,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2016-05-18 05:02:37,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:02:37,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:02:37,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:02:37,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-05-18 05:02:37,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0018
2016-05-18 05:02:37,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0018/
2016-05-18 05:02:55,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000002 is : 143
2016-05-18 05:02:55,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000003 is : 143
2016-05-18 05:02:56,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000005 is : 143
2016-05-18 05:02:56,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000006 is : 143
2016-05-18 05:02:56,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000004 is : 143
2016-05-18 05:03:04,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000008 is : 143
2016-05-18 05:03:05,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000007 is : 143
2016-05-18 05:03:05,546 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0018_01_000009 is : 143
2016-05-18 05:03:06,790 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none/_temporary
2016-05-18 05:03:06,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:29.411, using cpu time: 00:10.560
2016-05-18 05:03:06,813 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNone/none
2016-05-18 05:03:06,844 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:03:06,845 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 05:03:06,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 05:03:06,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:03:06,884 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 05:03:06,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:03:06,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:03:06,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2016-05-18 05:03:06,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:03:06,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:03:06,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:03:06,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-05-18 05:03:07,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0019
2016-05-18 05:03:07,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0019/
2016-05-18 05:03:25,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000004 is : 143
2016-05-18 05:03:25,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000006 is : 143
2016-05-18 05:03:25,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000003 is : 143
2016-05-18 05:03:25,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000005 is : 143
2016-05-18 05:03:25,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000002 is : 143
2016-05-18 05:03:35,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000008 is : 143
2016-05-18 05:03:35,831 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000009 is : 143
2016-05-18 05:03:36,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0019_01_000007 is : 143
2016-05-18 05:03:37,369 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap/_temporary
2016-05-18 05:03:37,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:30.468, using cpu time: 00:10.430
2016-05-18 05:03:37,394 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSwap/swap
2016-05-18 05:03:37,416 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:03:37,416 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 05:03:37,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 05:03:37,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:03:37,445 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 05:03:37,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:03:37,460 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.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:03:37,460 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-05-18 05:03:37,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:03:37,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:03:37,462 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:03:37,464 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-05-18 05:03:37,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0020
2016-05-18 05:03:37,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0020/
2016-05-18 05:03:55,875 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0020_01_000002 is : 143
2016-05-18 05:03:55,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0020_01_000006 is : 143
2016-05-18 05:03:56,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0020_01_000003 is : 143
2016-05-18 05:03:56,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0020_01_000004 is : 143
2016-05-18 05:03:56,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0020_01_000005 is : 143
2016-05-18 05:03:58,166 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2016-05-18 05:03:58,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.704, using cpu time: 00:04.760
2016-05-18 05:03:58,192 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter
2016-05-18 05:03:58,230 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:03:58,230 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 05:03:58,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:03:58,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:03:58,259 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 05:03:58,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:03:58,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 05:03:58,269 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-05-18 05:03:58,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:03:58,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:03:58,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:03:58,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-05-18 05:03:58,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0021
2016-05-18 05:03:58,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0021/
2016-05-18 05:04:16,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0021_01_000003 is : 143
2016-05-18 05:04:16,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0021_01_000002 is : 143
2016-05-18 05:04:17,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0021_01_000005 is : 143
2016-05-18 05:04:17,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0021_01_000004 is : 143
2016-05-18 05:04:17,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0021_01_000006 is : 143
2016-05-18 05:04:18,998 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2016-05-18 05:04:19,000 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.729, using cpu time: 00:04.950
2016-05-18 05:04:19,023 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped
2016-05-18 05:04:19,050 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:04:19,051 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 05:04:19,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-18 05:04:19,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 05:04:19,119 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 05:04:19,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:04:19,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:04:19,150 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2016-05-18 05:04:19,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:04:19,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 05:04:19,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-18 05:04:19,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 05:04:19,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0022
2016-05-18 05:04:19,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0022/
2016-05-18 05:04:37,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000003 is : 143
2016-05-18 05:04:37,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000006 is : 143
2016-05-18 05:04:37,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000004 is : 143
2016-05-18 05:04:37,977 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000002 is : 143
2016-05-18 05:04:38,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000005 is : 143
2016-05-18 05:04:47,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000007 is : 143
2016-05-18 05:04:47,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000009 is : 143
2016-05-18 05:04:48,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0022_01_000008 is : 143
2016-05-18 05:04:49,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2016-05-18 05:04:49,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0023
2016-05-18 05:04:49,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0023/
2016-05-18 05:05:03,201 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000003 is : 143
2016-05-18 05:05:03,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000002 is : 143
2016-05-18 05:05:03,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000004 is : 143
2016-05-18 05:05:12,493 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000006 is : 143
2016-05-18 05:05:12,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000005 is : 143
2016-05-18 05:05:12,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0023_01_000007 is : 143
2016-05-18 05:05:14,025 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall/_temporary
2016-05-18 05:05:14,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:54.871, using cpu time: 00:16.820
2016-05-18 05:05:14,041 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall
2016-05-18 05:05:14,059 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:05:14,060 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 05:05:14,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-18 05:05:14,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:05:14,109 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 05:05:14,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 05:05:14,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:05:14,124 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-05-18 05:05:14,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-18 05:05:14,125 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-18 05:05:14,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-18 05:05:14,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-05-18 05:05:14,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463547311221_0024
2016-05-18 05:05:14,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0024/
2016-05-18 05:05:32,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000006 is : 143
2016-05-18 05:05:32,446 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000004 is : 143
2016-05-18 05:05:32,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000002 is : 143
2016-05-18 05:05:32,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000003 is : 143
2016-05-18 05:05:32,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000005 is : 143
2016-05-18 05:05:42,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000007 is : 143
2016-05-18 05:05:42,543 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000008 is : 143
2016-05-18 05:05:43,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0024_01_000009 is : 143
2016-05-18 05:05:44,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2016-05-18 05:05:44,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:30.124, using cpu time: 00:10.570
2016-05-18 05:05:44,271 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-05-18 05:05:44,294 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:05:44,294 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 05:05:44,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 05:05:44,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:05:44,340 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 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting
2016-05-18 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-05-18 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] parallel execution of steps is enabled: true
2016-05-18 05:05:44,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] executing total steps: 1
2016-05-18 05:05:44,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] allocating management threads: 1
2016-05-18 05:05:44,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-05-18 05:05:44,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] submitted hadoop job: job_1463547311221_0025
2016-05-18 05:05:44,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0025/
2016-05-18 05:06:08,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000006 is : 143
2016-05-18 05:06:09,338 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000007 is : 143
2016-05-18 05:06:10,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000002 is : 143
2016-05-18 05:06:10,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000008 is : 143
2016-05-18 05:06:10,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000003 is : 143
2016-05-18 05:06:10,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000005 is : 143
2016-05-18 05:06:10,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000009 is : 143
2016-05-18 05:06:10,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000004 is : 143
2016-05-18 05:06:18,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000010 is : 143
2016-05-18 05:06:19,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000011 is : 143
2016-05-18 05:06:19,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0025_01_000012 is : 143
2016-05-18 05:06:20,388 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2016-05-18 05:06:20,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [groupby] completed in: 00:36.029, using cpu time: 00:15.630
2016-05-18 05:06:20,410 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-05-18 05:06:20,430 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:06:20,431 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 05:06:20,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 05:06:20,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:06:20,460 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 05:06:20,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:06:20,472 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.5.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 05:06:20,472 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-05-18 05:06:20,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:06:20,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:06:20,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:06:20,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-05-18 05:06:20,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0026
2016-05-18 05:06:20,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0026/
2016-05-18 05:06:37,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0026_01_000006 is : 143
2016-05-18 05:06:38,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0026_01_000004 is : 143
2016-05-18 05:06:38,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0026_01_000005 is : 143
2016-05-18 05:06:39,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0026_01_000003 is : 143
2016-05-18 05:06:39,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0026_01_000002 is : 143
2016-05-18 05:06:40,525 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2016-05-18 05:06:40,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.050, using cpu time: 00:05.100
2016-05-18 05:06:40,549 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-05-18 05:06:40,573 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:06:40,573 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 05:06:40,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 05:06:40,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 05:06:40,627 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 05:06:40,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:06:40,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:06:40,654 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-05-18 05:06:40,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:06:40,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 05:06:40,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-18 05:06:40,656 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 05:06:40,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0027
2016-05-18 05:06:40,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0027/
2016-05-18 05:06:58,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000003 is : 143
2016-05-18 05:06:59,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000002 is : 143
2016-05-18 05:06:59,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000004 is : 143
2016-05-18 05:06:59,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000005 is : 143
2016-05-18 05:07:00,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000006 is : 143
2016-05-18 05:07:08,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000008 is : 143
2016-05-18 05:07:08,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000007 is : 143
2016-05-18 05:07:09,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0027_01_000009 is : 143
2016-05-18 05:07:10,261 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2016-05-18 05:07:10,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0028
2016-05-18 05:07:10,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0028/
2016-05-18 05:07:24,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000002 is : 143
2016-05-18 05:07:24,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000004 is : 143
2016-05-18 05:07:24,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000003 is : 143
2016-05-18 05:07:34,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000005 is : 143
2016-05-18 05:07:34,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000006 is : 143
2016-05-18 05:07:35,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0028_01_000007 is : 143
2016-05-18 05:07:36,476 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2016-05-18 05:07:36,478 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:55.818, using cpu time: 00:19.010
2016-05-18 05:07:36,505 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup
2016-05-18 05:07:36,526 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:07:36,527 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 05:07:36,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 05:07:36,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 05:07:36,589 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 05:07:36,618 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting
2016-05-18 05:07:36,619 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:07:36,619 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-18 05:07:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] parallel execution of steps is enabled: true
2016-05-18 05:07:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] executing total steps: 2
2016-05-18 05:07:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] allocating management threads: 2
2016-05-18 05:07:36,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (1/2)
2016-05-18 05:07:36,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463547311221_0029
2016-05-18 05:07:36,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0029/
2016-05-18 05:07:58,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000006 is : 143
2016-05-18 05:07:58,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000007 is : 143
2016-05-18 05:07:59,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000008 is : 143
2016-05-18 05:07:59,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000004 is : 143
2016-05-18 05:08:00,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000002 is : 143
2016-05-18 05:08:00,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000003 is : 143
2016-05-18 05:08:00,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000005 is : 143
2016-05-18 05:08:08,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000010 is : 143
2016-05-18 05:08:08,460 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000011 is : 143
2016-05-18 05:08:08,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0029_01_000009 is : 143
2016-05-18 05:08:09,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-18 05:08:09,877 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-05-18 05:08:09,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] submitted hadoop job: job_1463547311221_0030
2016-05-18 05:08:09,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0030/
2016-05-18 05:08:34,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000003 is : 143
2016-05-18 05:08:34,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000002 is : 143
2016-05-18 05:08:36,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000009 is : 143
2016-05-18 05:08:36,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000007 is : 143
2016-05-18 05:08:36,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000004 is : 143
2016-05-18 05:08:36,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000006 is : 143
2016-05-18 05:08:36,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000005 is : 143
2016-05-18 05:08:44,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000010 is : 143
2016-05-18 05:08:44,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000011 is : 143
2016-05-18 05:08:44,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0030_01_000012 is : 143
2016-05-18 05:08:45,761 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-18 05:08:45,764 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower+upper+offset] completed in: 01:09.139, using cpu time: 00:26.670
2016-05-18 05:08:45,784 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-18 05:08:45,805 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:08:45,805 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 05:08:45,834 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 05:08:45,835 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:08:45,835 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 05:08:45,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:08:45,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:08:45,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2016-05-18 05:08:45,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:08:45,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:08:45,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:08:45,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-05-18 05:08:45,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0031
2016-05-18 05:08:45,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0031/
2016-05-18 05:09:03,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0031_01_000003 is : 143
2016-05-18 05:09:04,476 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0031_01_000002 is : 143
2016-05-18 05:09:04,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0031_01_000004 is : 143
2016-05-18 05:09:04,671 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0031_01_000006 is : 143
2016-05-18 05:09:04,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0031_01_000005 is : 143
2016-05-18 05:09:06,061 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2016-05-18 05:09:06,063 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.216, using cpu time: 00:05.400
2016-05-18 05:09:06,088 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testReplace/replace
2016-05-18 05:09:06,140 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:09:06,141 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 05:09:06,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 05:09:06,168 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:09:06,168 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 05:09:06,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:09:06,177 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.5.x/build/classes/test/data/extra+lower+upper.txt"]
2016-05-18 05:09:06,178 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-05-18 05:09:06,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:09:06,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:09:06,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:09:06,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-05-18 05:09:06,320 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0032
2016-05-18 05:09:06,320 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0032/
2016-05-18 05:09:24,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0032_01_000003 is : 143
2016-05-18 05:09:24,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0032_01_000002 is : 143
2016-05-18 05:09:24,590 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0032_01_000006 is : 143
2016-05-18 05:09:24,634 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0032_01_000005 is : 143
2016-05-18 05:09:25,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0032_01_000004 is : 143
2016-05-18 05:09:26,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2016-05-18 05:09:26,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.071, using cpu time: 00:05.090
2016-05-18 05:09:26,273 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-05-18 05:09:26,306 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:09:26,307 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 05:09:26,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 05:09:26,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:09:26,331 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 05:09:26,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:09:26,341 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.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:09:26,341 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2016-05-18 05:09:26,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:09:26,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:09:26,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:09:26,343 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-05-18 05:09:26,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0033
2016-05-18 05:09:26,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0033/
2016-05-18 05:09:44,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0033_01_000003 is : 143
2016-05-18 05:09:44,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0033_01_000005 is : 143
2016-05-18 05:09:44,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0033_01_000002 is : 143
2016-05-18 05:09:44,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0033_01_000006 is : 143
2016-05-18 05:09:44,866 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0033_01_000004 is : 143
2016-05-18 05:09:46,092 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter/_temporary
2016-05-18 05:09:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:19.749, using cpu time: 00:04.540
2016-05-18 05:09:46,123 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilter/filter
2016-05-18 05:09:46,149 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:09:46,152 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 05:09:46,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-05-18 05:09:46,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2016-05-18 05:09:46,253 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 05:09:46,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting
2016-05-18 05:09:46,298 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.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:09:46,298 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2016-05-18 05:09:46,298 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-05-18 05:09:46,299 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-05-18 05:09:46,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] parallel execution of steps is enabled: true
2016-05-18 05:09:46,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] executing total steps: 5
2016-05-18 05:09:46,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] allocating management threads: 5
2016-05-18 05:09:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (1/5)
2016-05-18 05:09:46,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463547311221_0034
2016-05-18 05:09:46,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0034/
2016-05-18 05:10:04,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000003 is : 143
2016-05-18 05:10:04,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000002 is : 143
2016-05-18 05:10:05,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000006 is : 143
2016-05-18 05:10:05,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000005 is : 143
2016-05-18 05:10:05,429 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000004 is : 143
2016-05-18 05:10:14,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000007 is : 143
2016-05-18 05:10:15,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000009 is : 143
2016-05-18 05:10:15,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0034_01_000008 is : 143
2016-05-18 05:10:16,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (2/5) ...rm/testSplitMultiple/left
2016-05-18 05:10:16,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (3/5)
2016-05-18 05:10:17,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463547311221_0035
2016-05-18 05:10:17,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0035/
2016-05-18 05:10:17,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463547311221_0036
2016-05-18 05:10:17,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0036/
2016-05-18 05:10:33,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0035_01_000002 is : 143
2016-05-18 05:10:33,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0035_01_000003 is : 143
2016-05-18 05:10:34,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0035_01_000004 is : 143
2016-05-18 05:10:41,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000003 is : 143
2016-05-18 05:10:41,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000002 is : 143
2016-05-18 05:10:41,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000004 is : 143
2016-05-18 05:10:51,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000007 is : 143
2016-05-18 05:10:51,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000005 is : 143
2016-05-18 05:10:52,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0036_01_000006 is : 143
2016-05-18 05:10:53,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (4/5) ...tSplitMultiple/rightright
2016-05-18 05:10:53,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] starting step: (5/5) ...stSplitMultiple/rightleft
2016-05-18 05:10:53,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463547311221_0037
2016-05-18 05:10:53,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0037/
2016-05-18 05:10:53,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] submitted hadoop job: job_1463547311221_0038
2016-05-18 05:10:53,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0038/
2016-05-18 05:11:10,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0037_01_000004 is : 143
2016-05-18 05:11:10,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0037_01_000002 is : 143
2016-05-18 05:11:11,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0037_01_000003 is : 143
2016-05-18 05:11:17,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0038_01_000003 is : 143
2016-05-18 05:11:17,829 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0038_01_000004 is : 143
2016-05-18 05:11:17,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0038_01_000002 is : 143
2016-05-18 05:11:19,167 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left/_temporary
2016-05-18 05:11:19,170 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2016-05-18 05:11:19,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2016-05-18 05:11:19,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+rightLeft+rightRight] completed in: 01:32.864, using cpu time: 00:27.610
2016-05-18 05:11:19,230 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright
2016-05-18 05:11:19,236 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft
2016-05-18 05:11:19,242 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left
2016-05-18 05:11:19,261 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:11:19,262 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 05:11:19,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:11:19,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:11:19,300 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 05:11:19,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting
2016-05-18 05:11:19,315 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.5.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]]]
2016-05-18 05:11:19,315 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-05-18 05:11:19,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] parallel execution of steps is enabled: true
2016-05-18 05:11:19,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] executing total steps: 1
2016-05-18 05:11:19,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] allocating management threads: 1
2016-05-18 05:11:19,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-05-18 05:11:19,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] submitted hadoop job: job_1463547311221_0039
2016-05-18 05:11:19,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0039/
2016-05-18 05:11:39,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000003 is : 143
2016-05-18 05:11:40,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000004 is : 143
2016-05-18 05:11:40,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000006 is : 143
2016-05-18 05:11:40,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000002 is : 143
2016-05-18 05:11:40,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000005 is : 143
2016-05-18 05:11:40,815 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000007 is : 143
2016-05-18 05:11:49,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000008 is : 143
2016-05-18 05:11:50,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000010 is : 143
2016-05-18 05:11:50,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0039_01_000009 is : 143
2016-05-18 05:11:51,690 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2016-05-18 05:11:51,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [concat] completed in: 00:32.374, using cpu time: 00:11.090
2016-05-18 05:11:51,710 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat
2016-05-18 05:11:51,731 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:11:51,731 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 05:11:51,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-05-18 05:11:51,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:11:51,798 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 05:11:51,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting
2016-05-18 05:11:51,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:11:51,824 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-05-18 05:11:51,824 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.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-05-18 05:11:51,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] parallel execution of steps is enabled: true
2016-05-18 05:11:51,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executing total steps: 3
2016-05-18 05:11:51,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] allocating management threads: 3
2016-05-18 05:11:51,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (1/3)
2016-05-18 05:11:51,899 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-05-18 05:11:51,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0040
2016-05-18 05:11:51,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0040/
2016-05-18 05:12:10,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000006 is : 143
2016-05-18 05:12:10,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000005 is : 143
2016-05-18 05:12:10,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000003 is : 143
2016-05-18 05:12:10,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000002 is : 143
2016-05-18 05:12:10,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000004 is : 143
2016-05-18 05:12:20,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000007 is : 143
2016-05-18 05:12:20,438 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000008 is : 143
2016-05-18 05:12:20,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0040_01_000009 is : 143
2016-05-18 05:12:22,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2016-05-18 05:12:22,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2016-05-18 05:12:22,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0041
2016-05-18 05:12:22,259 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0041/
2016-05-18 05:12:22,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] submitted hadoop job: job_1463547311221_0042
2016-05-18 05:12:22,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0042/
2016-05-18 05:12:38,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0041_01_000002 is : 143
2016-05-18 05:12:38,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0041_01_000003 is : 143
2016-05-18 05:12:38,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0041_01_000004 is : 143
2016-05-18 05:12:46,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0042_01_000003 is : 143
2016-05-18 05:12:46,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0042_01_000004 is : 143
2016-05-18 05:12:46,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0042_01_000002 is : 143
2016-05-18 05:12:48,120 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2016-05-18 05:12:48,121 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2016-05-18 05:12:48,127 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] completed in: 00:56.291, using cpu time: 00:16.490
2016-05-18 05:12:48,160 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-05-18 05:12:48,166 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-05-18 05:12:48,184 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:12:48,185 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 05:12:48,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 05:12:48,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:12:48,209 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 05:12:48,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 05:12:48,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-05-18 05:12:48,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2016-05-18 05:12:48,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 05:12:48,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 05:12:48,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 05:12:48,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-05-18 05:12:48,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463547311221_0043
2016-05-18 05:12:48,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:56721/proxy/application_1463547311221_0043/
2016-05-18 05:13:06,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0043_01_000003 is : 143
2016-05-18 05:13:06,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0043_01_000006 is : 143
2016-05-18 05:13:06,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0043_01_000002 is : 143
2016-05-18 05:13:07,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0043_01_000005 is : 143
2016-05-18 05:13:07,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463547311221_0043_01_000004 is : 143
2016-05-18 05:13:08,389 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2016-05-18 05:13:08,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:20.169, using cpu time: 00:05.270
2016-05-18 05:13:08,447 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup