2016-01-15 04:03:49,127 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 04:03:49,148 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-01-15 04:03:49,176 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 04:03:50,239 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-01-15 04:03:50,992 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 04:03:55,802 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-01-15 04:03:56,069 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-01-15 04:03:56,251 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-01-15 04:03:56,431 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-01-15 04:04:13,527 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 04:04:13,633 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:04:13,634 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:04:13,701 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: AD8FDFB4AB5B4C52A893AB076E05070E
2016-01-15 04:04:13,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.109
2016-01-15 04:04:13,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:04:13,858 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:04:14,002 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 04:04:14,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:04:14,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:04:14,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-01-15 04:04:14,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:04:14,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:04:14,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:04:14,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-01-15 04:04:14,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0001
2016-01-15 04:04:14,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0001/
2016-01-15 04:04:34,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000002 is : 143
2016-01-15 04:04:34,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000003 is : 143
2016-01-15 04:04:35,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000004 is : 143
2016-01-15 04:04:35,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000005 is : 143
2016-01-15 04:04:35,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000006 is : 143
2016-01-15 04:04:44,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000008 is : 143
2016-01-15 04:04:44,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000007 is : 143
2016-01-15 04:04:45,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0001_01_000009 is : 143
2016-01-15 04:04:46,565 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2016-01-15 04:04:46,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:32.559, using cpu time: 00:09.350
2016-01-15 04:04:46,610 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-01-15 04:04:46,655 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:04:46,656 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:04:46,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-15 04:04:46,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:04:46,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:04:46,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:04:46,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:04:46,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-01-15 04:04:46,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:04:46,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:04:46,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:04:46,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-01-15 04:04:46,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0002
2016-01-15 04:04:46,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0002/
2016-01-15 04:05:11,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000004 is : 143
2016-01-15 04:05:12,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000002 is : 143
2016-01-15 04:05:12,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000003 is : 143
2016-01-15 04:05:12,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000005 is : 143
2016-01-15 04:05:12,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000006 is : 143
2016-01-15 04:05:22,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000009 is : 143
2016-01-15 04:05:22,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000008 is : 143
2016-01-15 04:05:23,639 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0002_01_000007 is : 143
2016-01-15 04:05:24,862 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-15 04:05:24,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:38.099, using cpu time: 00:11.180
2016-01-15 04:05:24,894 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain
2016-01-15 04:05:24,930 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:05:24,931 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:05:24,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-15 04:05:24,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:05:24,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:05:25,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:05:25,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:05:25,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2016-01-15 04:05:25,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:05:25,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:05:25,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:05:25,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-01-15 04:05:25,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0003
2016-01-15 04:05:25,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0003/
2016-01-15 04:05:50,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000004 is : 143
2016-01-15 04:05:50,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000005 is : 143
2016-01-15 04:05:50,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000003 is : 143
2016-01-15 04:05:50,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000006 is : 143
2016-01-15 04:06:00,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000007 is : 143
2016-01-15 04:06:00,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000009 is : 143
2016-01-15 04:06:01,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0003_01_000008 is : 143
2016-01-15 04:06:02,270 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2016-01-15 04:06:02,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:37.265, using cpu time: 00:11.640
2016-01-15 04:06:02,319 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple
2016-01-15 04:06:02,379 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:06:02,380 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:06:02,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-15 04:06:02,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:06:02,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:06:02,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-15 04:06:02,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:06:02,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:06:02,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-01-15 04:06:02,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-15 04:06:02,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-15 04:06:02,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-15 04:06:02,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-15 04:06:02,631 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452830648025_0004
2016-01-15 04:06:02,631 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0004/
2016-01-15 04:06:34,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000003 is : 143
2016-01-15 04:06:34,540 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000002 is : 143
2016-01-15 04:06:35,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000008 is : 143
2016-01-15 04:06:35,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000005 is : 143
2016-01-15 04:06:35,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000006 is : 143
2016-01-15 04:06:35,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000004 is : 143
2016-01-15 04:06:35,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000007 is : 143
2016-01-15 04:06:35,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000009 is : 143
2016-01-15 04:06:44,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000010 is : 143
2016-01-15 04:06:45,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000011 is : 143
2016-01-15 04:06:45,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0004_01_000012 is : 143
2016-01-15 04:06:46,690 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2016-01-15 04:06:46,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:44.214, using cpu time: 00:13.670
2016-01-15 04:06:46,738 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-01-15 04:06:46,890 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:06:46,890 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:06:46,944 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-15 04:06:46,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:06:46,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:06:46,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:06:46,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:06:46,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-01-15 04:06:46,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:06:46,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:06:46,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:06:46,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-01-15 04:06:47,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0005
2016-01-15 04:06:47,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0005/
2016-01-15 04:07:10,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000004 is : 143
2016-01-15 04:07:10,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000003 is : 143
2016-01-15 04:07:11,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000002 is : 143
2016-01-15 04:07:11,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000005 is : 143
2016-01-15 04:07:11,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000006 is : 143
2016-01-15 04:07:21,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000009 is : 143
2016-01-15 04:07:21,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000008 is : 143
2016-01-15 04:07:21,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0005_01_000007 is : 143
2016-01-15 04:07:23,127 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2016-01-15 04:07:23,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:36.154, using cpu time: 00:11.690
2016-01-15 04:07:23,152 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-01-15 04:07:23,178 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:07:23,178 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:07:23,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-15 04:07:23,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:07:23,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:07:23,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:07:23,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:07:23,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-01-15 04:07:23,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:07:23,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:07:23,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:07:23,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-01-15 04:07:23,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0006
2016-01-15 04:07:23,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0006/
2016-01-15 04:07:47,444 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000002 is : 143
2016-01-15 04:07:47,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000003 is : 143
2016-01-15 04:07:47,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000006 is : 143
2016-01-15 04:07:48,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000004 is : 143
2016-01-15 04:07:48,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000005 is : 143
2016-01-15 04:07:57,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000009 is : 143
2016-01-15 04:07:58,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000007 is : 143
2016-01-15 04:07:58,590 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0006_01_000008 is : 143
2016-01-15 04:07:59,781 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2016-01-15 04:07:59,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:36.532, using cpu time: 00:11.720
2016-01-15 04:07:59,806 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-01-15 04:07:59,853 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:07:59,854 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:07:59,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-01-15 04:07:59,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:07:59,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:07:59,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-15 04:07:59,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:07:59,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:07:59,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 04:07:59,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-15 04:07:59,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-15 04:07:59,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-15 04:07:59,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-15 04:07:59,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-15 04:08:00,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452830648025_0007
2016-01-15 04:08:00,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0007/
2016-01-15 04:08:34,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000006 is : 143
2016-01-15 04:08:34,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000003 is : 143
2016-01-15 04:08:34,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000009 is : 143
2016-01-15 04:08:35,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000002 is : 143
2016-01-15 04:08:35,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000005 is : 143
2016-01-15 04:08:35,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000010 is : 143
2016-01-15 04:08:35,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000004 is : 143
2016-01-15 04:08:35,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000008 is : 143
2016-01-15 04:08:44,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000012 is : 143
2016-01-15 04:08:44,830 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000011 is : 143
2016-01-15 04:08:44,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0007_01_000013 is : 143
2016-01-15 04:08:46,109 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-01-15 04:08:46,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:46.138, using cpu time: 00:15.300
2016-01-15 04:08:46,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-01-15 04:08:46,175 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:08:46,175 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:08:46,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-15 04:08:46,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-15 04:08:46,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:08:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-15 04:08:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:08:46,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-01-15 04:08:46,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-01-15 04:08:46,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] parallel execution of steps is enabled: true
2016-01-15 04:08:46,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executing total steps: 3
2016-01-15 04:08:46,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] allocating management threads: 3
2016-01-15 04:08:46,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2016-01-15 04:08:46,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0008
2016-01-15 04:08:46,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0008/
2016-01-15 04:09:10,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0008_01_000003 is : 143
2016-01-15 04:09:11,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0008_01_000004 is : 143
2016-01-15 04:09:11,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0008_01_000006 is : 143
2016-01-15 04:09:11,863 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0008_01_000005 is : 143
2016-01-15 04:09:13,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2016-01-15 04:09:13,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2016-01-15 04:09:13,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0010
2016-01-15 04:09:13,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0010/
2016-01-15 04:09:13,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0009
2016-01-15 04:09:13,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0009/
2016-01-15 04:09:37,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0009_01_000006 is : 143
2016-01-15 04:09:38,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0009_01_000002 is : 143
2016-01-15 04:09:38,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0009_01_000004 is : 143
2016-01-15 04:09:38,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0009_01_000005 is : 143
2016-01-15 04:09:38,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0009_01_000003 is : 143
2016-01-15 04:10:03,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0010_01_000005 is : 143
2016-01-15 04:10:03,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0010_01_000006 is : 143
2016-01-15 04:10:04,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0010_01_000004 is : 143
2016-01-15 04:10:04,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0010_01_000002 is : 143
2016-01-15 04:10:04,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0010_01_000003 is : 143
2016-01-15 04:10:05,620 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2016-01-15 04:10:05,622 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2016-01-15 04:10:05,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] completed in: 01:19.335, using cpu time: 00:16.850
2016-01-15 04:10:05,661 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-01-15 04:10:05,670 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-01-15 04:10:05,695 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:10:05,695 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:10:05,755 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-15 04:10:05,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-15 04:10:05,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:10:05,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting
2016-01-15 04:10:05,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:10:05,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2016-01-15 04:10:05,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2016-01-15 04:10:05,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] parallel execution of steps is enabled: true
2016-01-15 04:10:05,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executing total steps: 3
2016-01-15 04:10:05,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] allocating management threads: 3
2016-01-15 04:10:05,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (1/3)
2016-01-15 04:10:05,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1452830648025_0011
2016-01-15 04:10:05,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0011/
2016-01-15 04:10:29,553 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000002 is : 143
2016-01-15 04:10:29,653 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000005 is : 143
2016-01-15 04:10:29,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000003 is : 143
2016-01-15 04:10:30,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000006 is : 143
2016-01-15 04:10:30,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000004 is : 143
2016-01-15 04:10:40,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000008 is : 143
2016-01-15 04:10:40,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000007 is : 143
2016-01-15 04:10:40,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0011_01_000009 is : 143
2016-01-15 04:10:41,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout1
2016-01-15 04:10:41,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout2
2016-01-15 04:10:41,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1452830648025_0012
2016-01-15 04:10:41,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0012/
2016-01-15 04:10:41,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1452830648025_0013
2016-01-15 04:10:41,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0013/
2016-01-15 04:11:01,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0012_01_000002 is : 143
2016-01-15 04:11:01,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0012_01_000003 is : 143
2016-01-15 04:11:02,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0012_01_000004 is : 143
2016-01-15 04:11:23,943 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000003 is : 143
2016-01-15 04:11:24,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000004 is : 143
2016-01-15 04:11:24,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000002 is : 143
2016-01-15 04:11:34,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000007 is : 143
2016-01-15 04:11:34,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000005 is : 143
2016-01-15 04:11:34,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0013_01_000006 is : 143
2016-01-15 04:11:36,109 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2016-01-15 04:11:36,111 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2016-01-15 04:11:36,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] completed in: 01:30.321, using cpu time: 00:22.330
2016-01-15 04:11:36,197 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1
2016-01-15 04:11:36,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2
2016-01-15 04:11:36,232 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:11:36,233 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:11:36,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 04:11:36,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 04:11:36,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] parallel execution of steps is enabled: true
2016-01-15 04:11:36,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executing total steps: 2
2016-01-15 04:11:36,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] allocating management threads: 2
2016-01-15 04:11:36,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/2) ...platform/testSplit/split1
2016-01-15 04:11:36,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/2) ...platform/testSplit/split2
2016-01-15 04:11:36,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0015
2016-01-15 04:11:36,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0015/
2016-01-15 04:11:36,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0014
2016-01-15 04:11:36,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0014/
2016-01-15 04:12:00,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0014_01_000004 is : 143
2016-01-15 04:12:01,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0014_01_000002 is : 143
2016-01-15 04:12:01,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0014_01_000005 is : 143
2016-01-15 04:12:01,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0014_01_000006 is : 143
2016-01-15 04:12:02,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0014_01_000003 is : 143
2016-01-15 04:12:27,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0015_01_000006 is : 143
2016-01-15 04:12:27,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0015_01_000002 is : 143
2016-01-15 04:12:27,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0015_01_000003 is : 143
2016-01-15 04:12:28,097 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0015_01_000004 is : 143
2016-01-15 04:12:28,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0015_01_000005 is : 143
2016-01-15 04:12:29,358 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1/_temporary
2016-01-15 04:12:29,360 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2/_temporary
2016-01-15 04:12:29,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] completed in: 00:53.061, using cpu time: 00:09.430
2016-01-15 04:12:29,401 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split2
2016-01-15 04:12:29,413 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split1
2016-01-15 04:12:29,446 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:12:29,446 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:12:29,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-15 04:12:29,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:12:29,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:12:29,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-15 04:12:29,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:12:29,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-15 04:12:29,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] parallel execution of steps is enabled: true
2016-01-15 04:12:29,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executing total steps: 1
2016-01-15 04:12:29,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] allocating management threads: 1
2016-01-15 04:12:29,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-15 04:12:29,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1452830648025_0016
2016-01-15 04:12:29,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0016/
2016-01-15 04:12:53,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000002 is : 143
2016-01-15 04:12:54,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000004 is : 143
2016-01-15 04:12:54,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000005 is : 143
2016-01-15 04:12:54,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000003 is : 143
2016-01-15 04:12:54,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000006 is : 143
2016-01-15 04:13:04,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000007 is : 143
2016-01-15 04:13:04,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000008 is : 143
2016-01-15 04:13:04,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0016_01_000009 is : 143
2016-01-15 04:13:05,925 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-01-15 04:13:05,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] completed in: 00:36.418, using cpu time: 00:10.550
2016-01-15 04:13:05,947 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-15 04:13:05,981 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:13:05,982 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:13:06,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-15 04:13:06,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:13:06,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:13:06,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:13:06,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:13:06,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2016-01-15 04:13:06,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:13:06,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:13:06,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:13:06,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-01-15 04:13:06,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0017
2016-01-15 04:13:06,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0017/
2016-01-15 04:13:31,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0017_01_000005 is : 143
2016-01-15 04:13:31,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0017_01_000003 is : 143
2016-01-15 04:13:31,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0017_01_000002 is : 143
2016-01-15 04:13:31,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0017_01_000006 is : 143
2016-01-15 04:13:31,744 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0017_01_000004 is : 143
2016-01-15 04:13:32,944 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy/_temporary
2016-01-15 04:13:32,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.926, using cpu time: 00:05.210
2016-01-15 04:13:32,972 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testCopy/copy
2016-01-15 04:13:33,001 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:13:33,001 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:13:33,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-15 04:13:33,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:13:33,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:13:33,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:13:33,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-01-15 04:13:33,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0018
2016-01-15 04:13:33,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0018/
2016-01-15 04:13:58,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000003 is : 143
2016-01-15 04:13:58,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000002 is : 143
2016-01-15 04:13:58,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000005 is : 143
2016-01-15 04:13:58,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000004 is : 143
2016-01-15 04:13:58,634 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000006 is : 143
2016-01-15 04:14:09,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000008 is : 143
2016-01-15 04:14:09,247 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000007 is : 143
2016-01-15 04:14:09,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0018_01_000009 is : 143
2016-01-15 04:14:10,746 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none/_temporary
2016-01-15 04:14:10,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:37.655, using cpu time: 00:10.900
2016-01-15 04:14:10,769 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNone/none
2016-01-15 04:14:10,795 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:14:10,795 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:14:10,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-15 04:14:10,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:14:10,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:14:10,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:14:10,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:14:10,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2016-01-15 04:14:10,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:14:10,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:14:10,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:14:10,858 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-15 04:14:10,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0019
2016-01-15 04:14:10,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0019/
2016-01-15 04:14:34,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000002 is : 143
2016-01-15 04:14:35,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000003 is : 143
2016-01-15 04:14:35,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000006 is : 143
2016-01-15 04:14:35,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000004 is : 143
2016-01-15 04:14:35,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000005 is : 143
2016-01-15 04:14:45,020 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000007 is : 143
2016-01-15 04:14:45,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000009 is : 143
2016-01-15 04:14:45,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0019_01_000008 is : 143
2016-01-15 04:14:46,787 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap/_temporary
2016-01-15 04:14:46,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:35.929, using cpu time: 00:10.850
2016-01-15 04:14:46,810 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSwap/swap
2016-01-15 04:14:46,836 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:14:46,836 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:14:46,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 04:14:46,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:14:46,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:14:46,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:14:46,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:14:46,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-01-15 04:14:46,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:14:46,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:14:46,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:14:46,885 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-01-15 04:14:46,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0020
2016-01-15 04:14:46,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0020/
2016-01-15 04:15:09,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0020_01_000003 is : 143
2016-01-15 04:15:09,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0020_01_000002 is : 143
2016-01-15 04:15:10,532 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0020_01_000004 is : 143
2016-01-15 04:15:10,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0020_01_000006 is : 143
2016-01-15 04:15:11,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0020_01_000005 is : 143
2016-01-15 04:15:12,227 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2016-01-15 04:15:12,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:25.342, using cpu time: 00:04.860
2016-01-15 04:15:12,253 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter
2016-01-15 04:15:12,288 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:15:12,288 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:15:12,314 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 04:15:12,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:15:12,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:15:12,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:15:12,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 04:15:12,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-01-15 04:15:12,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:15:12,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:15:12,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:15:12,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-15 04:15:12,378 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 04:15:12,378 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 04:15:12,378 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 04:15:12,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0021
2016-01-15 04:15:12,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0021/
2016-01-15 04:15:13,066 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 04:15:13,066 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 04:15:13,066 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK, ARCHIVE], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 04:15:13,067 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) All required storage types are unavailable: unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 04:15:13,067 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 04:15:13,067 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 04:15:13,067 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK, ARCHIVE], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 04:15:13,067 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) All required storage types are unavailable: unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 04:15:17,639 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452830648025_0020_01_000001
2016-01-15 04:15:36,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0021_01_000003 is : 143
2016-01-15 04:15:36,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0021_01_000002 is : 143
2016-01-15 04:15:36,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0021_01_000006 is : 143
2016-01-15 04:15:37,064 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0021_01_000005 is : 143
2016-01-15 04:15:37,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0021_01_000004 is : 143
2016-01-15 04:15:38,337 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-15 04:15:38,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.011, using cpu time: 00:05.270
2016-01-15 04:15:38,363 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped
2016-01-15 04:15:38,388 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:15:38,388 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:15:38,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-15 04:15:38,449 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 04:15:38,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2016-01-15 04:15:38,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 2
2016-01-15 04:15:38,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-15 04:15:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0022
2016-01-15 04:15:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0022/
2016-01-15 04:15:43,830 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452830648025_0021_01_000001
2016-01-15 04:16:02,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000003 is : 143
2016-01-15 04:16:02,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000002 is : 143
2016-01-15 04:16:02,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000005 is : 143
2016-01-15 04:16:03,012 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000004 is : 143
2016-01-15 04:16:03,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000006 is : 143
2016-01-15 04:16:12,563 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000008 is : 143
2016-01-15 04:16:13,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000007 is : 143
2016-01-15 04:16:13,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0022_01_000009 is : 143
2016-01-15 04:16:14,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2016-01-15 04:16:14,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0023
2016-01-15 04:16:14,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0023/
2016-01-15 04:16:34,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000002 is : 143
2016-01-15 04:16:34,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000003 is : 143
2016-01-15 04:16:34,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000004 is : 143
2016-01-15 04:16:44,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000006 is : 143
2016-01-15 04:16:44,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000007 is : 143
2016-01-15 04:16:44,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0023_01_000005 is : 143
2016-01-15 04:16:46,164 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall/_temporary
2016-01-15 04:16:46,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:07.681, using cpu time: 00:16.640
2016-01-15 04:16:46,181 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall
2016-01-15 04:16:46,200 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:16:46,201 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:16:46,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-15 04:16:46,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:16:46,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:16:46,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-15 04:16:46,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:16:46,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-01-15 04:16:46,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] parallel execution of steps is enabled: true
2016-01-15 04:16:46,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executing total steps: 1
2016-01-15 04:16:46,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] allocating management threads: 1
2016-01-15 04:16:46,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-01-15 04:16:46,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1452830648025_0024
2016-01-15 04:16:46,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0024/
2016-01-15 04:17:10,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000006 is : 143
2016-01-15 04:17:10,866 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000003 is : 143
2016-01-15 04:17:11,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000002 is : 143
2016-01-15 04:17:11,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000004 is : 143
2016-01-15 04:17:21,011 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000007 is : 143
2016-01-15 04:17:21,430 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000009 is : 143
2016-01-15 04:17:21,610 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0024_01_000008 is : 143
2016-01-15 04:17:22,789 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2016-01-15 04:17:22,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] completed in: 00:36.533, using cpu time: 00:10.940
2016-01-15 04:17:22,824 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-01-15 04:17:22,850 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:17:22,850 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:17:22,893 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 04:17:22,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:17:22,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:17:22,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting
2016-01-15 04:17:22,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:17:22,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:17:22,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-01-15 04:17:22,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] parallel execution of steps is enabled: true
2016-01-15 04:17:22,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executing total steps: 1
2016-01-15 04:17:22,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] allocating management threads: 1
2016-01-15 04:17:22,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-01-15 04:17:23,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] submitted hadoop job: job_1452830648025_0025
2016-01-15 04:17:23,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0025/
2016-01-15 04:17:54,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000006 is : 143
2016-01-15 04:17:54,767 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000003 is : 143
2016-01-15 04:17:55,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000004 is : 143
2016-01-15 04:17:55,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000009 is : 143
2016-01-15 04:17:55,335 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000008 is : 143
2016-01-15 04:17:55,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000005 is : 143
2016-01-15 04:18:04,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000011 is : 143
2016-01-15 04:18:05,105 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000010 is : 143
2016-01-15 04:18:05,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0025_01_000012 is : 143
2016-01-15 04:18:06,523 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2016-01-15 04:18:06,525 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] completed in: 00:43.609, using cpu time: 00:15.600
2016-01-15 04:18:06,545 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-01-15 04:18:06,567 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:18:06,568 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:18:06,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 04:18:06,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:18:06,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:18:06,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:18:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 04:18:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-01-15 04:18:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:18:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:18:06,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:18:06,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-01-15 04:18:06,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0026
2016-01-15 04:18:06,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0026/
2016-01-15 04:18:30,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0026_01_000005 is : 143
2016-01-15 04:18:31,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0026_01_000002 is : 143
2016-01-15 04:18:31,571 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0026_01_000006 is : 143
2016-01-15 04:18:31,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0026_01_000004 is : 143
2016-01-15 04:18:32,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0026_01_000003 is : 143
2016-01-15 04:18:33,547 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2016-01-15 04:18:33,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.940, using cpu time: 00:05.430
2016-01-15 04:18:33,572 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-01-15 04:18:33,597 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:18:33,598 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:18:33,653 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-15 04:18:33,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 04:18:33,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:18:33,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:18:33,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:18:33,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-01-15 04:18:33,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:18:33,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2016-01-15 04:18:33,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 2
2016-01-15 04:18:33,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-15 04:18:33,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0027
2016-01-15 04:18:33,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0027/
2016-01-15 04:18:57,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000003 is : 143
2016-01-15 04:18:58,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000006 is : 143
2016-01-15 04:18:58,103 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000002 is : 143
2016-01-15 04:18:58,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000005 is : 143
2016-01-15 04:18:58,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000004 is : 143
2016-01-15 04:19:08,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000007 is : 143
2016-01-15 04:19:08,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000008 is : 143
2016-01-15 04:19:08,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0027_01_000009 is : 143
2016-01-15 04:19:10,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2016-01-15 04:19:10,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0028
2016-01-15 04:19:10,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0028/
2016-01-15 04:19:30,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000003 is : 143
2016-01-15 04:19:30,740 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000004 is : 143
2016-01-15 04:19:30,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000002 is : 143
2016-01-15 04:19:41,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000005 is : 143
2016-01-15 04:19:41,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000006 is : 143
2016-01-15 04:19:41,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0028_01_000007 is : 143
2016-01-15 04:19:42,990 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2016-01-15 04:19:42,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:09.310, using cpu time: 00:20.140
2016-01-15 04:19:43,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup
2016-01-15 04:19:43,036 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:19:43,036 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:19:43,105 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-15 04:19:43,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 04:19:43,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:19:43,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting
2016-01-15 04:19:43,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:19:43,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-15 04:19:43,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] parallel execution of steps is enabled: true
2016-01-15 04:19:43,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executing total steps: 2
2016-01-15 04:19:43,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] allocating management threads: 2
2016-01-15 04:19:43,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (1/2)
2016-01-15 04:19:43,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1452830648025_0029
2016-01-15 04:19:43,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0029/
2016-01-15 04:20:10,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000002 is : 143
2016-01-15 04:20:11,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000003 is : 143
2016-01-15 04:20:12,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000005 is : 143
2016-01-15 04:20:12,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000007 is : 143
2016-01-15 04:20:12,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000006 is : 143
2016-01-15 04:20:13,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000004 is : 143
2016-01-15 04:20:13,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000008 is : 143
2016-01-15 04:20:21,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000011 is : 143
2016-01-15 04:20:21,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000009 is : 143
2016-01-15 04:20:21,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0029_01_000010 is : 143
2016-01-15 04:20:22,802 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2016-01-15 04:20:22,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1452830648025_0030
2016-01-15 04:20:22,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0030/
2016-01-15 04:20:54,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000006 is : 143
2016-01-15 04:20:54,478 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000004 is : 143
2016-01-15 04:20:54,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000008 is : 143
2016-01-15 04:20:54,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000009 is : 143
2016-01-15 04:20:55,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000003 is : 143
2016-01-15 04:20:55,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000005 is : 143
2016-01-15 04:20:55,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000007 is : 143
2016-01-15 04:20:55,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000002 is : 143
2016-01-15 04:21:04,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000010 is : 143
2016-01-15 04:21:04,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000012 is : 143
2016-01-15 04:21:05,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0030_01_000011 is : 143
2016-01-15 04:21:06,438 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-01-15 04:21:06,440 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] completed in: 01:23.287, using cpu time: 00:27.440
2016-01-15 04:21:06,459 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-15 04:21:06,480 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:21:06,481 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:21:06,521 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 04:21:06,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:21:06,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:21:06,531 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:21:06,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:21:06,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2016-01-15 04:21:06,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:21:06,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:21:06,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:21:06,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-15 04:21:06,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0031
2016-01-15 04:21:06,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0031/
2016-01-15 04:21:30,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0031_01_000002 is : 143
2016-01-15 04:21:31,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0031_01_000003 is : 143
2016-01-15 04:21:31,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0031_01_000005 is : 143
2016-01-15 04:21:31,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0031_01_000004 is : 143
2016-01-15 04:21:31,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0031_01_000006 is : 143
2016-01-15 04:21:32,781 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2016-01-15 04:21:32,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.245, using cpu time: 00:05.700
2016-01-15 04:21:32,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testReplace/replace
2016-01-15 04:21:32,854 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:21:32,855 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:21:32,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 04:21:32,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:21:32,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:21:32,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:21:32,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/extra+lower+upper.txt"]
2016-01-15 04:21:32,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-01-15 04:21:32,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:21:32,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:21:32,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:21:32,892 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-01-15 04:21:33,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0032
2016-01-15 04:21:33,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0032/
2016-01-15 04:21:57,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0032_01_000002 is : 143
2016-01-15 04:21:57,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0032_01_000004 is : 143
2016-01-15 04:21:57,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0032_01_000003 is : 143
2016-01-15 04:21:57,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0032_01_000005 is : 143
2016-01-15 04:21:58,949 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2016-01-15 04:21:58,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.058, using cpu time: 00:05.430
2016-01-15 04:21:58,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-01-15 04:21:58,997 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:21:58,998 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:21:59,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-15 04:21:59,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:21:59,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:21:59,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:21:59,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:21:59,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2016-01-15 04:21:59,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:21:59,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:21:59,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:21:59,031 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-15 04:21:59,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0033
2016-01-15 04:21:59,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0033/
2016-01-15 04:22:23,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0033_01_000003 is : 143
2016-01-15 04:22:23,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0033_01_000004 is : 143
2016-01-15 04:22:23,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0033_01_000005 is : 143
2016-01-15 04:22:23,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0033_01_000006 is : 143
2016-01-15 04:22:24,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0033_01_000002 is : 143
2016-01-15 04:22:25,700 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter/_temporary
2016-01-15 04:22:25,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:26.669, using cpu time: 00:04.960
2016-01-15 04:22:25,723 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilter/filter
2016-01-15 04:22:25,749 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:22:25,750 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:22:25,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-01-15 04:22:25,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2016-01-15 04:22:25,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] parallel execution of steps is enabled: true
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executing total steps: 5
2016-01-15 04:22:25,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] allocating management threads: 5
2016-01-15 04:22:25,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (1/5)
2016-01-15 04:22:26,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1452830648025_0034
2016-01-15 04:22:26,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0034/
2016-01-15 04:22:50,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000002 is : 143
2016-01-15 04:22:50,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000003 is : 143
2016-01-15 04:22:51,052 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000004 is : 143
2016-01-15 04:22:51,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000006 is : 143
2016-01-15 04:22:51,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000005 is : 143
2016-01-15 04:23:01,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000009 is : 143
2016-01-15 04:23:01,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000008 is : 143
2016-01-15 04:23:02,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0034_01_000007 is : 143
2016-01-15 04:23:03,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (3/5)
2016-01-15 04:23:03,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (2/5) ...rm/testSplitMultiple/left
2016-01-15 04:23:03,552 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1452830648025_0036
2016-01-15 04:23:03,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0036/
2016-01-15 04:23:03,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1452830648025_0035
2016-01-15 04:23:03,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0035/
2016-01-15 04:23:23,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0035_01_000002 is : 143
2016-01-15 04:23:24,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0035_01_000003 is : 143
2016-01-15 04:23:24,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0035_01_000004 is : 143
2016-01-15 04:23:45,433 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000002 is : 143
2016-01-15 04:23:45,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000003 is : 143
2016-01-15 04:23:45,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000004 is : 143
2016-01-15 04:23:55,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000007 is : 143
2016-01-15 04:23:56,103 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000006 is : 143
2016-01-15 04:23:56,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0036_01_000005 is : 143
2016-01-15 04:23:57,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (4/5) ...tSplitMultiple/rightright
2016-01-15 04:23:57,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (5/5) ...stSplitMultiple/rightleft
2016-01-15 04:23:57,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1452830648025_0037
2016-01-15 04:23:57,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0037/
2016-01-15 04:23:57,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1452830648025_0038
2016-01-15 04:23:57,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0038/
2016-01-15 04:24:17,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0037_01_000002 is : 143
2016-01-15 04:24:17,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0037_01_000003 is : 143
2016-01-15 04:24:18,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0037_01_000004 is : 143
2016-01-15 04:24:38,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0038_01_000003 is : 143
2016-01-15 04:24:38,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0038_01_000002 is : 143
2016-01-15 04:24:39,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0038_01_000004 is : 143
2016-01-15 04:24:40,330 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left/_temporary
2016-01-15 04:24:40,332 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2016-01-15 04:24:40,333 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2016-01-15 04:24:40,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] completed in: 02:14.429, using cpu time: 00:27.720
2016-01-15 04:24:40,385 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left
2016-01-15 04:24:40,391 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft
2016-01-15 04:24:40,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright
2016-01-15 04:24:40,426 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:24:40,426 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:24:40,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-15 04:24:40,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:24:40,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:24:40,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting
2016-01-15 04:24:40,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]]]
2016-01-15 04:24:40,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-01-15 04:24:40,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] parallel execution of steps is enabled: true
2016-01-15 04:24:40,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executing total steps: 1
2016-01-15 04:24:40,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] allocating management threads: 1
2016-01-15 04:24:40,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-01-15 04:24:40,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] submitted hadoop job: job_1452830648025_0039
2016-01-15 04:24:40,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0039/
2016-01-15 04:25:06,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000003 is : 143
2016-01-15 04:25:06,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000002 is : 143
2016-01-15 04:25:06,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000007 is : 143
2016-01-15 04:25:07,275 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000004 is : 143
2016-01-15 04:25:07,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000005 is : 143
2016-01-15 04:25:07,668 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000006 is : 143
2016-01-15 04:25:16,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000010 is : 143
2016-01-15 04:25:16,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000008 is : 143
2016-01-15 04:25:16,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0039_01_000009 is : 143
2016-01-15 04:25:18,015 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2016-01-15 04:25:18,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] completed in: 00:37.539, using cpu time: 00:11.080
2016-01-15 04:25:18,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat
2016-01-15 04:25:18,057 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:25:18,057 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:25:18,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-01-15 04:25:18,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-01-15 04:25:18,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:25:18,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-15 04:25:18,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:25:18,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-01-15 04:25:18,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-01-15 04:25:18,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] parallel execution of steps is enabled: true
2016-01-15 04:25:18,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executing total steps: 3
2016-01-15 04:25:18,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] allocating management threads: 3
2016-01-15 04:25:18,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2016-01-15 04:25:18,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0040
2016-01-15 04:25:18,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0040/
2016-01-15 04:25:42,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000002 is : 143
2016-01-15 04:25:43,201 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000004 is : 143
2016-01-15 04:25:43,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000003 is : 143
2016-01-15 04:25:43,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000005 is : 143
2016-01-15 04:25:43,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000006 is : 143
2016-01-15 04:25:53,864 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000009 is : 143
2016-01-15 04:25:54,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000008 is : 143
2016-01-15 04:25:54,719 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0040_01_000007 is : 143
2016-01-15 04:25:55,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2016-01-15 04:25:55,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2016-01-15 04:25:56,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0041
2016-01-15 04:25:56,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0041/
2016-01-15 04:25:56,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1452830648025_0042
2016-01-15 04:25:56,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0042/
2016-01-15 04:26:16,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0041_01_000004 is : 143
2016-01-15 04:26:16,445 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0041_01_000002 is : 143
2016-01-15 04:26:16,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0041_01_000003 is : 143
2016-01-15 04:26:37,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0042_01_000003 is : 143
2016-01-15 04:26:38,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0042_01_000002 is : 143
2016-01-15 04:26:38,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0042_01_000004 is : 143
2016-01-15 04:26:39,448 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2016-01-15 04:26:39,450 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2016-01-15 04:26:39,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] completed in: 01:21.277, using cpu time: 00:17.730
2016-01-15 04:26:39,488 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-01-15 04:26:39,495 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-01-15 04:26:39,513 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:26:39,513 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:26:39,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 04:26:39,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:26:39,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 04:26:39,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:26:39,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:26:39,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2016-01-15 04:26:39,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-15 04:26:39,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 04:26:39,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 04:26:39,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-01-15 04:26:39,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452830648025_0043
2016-01-15 04:26:39,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:46827/proxy/application_1452830648025_0043/
2016-01-15 04:27:04,512 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0043_01_000004 is : 143
2016-01-15 04:27:04,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0043_01_000002 is : 143
2016-01-15 04:27:04,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0043_01_000003 is : 143
2016-01-15 04:27:04,785 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0043_01_000006 is : 143
2016-01-15 04:27:05,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452830648025_0043_01_000005 is : 143
2016-01-15 04:27:06,785 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2016-01-15 04:27:06,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:27.238, using cpu time: 00:05.460
2016-01-15 04:27:07,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup