2016-01-15 03:15:26,053 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 03:15:26,077 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.CoGroupFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-01-15 03:15:26,121 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 03:15:27,210 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 03:15:27,919 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 03:15:32,539 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 03:15:32,756 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 03:15:32,937 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 03:15:33,121 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 03:15:50,230 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 03:15:50,360 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:15:50,361 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 03:15:50,425 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 8F38164A58BD4CA7B4A7365575D4C5B4
2016-01-15 03:15:50,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.108
2016-01-15 03:15:50,581 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:15:50,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:15:50,760 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 03:15:50,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:15:50,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:15:50,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:15:50,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner"]
2016-01-15 03:15:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:15:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:15:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:15:50,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupInner/cogroupinner
2016-01-15 03:15:51,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0001
2016-01-15 03:15:51,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0001/
2016-01-15 03:16:10,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000003 is : 143
2016-01-15 03:16:10,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000002 is : 143
2016-01-15 03:16:12,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000004 is : 143
2016-01-15 03:16:12,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000006 is : 143
2016-01-15 03:16:12,365 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000005 is : 143
2016-01-15 03:16:17,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0001_01_000007 is : 143
2016-01-15 03:16:19,134 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/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner/_temporary
2016-01-15 03:16:19,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:28.364, using cpu time: 00:08.630
2016-01-15 03:16:19,226 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:16:19,227 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 03:16:19,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-01-15 03:16:19,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:16:19,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:16:19,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:16:19,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:16:19,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:16:19,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup"]
2016-01-15 03:16:19,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:16:19,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:16:19,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:16:19,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupinner-resultgroup
2016-01-15 03:16:19,427 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 03:16:19,428 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 03:16:19,428 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 03:16:19,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0002
2016-01-15 03:16:19,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0002/
2016-01-15 03:16:19,889 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 03:16:19,890 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 03:16:19,890 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 03:16:19,890 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 03:16:19,891 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 03:16:19,891 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 03:16:19,891 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 03:16:19,891 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 03:16:44,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000003 is : 143
2016-01-15 03:16:44,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000002 is : 143
2016-01-15 03:16:44,697 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000005 is : 143
2016-01-15 03:16:44,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000004 is : 143
2016-01-15 03:16:45,003 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000006 is : 143
2016-01-15 03:16:50,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0002_01_000007 is : 143
2016-01-15 03:16:51,827 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/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup/_temporary
2016-01-15 03:16:51,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.489, using cpu time: 00:07.730
2016-01-15 03:16:51,873 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/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner
2016-01-15 03:16:51,881 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/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup
2016-01-15 03:16:51,963 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:16:51,964 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 03:16:52,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-01-15 03:16:52,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:16:52,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:16:52,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting
2016-01-15 03:16:52,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] 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 03:16:52,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] 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 03:16:52,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] 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 03:16:52,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] sink: Hfs["TextDelimited[[0:5]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed"]
2016-01-15 03:16:52,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] parallel execution of steps is enabled: true
2016-01-15 03:16:52,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] executing total steps: 1
2016-01-15 03:16:52,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] allocating management threads: 1
2016-01-15 03:16:52,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting step: (1/1) ...CoGroupMixed/cogroupmixed
2016-01-15 03:16:52,283 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] submitted hadoop job: job_1452827744728_0003
2016-01-15 03:16:52,283 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0003/
2016-01-15 03:17:26,019 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000008 is : 143
2016-01-15 03:17:26,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000007 is : 143
2016-01-15 03:17:27,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000006 is : 143
2016-01-15 03:17:27,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000009 is : 143
2016-01-15 03:17:27,864 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000002 is : 143
2016-01-15 03:17:27,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000003 is : 143
2016-01-15 03:17:27,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000004 is : 143
2016-01-15 03:17:28,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000005 is : 143
2016-01-15 03:17:33,284 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0003_01_000011 is : 143
2016-01-15 03:17:34,494 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/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed/_temporary
2016-01-15 03:17:34,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] completed in: 00:42.412, using cpu time: 00:11.810
2016-01-15 03:17:34,548 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/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed
2016-01-15 03:17:34,576 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:17:34,577 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 03:17:34,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-15 03:17:34,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:17:34,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:17:34,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:17:34,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:17:34,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:17:34,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter"]
2016-01-15 03:17:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:17:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:17:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:17:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupOuter/cogroupouter
2016-01-15 03:17:34,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0004
2016-01-15 03:17:34,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0004/
2016-01-15 03:17:59,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000005 is : 143
2016-01-15 03:17:59,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000004 is : 143
2016-01-15 03:18:00,201 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000003 is : 143
2016-01-15 03:18:00,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000002 is : 143
2016-01-15 03:18:00,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000006 is : 143
2016-01-15 03:18:06,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0004_01_000007 is : 143
2016-01-15 03:18:08,004 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/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter/_temporary
2016-01-15 03:18:08,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.343, using cpu time: 00:06.970
2016-01-15 03:18:08,086 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:18:08,087 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 03:18:08,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-01-15 03:18:08,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:18:08,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:18:08,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:18:08,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:18:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:18:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup"]
2016-01-15 03:18:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:18:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:18:08,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:18:08,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupouter-resultgroup
2016-01-15 03:18:08,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0005
2016-01-15 03:18:08,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0005/
2016-01-15 03:18:33,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0005_01_000006 is : 143
2016-01-15 03:18:33,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0005_01_000002 is : 143
2016-01-15 03:18:33,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0005_01_000004 is : 143
2016-01-15 03:18:33,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0005_01_000003 is : 143
2016-01-15 03:18:40,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0005_01_000007 is : 143
2016-01-15 03:18:41,596 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/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup/_temporary
2016-01-15 03:18:41,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.428, using cpu time: 00:08.480
2016-01-15 03:18:41,638 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/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup
2016-01-15 03:18:41,646 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/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter
2016-01-15 03:18:41,698 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:18:41,698 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 03:18:41,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-01-15 03:18:41,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:18:41,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:18:41,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2016-01-15 03:18:41,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.10.txt"]
2016-01-15 03:18:41,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.10.txt"]
2016-01-15 03:18:41,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-01-15 03:18:41,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2"]
2016-01-15 03:18:41,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] parallel execution of steps is enabled: true
2016-01-15 03:18:41,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executing total steps: 2
2016-01-15 03:18:41,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] allocating management threads: 2
2016-01-15 03:18:41,830 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2016-01-15 03:18:41,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1452827744728_0006
2016-01-15 03:18:41,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0006/
2016-01-15 03:19:06,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000002 is : 143
2016-01-15 03:19:06,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000005 is : 143
2016-01-15 03:19:06,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000003 is : 143
2016-01-15 03:19:06,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000006 is : 143
2016-01-15 03:19:07,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000004 is : 143
2016-01-15 03:19:12,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0006_01_000007 is : 143
2016-01-15 03:19:13,812 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...pWith/cogroupacogroupopt2
2016-01-15 03:19:14,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1452827744728_0007
2016-01-15 03:19:14,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0007/
2016-01-15 03:19:38,121 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000002 is : 143
2016-01-15 03:19:38,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000003 is : 143
2016-01-15 03:19:38,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000005 is : 143
2016-01-15 03:19:38,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000006 is : 143
2016-01-15 03:19:39,183 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000004 is : 143
2016-01-15 03:19:45,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0007_01_000007 is : 143
2016-01-15 03:19:46,616 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2/_temporary
2016-01-15 03:19:46,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] completed in: 01:04.784, using cpu time: 00:13.120
2016-01-15 03:19:46,652 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2
2016-01-15 03:19:46,677 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:19:46,677 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 03:19:46,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.091
2016-01-15 03:19:46,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:19:46,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:19:46,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2016-01-15 03:19:46,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.10.txt"]
2016-01-15 03:19:46,809 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.10.txt"]
2016-01-15 03:19:46,809 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-01-15 03:19:46,809 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1"]
2016-01-15 03:19:46,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] parallel execution of steps is enabled: true
2016-01-15 03:19:46,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executing total steps: 2
2016-01-15 03:19:46,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] allocating management threads: 2
2016-01-15 03:19:46,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2016-01-15 03:19:46,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1452827744728_0008
2016-01-15 03:19:46,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0008/
2016-01-15 03:20:11,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0008_01_000003 is : 143
2016-01-15 03:20:11,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0008_01_000005 is : 143
2016-01-15 03:20:12,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0008_01_000006 is : 143
2016-01-15 03:20:12,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0008_01_000004 is : 143
2016-01-15 03:20:19,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0008_01_000007 is : 143
2016-01-15 03:20:20,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...thout/cogroupacogroupopt1
2016-01-15 03:20:20,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1452827744728_0009
2016-01-15 03:20:20,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0009/
2016-01-15 03:20:44,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000002 is : 143
2016-01-15 03:20:45,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000006 is : 143
2016-01-15 03:20:45,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000005 is : 143
2016-01-15 03:20:45,486 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000003 is : 143
2016-01-15 03:20:45,543 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000004 is : 143
2016-01-15 03:20:51,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0009_01_000007 is : 143
2016-01-15 03:20:52,544 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1/_temporary
2016-01-15 03:20:52,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] completed in: 01:05.732, using cpu time: 00:13.670
2016-01-15 03:20:52,591 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1
2016-01-15 03:20:52,615 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:20:52,615 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 03:20:52,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-15 03:20:52,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:20:52,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:20:52,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2016-01-15 03:20:52,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] 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 03:20:52,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] 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 03:20:52,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] 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 03:20:52,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup"]
2016-01-15 03:20:52,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-01-15 03:20:52,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 2
2016-01-15 03:20:52,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 2
2016-01-15 03:20:52,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/2)
2016-01-15 03:20:52,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452827744728_0010
2016-01-15 03:20:52,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0010/
2016-01-15 03:21:18,564 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000003 is : 143
2016-01-15 03:21:18,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000002 is : 143
2016-01-15 03:21:19,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000006 is : 143
2016-01-15 03:21:19,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000005 is : 143
2016-01-15 03:21:19,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000007 is : 143
2016-01-15 03:21:19,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000004 is : 143
2016-01-15 03:21:25,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0010_01_000008 is : 143
2016-01-15 03:21:27,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/2) ...ndCoGroup/cogroupacogroup
2016-01-15 03:21:27,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452827744728_0011
2016-01-15 03:21:27,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0011/
2016-01-15 03:21:53,454 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000005 is : 143
2016-01-15 03:21:53,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000003 is : 143
2016-01-15 03:21:54,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000004 is : 143
2016-01-15 03:21:54,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000002 is : 143
2016-01-15 03:21:54,700 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000006 is : 143
2016-01-15 03:21:54,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000007 is : 143
2016-01-15 03:22:00,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0011_01_000008 is : 143
2016-01-15 03:22:01,367 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup/_temporary
2016-01-15 03:22:01,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 01:08.630, using cpu time: 00:16.170
2016-01-15 03:22:01,403 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/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup
2016-01-15 03:22:01,427 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:22:01,428 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 03:22:01,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-15 03:22:01,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:22:01,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:22:01,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:22:01,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:22:01,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:22:01,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter"]
2016-01-15 03:22:01,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:22:01,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:22:01,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:22:01,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erOuter/cogroupinnerouter
2016-01-15 03:22:01,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0012
2016-01-15 03:22:01,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0012/
2016-01-15 03:22:25,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000004 is : 143
2016-01-15 03:22:26,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000005 is : 143
2016-01-15 03:22:26,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000006 is : 143
2016-01-15 03:22:26,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000003 is : 143
2016-01-15 03:22:26,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000002 is : 143
2016-01-15 03:22:32,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0012_01_000007 is : 143
2016-01-15 03:22:33,396 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/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter/_temporary
2016-01-15 03:22:33,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:31.891, using cpu time: 00:06.790
2016-01-15 03:22:33,448 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:22:33,449 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 03:22:33,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-15 03:22:33,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:22:33,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:22:33,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:22:33,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:22:33,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:22:33,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup"]
2016-01-15 03:22:33,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:22:33,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:22:33,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:22:33,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupinnerouter-resultgroup
2016-01-15 03:22:33,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0013
2016-01-15 03:22:33,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0013/
2016-01-15 03:22:58,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000002 is : 143
2016-01-15 03:22:58,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000004 is : 143
2016-01-15 03:22:58,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000003 is : 143
2016-01-15 03:22:58,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000005 is : 143
2016-01-15 03:22:58,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000006 is : 143
2016-01-15 03:23:04,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0013_01_000007 is : 143
2016-01-15 03:23:06,012 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/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup/_temporary
2016-01-15 03:23:06,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.504, using cpu time: 00:07.070
2016-01-15 03:23:06,061 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/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup
2016-01-15 03:23:06,066 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/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter
2016-01-15 03:23:06,087 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:23:06,088 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 03:23:06,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 03:23:06,132 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:23:06,132 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:23:06,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:23:06,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:23:06,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:23:06,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields"]
2016-01-15 03:23:06,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:23:06,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:23:06,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:23:06,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupDiffFields/difffields
2016-01-15 03:23:06,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0014
2016-01-15 03:23:06,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0014/
2016-01-15 03:23:32,011 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000003 is : 143
2016-01-15 03:23:32,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000002 is : 143
2016-01-15 03:23:33,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000004 is : 143
2016-01-15 03:23:33,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000006 is : 143
2016-01-15 03:23:33,328 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000007 is : 143
2016-01-15 03:23:33,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000005 is : 143
2016-01-15 03:23:38,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0014_01_000008 is : 143
2016-01-15 03:23:39,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/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields/_temporary
2016-01-15 03:23:39,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.541, using cpu time: 00:08.600
2016-01-15 03:23:39,753 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/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields
2016-01-15 03:23:39,774 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:23:39,774 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 03:23:39,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 03:23:39,807 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:23:39,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:23:39,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-15 03:23:39,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] 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 03:23:39,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2"]
2016-01-15 03:23:39,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-15 03:23:39,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-15 03:23:39,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-15 03:23:39,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...oGroupSamePipe2/samepipe2
2016-01-15 03:23:39,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452827744728_0015
2016-01-15 03:23:39,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0015/
2016-01-15 03:24:03,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000005 is : 143
2016-01-15 03:24:04,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000006 is : 143
2016-01-15 03:24:04,248 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000002 is : 143
2016-01-15 03:24:04,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000004 is : 143
2016-01-15 03:24:04,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000003 is : 143
2016-01-15 03:24:10,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0015_01_000007 is : 143
2016-01-15 03:24:11,881 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/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2/_temporary
2016-01-15 03:24:11,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:32.058, using cpu time: 00:07.720
2016-01-15 03:24:11,917 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/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2
2016-01-15 03:24:11,940 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:24:11,940 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 03:24:11,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-15 03:24:11,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:24:11,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:24:11,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2016-01-15 03:24:11,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] 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 03:24:11,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3"]
2016-01-15 03:24:11,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] parallel execution of steps is enabled: true
2016-01-15 03:24:11,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executing total steps: 1
2016-01-15 03:24:11,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] allocating management threads: 1
2016-01-15 03:24:11,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...oGroupSamePipe3/samepipe3
2016-01-15 03:24:12,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1452827744728_0016
2016-01-15 03:24:12,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0016/
2016-01-15 03:24:35,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000004 is : 143
2016-01-15 03:24:36,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000003 is : 143
2016-01-15 03:24:36,246 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000005 is : 143
2016-01-15 03:24:36,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000002 is : 143
2016-01-15 03:24:36,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000006 is : 143
2016-01-15 03:24:42,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0016_01_000007 is : 143
2016-01-15 03:24:43,415 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/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3/_temporary
2016-01-15 03:24:43,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] completed in: 00:31.428, using cpu time: 00:06.790
2016-01-15 03:24:43,448 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/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3
2016-01-15 03:24:43,494 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:24:43,494 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 03:24:43,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-15 03:24:43,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:24:43,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:24:43,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-15 03:24:43,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-01-15 03:24:43,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-01-15 03:24:43,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross"]
2016-01-15 03:24:43,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-01-15 03:24:43,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2016-01-15 03:24:43,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2016-01-15 03:24:43,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-01-15 03:24:43,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452827744728_0017
2016-01-15 03:24:43,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0017/
2016-01-15 03:25:07,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000002 is : 143
2016-01-15 03:25:07,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000003 is : 143
2016-01-15 03:25:08,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000005 is : 143
2016-01-15 03:25:08,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000004 is : 143
2016-01-15 03:25:08,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000006 is : 143
2016-01-15 03:25:13,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0017_01_000007 is : 143
2016-01-15 03:25:14,828 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/cogroupfieldedpipesplatform/testCross/cross/_temporary
2016-01-15 03:25:14,830 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:31.268, using cpu time: 00:06.940
2016-01-15 03:25:14,864 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/cogroupfieldedpipesplatform/testCross/cross
2016-01-15 03:25:14,885 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:25:14,885 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 03:25:14,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-15 03:25:14,941 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:25:14,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:25:14,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-15 03:25:14,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] 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 03:25:14,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe"]
2016-01-15 03:25:14,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-15 03:25:14,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-15 03:25:14,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-15 03:25:14,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tCoGroupSamePipe/samepipe
2016-01-15 03:25:15,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452827744728_0018
2016-01-15 03:25:15,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0018/
2016-01-15 03:25:39,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000002 is : 143
2016-01-15 03:25:39,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000003 is : 143
2016-01-15 03:25:39,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000006 is : 143
2016-01-15 03:25:39,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000005 is : 143
2016-01-15 03:25:40,365 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000004 is : 143
2016-01-15 03:25:45,752 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0018_01_000007 is : 143
2016-01-15 03:25:46,923 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/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe/_temporary
2016-01-15 03:25:46,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:31.965, using cpu time: 00:07.520
2016-01-15 03:25:46,957 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/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe
2016-01-15 03:25:46,986 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:25:46,987 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 03:25:47,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 03:25:47,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:25:47,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:25:47,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:25:47,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:25:47,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:25:47,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone"]
2016-01-15 03:25:47,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:25:47,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:25:47,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:25:47,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-01-15 03:25:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0019
2016-01-15 03:25:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0019/
2016-01-15 03:26:12,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000003 is : 143
2016-01-15 03:26:12,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000002 is : 143
2016-01-15 03:26:13,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000007 is : 143
2016-01-15 03:26:13,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000006 is : 143
2016-01-15 03:26:13,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000005 is : 143
2016-01-15 03:26:14,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000004 is : 143
2016-01-15 03:26:19,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0019_01_000008 is : 143
2016-01-15 03:26:20,841 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/cogroupfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-01-15 03:26:20,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.791, using cpu time: 00:07.890
2016-01-15 03:26:20,876 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/cogroupfieldedpipesplatform/testJoinNone/joinnone
2016-01-15 03:26:20,898 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:26:20,899 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 03:26:20,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-15 03:26:20,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 03:26:20,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:26:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:26:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:26:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:26:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery"]
2016-01-15 03:26:21,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:26:21,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 03:26:21,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 03:26:21,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 03:26:21,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 03:26:21,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0021
2016-01-15 03:26:21,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0021/
2016-01-15 03:26:21,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0020
2016-01-15 03:26:21,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0020/
2016-01-15 03:26:45,878 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000002 is : 143
2016-01-15 03:26:46,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000004 is : 143
2016-01-15 03:26:46,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000005 is : 143
2016-01-15 03:26:46,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000003 is : 143
2016-01-15 03:26:46,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000006 is : 143
2016-01-15 03:26:53,470 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0020_01_000007 is : 143
2016-01-15 03:27:19,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000004 is : 143
2016-01-15 03:27:19,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000005 is : 143
2016-01-15 03:27:19,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000003 is : 143
2016-01-15 03:27:19,924 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000002 is : 143
2016-01-15 03:27:20,091 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000006 is : 143
2016-01-15 03:27:26,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0021_01_000007 is : 143
2016-01-15 03:27:27,382 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...roupAfterEvery/afterevery
2016-01-15 03:27:27,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0022
2016-01-15 03:27:27,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0022/
2016-01-15 03:27:45,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0022_01_000002 is : 143
2016-01-15 03:27:46,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0022_01_000003 is : 143
2016-01-15 03:27:52,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0022_01_000004 is : 143
2016-01-15 03:27:53,452 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/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery/_temporary
2016-01-15 03:27:53,458 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:32.427, using cpu time: 00:17.080
2016-01-15 03:27:53,491 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/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery
2016-01-15 03:27:53,526 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:27:53,527 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 03:27:53,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.143
2016-01-15 03:27:53,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 10
2016-01-15 03:27:53,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:27:53,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2016-01-15 03:27:53,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-01-15 03:27:53,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-01-15 03:27:53,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer"]
2016-01-15 03:27:53,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner"]
2016-01-15 03:27:53,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left"]
2016-01-15 03:27:53,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right"]
2016-01-15 03:27:53,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] parallel execution of steps is enabled: true
2016-01-15 03:27:53,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executing total steps: 5
2016-01-15 03:27:53,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] allocating management threads: 5
2016-01-15 03:27:53,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/5)
2016-01-15 03:27:53,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0023
2016-01-15 03:27:53,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0023/
2016-01-15 03:28:15,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0023_01_000002 is : 143
2016-01-15 03:28:15,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0023_01_000005 is : 143
2016-01-15 03:28:15,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0023_01_000003 is : 143
2016-01-15 03:28:15,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0023_01_000004 is : 143
2016-01-15 03:28:21,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0023_01_000006 is : 143
2016-01-15 03:28:23,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/5) ...tform/testMultiJoin/outer
2016-01-15 03:28:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/5) ...tform/testMultiJoin/right
2016-01-15 03:28:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/5) ...atform/testMultiJoin/left
2016-01-15 03:28:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (5/5) ...tform/testMultiJoin/inner
2016-01-15 03:28:23,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0024
2016-01-15 03:28:23,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0024/
2016-01-15 03:28:23,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0026
2016-01-15 03:28:23,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0026/
2016-01-15 03:28:23,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0027
2016-01-15 03:28:23,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0027/
2016-01-15 03:28:23,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0025
2016-01-15 03:28:23,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0025/
2016-01-15 03:28:48,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000005 is : 143
2016-01-15 03:28:49,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000006 is : 143
2016-01-15 03:28:49,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000002 is : 143
2016-01-15 03:28:49,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000003 is : 143
2016-01-15 03:28:49,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000004 is : 143
2016-01-15 03:28:55,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0024_01_000007 is : 143
2016-01-15 03:29:20,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000003 is : 143
2016-01-15 03:29:21,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000002 is : 143
2016-01-15 03:29:21,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000005 is : 143
2016-01-15 03:29:21,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000004 is : 143
2016-01-15 03:29:21,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000006 is : 143
2016-01-15 03:29:27,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0025_01_000007 is : 143
2016-01-15 03:29:53,128 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000003 is : 143
2016-01-15 03:29:53,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000005 is : 143
2016-01-15 03:29:54,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000002 is : 143
2016-01-15 03:29:54,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000004 is : 143
2016-01-15 03:29:54,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000006 is : 143
2016-01-15 03:29:59,863 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0026_01_000007 is : 143
2016-01-15 03:30:24,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000006 is : 143
2016-01-15 03:30:25,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000004 is : 143
2016-01-15 03:30:25,897 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000005 is : 143
2016-01-15 03:30:26,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000003 is : 143
2016-01-15 03:30:26,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000002 is : 143
2016-01-15 03:30:31,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0027_01_000007 is : 143
2016-01-15 03:30:32,978 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/cogroupfieldedpipesplatform/testMultiJoin/outer/_temporary
2016-01-15 03:30:32,980 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/cogroupfieldedpipesplatform/testMultiJoin/left/_temporary
2016-01-15 03:30:32,981 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/cogroupfieldedpipesplatform/testMultiJoin/right/_temporary
2016-01-15 03:30:32,982 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/cogroupfieldedpipesplatform/testMultiJoin/inner/_temporary
2016-01-15 03:30:32,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] completed in: 02:39.195, using cpu time: 00:37.310
2016-01-15 03:30:33,060 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/cogroupfieldedpipesplatform/testMultiJoin/inner
2016-01-15 03:30:33,065 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/cogroupfieldedpipesplatform/testMultiJoin/right
2016-01-15 03:30:33,069 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/cogroupfieldedpipesplatform/testMultiJoin/left
2016-01-15 03:30:33,073 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/cogroupfieldedpipesplatform/testMultiJoin/outer
2016-01-15 03:30:33,094 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:30:33,094 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 03:30:33,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 03:30:33,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:30:33,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:30:33,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting
2016-01-15 03:30:33,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] 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 03:30:33,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:30:33,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields"]
2016-01-15 03:30:33,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] parallel execution of steps is enabled: true
2016-01-15 03:30:33,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] executing total steps: 1
2016-01-15 03:30:33,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] allocating management threads: 1
2016-01-15 03:30:33,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting step: (1/1) ...meFile/samefiledifffields
2016-01-15 03:30:33,269 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] submitted hadoop job: job_1452827744728_0028
2016-01-15 03:30:33,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0028/
2016-01-15 03:30:59,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000003 is : 143
2016-01-15 03:31:00,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000005 is : 143
2016-01-15 03:31:00,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000006 is : 143
2016-01-15 03:31:00,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000007 is : 143
2016-01-15 03:31:00,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000002 is : 143
2016-01-15 03:31:01,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000004 is : 143
2016-01-15 03:31:07,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0028_01_000008 is : 143
2016-01-15 03:31:08,606 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/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields/_temporary
2016-01-15 03:31:08,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] completed in: 00:35.452, using cpu time: 00:08.230
2016-01-15 03:31:08,639 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/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields
2016-01-15 03:31:08,658 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:31:08,659 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 03:31:08,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-15 03:31:08,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:31:08,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:31:08,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:31:08,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:31:08,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:31:08,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner"]
2016-01-15 03:31:08,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:31:08,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:31:08,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:31:08,723 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erInner/cogroupouterinner
2016-01-15 03:31:08,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0029
2016-01-15 03:31:08,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0029/
2016-01-15 03:31:32,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000003 is : 143
2016-01-15 03:31:32,589 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000002 is : 143
2016-01-15 03:31:33,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000006 is : 143
2016-01-15 03:31:33,460 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000004 is : 143
2016-01-15 03:31:33,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000005 is : 143
2016-01-15 03:31:39,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0029_01_000007 is : 143
2016-01-15 03:31:40,795 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/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner/_temporary
2016-01-15 03:31:40,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.070, using cpu time: 00:07.500
2016-01-15 03:31:40,851 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:31:40,851 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 03:31:40,887 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-15 03:31:40,888 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:31:40,888 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:31:40,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:31:40,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:31:40,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:31:40,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup"]
2016-01-15 03:31:40,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:31:40,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:31:40,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:31:40,905 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupouterinner-resultgroup
2016-01-15 03:31:41,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0030
2016-01-15 03:31:41,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0030/
2016-01-15 03:32:05,197 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0030_01_000006 is : 143
2016-01-15 03:32:05,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0030_01_000003 is : 143
2016-01-15 03:32:05,772 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0030_01_000005 is : 143
2016-01-15 03:32:05,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0030_01_000004 is : 143
2016-01-15 03:32:12,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0030_01_000007 is : 143
2016-01-15 03:32:13,214 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/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup/_temporary
2016-01-15 03:32:13,215 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.311, using cpu time: 00:06.870
2016-01-15 03:32:13,247 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/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup
2016-01-15 03:32:13,252 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/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner
2016-01-15 03:32:13,275 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:32:13,276 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 03:32:13,402 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2016-01-15 03:32:13,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 8
2016-01-15 03:32:13,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:32:13,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2016-01-15 03:32:13,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-01-15 03:32:13,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs"]
2016-01-15 03:32:13,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs"]
2016-01-15 03:32:13,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs"]
2016-01-15 03:32:13,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs"]
2016-01-15 03:32:13,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] parallel execution of steps is enabled: true
2016-01-15 03:32:13,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executing total steps: 4
2016-01-15 03:32:13,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] allocating management threads: 4
2016-01-15 03:32:13,471 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/4) ...tiJoinWithSplits/innerLhs
2016-01-15 03:32:13,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/4) ...tiJoinWithSplits/innerRhs
2016-01-15 03:32:13,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/4) ...JoinWithSplits/uniquesRhs
2016-01-15 03:32:13,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/4) ...JoinWithSplits/uniquesLhs
2016-01-15 03:32:13,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0032
2016-01-15 03:32:13,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0032/
2016-01-15 03:32:13,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0033
2016-01-15 03:32:13,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0033/
2016-01-15 03:32:14,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0034
2016-01-15 03:32:14,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0034/
2016-01-15 03:32:14,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1452827744728_0031
2016-01-15 03:32:14,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0031/
2016-01-15 03:32:36,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0031_01_000003 is : 143
2016-01-15 03:32:36,558 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0031_01_000002 is : 143
2016-01-15 03:32:36,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0031_01_000005 is : 143
2016-01-15 03:32:36,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0031_01_000004 is : 143
2016-01-15 03:32:43,668 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0031_01_000006 is : 143
2016-01-15 03:33:08,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0032_01_000005 is : 143
2016-01-15 03:33:08,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0032_01_000002 is : 143
2016-01-15 03:33:08,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0032_01_000003 is : 143
2016-01-15 03:33:15,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0032_01_000006 is : 143
2016-01-15 03:33:39,769 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0033_01_000004 is : 143
2016-01-15 03:33:39,837 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0033_01_000002 is : 143
2016-01-15 03:33:39,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0033_01_000003 is : 143
2016-01-15 03:33:40,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0033_01_000005 is : 143
2016-01-15 03:33:47,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0033_01_000006 is : 143
2016-01-15 03:34:10,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0034_01_000002 is : 143
2016-01-15 03:34:11,103 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0034_01_000003 is : 143
2016-01-15 03:34:11,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0034_01_000004 is : 143
2016-01-15 03:34:11,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0034_01_000005 is : 143
2016-01-15 03:34:18,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0034_01_000006 is : 143
2016-01-15 03:34:19,277 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs/_temporary
2016-01-15 03:34:19,279 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs/_temporary
2016-01-15 03:34:19,280 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs/_temporary
2016-01-15 03:34:19,282 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs/_temporary
2016-01-15 03:34:19,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] completed in: 02:05.803, using cpu time: 00:25.020
2016-01-15 03:34:19,447 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs
2016-01-15 03:34:19,452 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs
2016-01-15 03:34:19,456 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs
2016-01-15 03:34:19,461 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/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs
2016-01-15 03:34:19,489 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:34:19,490 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 03:34:19,523 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 03:34:19,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:34:19,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:34:19,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:34:19,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:34:19,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:34:19,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull"]
2016-01-15 03:34:19,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:34:19,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:34:19,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:34:19,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupinnerouternull
2016-01-15 03:34:19,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0035
2016-01-15 03:34:19,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0035/
2016-01-15 03:34:43,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000005 is : 143
2016-01-15 03:34:44,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000003 is : 143
2016-01-15 03:34:44,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000002 is : 143
2016-01-15 03:34:44,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000006 is : 143
2016-01-15 03:34:44,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000004 is : 143
2016-01-15 03:34:50,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0035_01_000007 is : 143
2016-01-15 03:34:51,993 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/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull/_temporary
2016-01-15 03:34:51,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.449, using cpu time: 00:06.820
2016-01-15 03:34:52,049 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:34:52,049 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 03:34:52,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-15 03:34:52,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:34:52,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:34:52,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:34:52,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:34:52,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:34:52,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup"]
2016-01-15 03:34:52,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:34:52,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:34:52,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:34:52,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerouternull-resultgroup
2016-01-15 03:34:52,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0036
2016-01-15 03:34:52,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0036/
2016-01-15 03:35:16,272 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000003 is : 143
2016-01-15 03:35:16,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000004 is : 143
2016-01-15 03:35:16,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000002 is : 143
2016-01-15 03:35:16,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000005 is : 143
2016-01-15 03:35:17,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000006 is : 143
2016-01-15 03:35:23,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0036_01_000007 is : 143
2016-01-15 03:35:24,536 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/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup/_temporary
2016-01-15 03:35:24,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.419, using cpu time: 00:06.820
2016-01-15 03:35:24,570 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/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup
2016-01-15 03:35:24,575 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/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull
2016-01-15 03:35:24,595 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:35:24,595 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 03:35:24,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-15 03:35:24,633 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:35:24,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:35:24,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:35:24,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:35:24,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:35:24,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull"]
2016-01-15 03:35:24,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:35:24,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:35:24,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:35:24,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterNull/cogroupouternull
2016-01-15 03:35:24,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0037
2016-01-15 03:35:24,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0037/
2016-01-15 03:35:49,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000004 is : 143
2016-01-15 03:35:49,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000003 is : 143
2016-01-15 03:35:49,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000002 is : 143
2016-01-15 03:35:49,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000005 is : 143
2016-01-15 03:35:49,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000006 is : 143
2016-01-15 03:35:56,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0037_01_000007 is : 143
2016-01-15 03:35:57,536 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/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull/_temporary
2016-01-15 03:35:57,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.883, using cpu time: 00:06.960
2016-01-15 03:35:57,591 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:35:57,591 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 03:35:57,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 03:35:57,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:35:57,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:35:57,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:35:57,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:35:57,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:35:57,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup"]
2016-01-15 03:35:57,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:35:57,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:35:57,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:35:57,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupouternull-resultgroup
2016-01-15 03:35:57,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0038
2016-01-15 03:35:57,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0038/
2016-01-15 03:36:21,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000006 is : 143
2016-01-15 03:36:21,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000005 is : 143
2016-01-15 03:36:22,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000002 is : 143
2016-01-15 03:36:22,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000003 is : 143
2016-01-15 03:36:22,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000004 is : 143
2016-01-15 03:36:28,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0038_01_000007 is : 143
2016-01-15 03:36:29,858 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/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup/_temporary
2016-01-15 03:36:29,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.217, using cpu time: 00:07.740
2016-01-15 03:36:29,907 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/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup
2016-01-15 03:36:29,912 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/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull
2016-01-15 03:36:29,932 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:36:29,933 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 03:36:29,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-15 03:36:29,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:36:29,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:36:30,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2016-01-15 03:36:30,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] 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 03:36:30,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] 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 03:36:30,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] 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 03:36:30,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] 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 03:36:30,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs"]
2016-01-15 03:36:30,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs"]
2016-01-15 03:36:30,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] parallel execution of steps is enabled: true
2016-01-15 03:36:30,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executing total steps: 2
2016-01-15 03:36:30,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] allocating management threads: 2
2016-01-15 03:36:30,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/2) ...Self/splitcogroupself/lhs
2016-01-15 03:36:30,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/2) ...Self/splitcogroupself/rhs
2016-01-15 03:36:30,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1452827744728_0039
2016-01-15 03:36:30,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0039/
2016-01-15 03:36:30,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1452827744728_0040
2016-01-15 03:36:30,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0040/
2016-01-15 03:36:54,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000002 is : 143
2016-01-15 03:36:55,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000003 is : 143
2016-01-15 03:36:55,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000004 is : 143
2016-01-15 03:36:55,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000005 is : 143
2016-01-15 03:36:55,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000006 is : 143
2016-01-15 03:37:02,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0039_01_000007 is : 143
2016-01-15 03:37:28,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0040_01_000005 is : 143
2016-01-15 03:37:28,719 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0040_01_000004 is : 143
2016-01-15 03:37:28,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0040_01_000006 is : 143
2016-01-15 03:37:28,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0040_01_000003 is : 143
2016-01-15 03:37:35,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0040_01_000007 is : 143
2016-01-15 03:37:37,081 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/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs/_temporary
2016-01-15 03:37:37,083 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/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs/_temporary
2016-01-15 03:37:37,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] completed in: 01:07.062, using cpu time: 00:13.940
2016-01-15 03:37:37,126 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/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs
2016-01-15 03:37:37,131 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/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs
2016-01-15 03:37:37,150 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:37:37,151 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 03:37:37,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-15 03:37:37,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:37:37,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:37:37,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2016-01-15 03:37:37,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] 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 03:37:37,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] 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 03:37:37,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes"]
2016-01-15 03:37:37,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] parallel execution of steps is enabled: true
2016-01-15 03:37:37,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executing total steps: 1
2016-01-15 03:37:37,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] allocating management threads: 1
2016-01-15 03:37:37,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-01-15 03:37:37,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1452827744728_0041
2016-01-15 03:37:37,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0041/
2016-01-15 03:38:02,483 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000006 is : 143
2016-01-15 03:38:03,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000007 is : 143
2016-01-15 03:38:03,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000002 is : 143
2016-01-15 03:38:04,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000004 is : 143
2016-01-15 03:38:04,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000003 is : 143
2016-01-15 03:38:04,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000005 is : 143
2016-01-15 03:38:09,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0041_01_000008 is : 143
2016-01-15 03:38:10,243 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/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes/_temporary
2016-01-15 03:38:10,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] completed in: 00:33.037, using cpu time: 00:07.900
2016-01-15 03:38:10,283 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/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes
2016-01-15 03:38:10,313 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:38:10,313 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 03:38:10,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-15 03:38:10,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:38:10,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:38:10,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:38:10,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:38:10,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:38:10,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch"]
2016-01-15 03:38:10,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:38:10,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2016-01-15 03:38:10,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2016-01-15 03:38:10,401 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-15 03:38:10,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0042
2016-01-15 03:38:10,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0042/
2016-01-15 03:38:34,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000006 is : 143
2016-01-15 03:38:34,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000004 is : 143
2016-01-15 03:38:35,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000002 is : 143
2016-01-15 03:38:35,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000003 is : 143
2016-01-15 03:38:35,438 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000005 is : 143
2016-01-15 03:38:41,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0042_01_000007 is : 143
2016-01-15 03:38:42,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...nch/cogroupfilteredbranch
2016-01-15 03:38:42,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0043
2016-01-15 03:38:42,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0043/
2016-01-15 03:39:09,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000003 is : 143
2016-01-15 03:39:09,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000002 is : 143
2016-01-15 03:39:09,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000004 is : 143
2016-01-15 03:39:09,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000007 is : 143
2016-01-15 03:39:09,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000005 is : 143
2016-01-15 03:39:09,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000006 is : 143
2016-01-15 03:39:16,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0043_01_000008 is : 143
2016-01-15 03:39:17,531 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/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch/_temporary
2016-01-15 03:39:17,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:07.132, using cpu time: 00:15.670
2016-01-15 03:39:17,569 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/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch
2016-01-15 03:39:17,590 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:39:17,590 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 03:39:17,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-15 03:39:17,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:39:17,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:39:17,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:39:17,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:39:17,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:39:17,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup"]
2016-01-15 03:39:17,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:39:17,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:39:17,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:39:17,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tform/testCoGroup/cogroup
2016-01-15 03:39:18,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0044
2016-01-15 03:39:18,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0044/
2016-01-15 03:39:44,197 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000003 is : 143
2016-01-15 03:39:44,685 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000002 is : 143
2016-01-15 03:39:45,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000006 is : 143
2016-01-15 03:39:45,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000004 is : 143
2016-01-15 03:39:45,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000007 is : 143
2016-01-15 03:39:45,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000005 is : 143
2016-01-15 03:39:52,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0044_01_000008 is : 143
2016-01-15 03:39:53,614 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/cogroupfieldedpipesplatform/testCoGroup/cogroup/_temporary
2016-01-15 03:39:53,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:35.950, using cpu time: 00:10.910
2016-01-15 03:39:53,655 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/cogroupfieldedpipesplatform/testCoGroup/cogroup
2016-01-15 03:39:53,673 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:39:53,674 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 03:39:53,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-15 03:39:53,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:39:53,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:39:53,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:39:53,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:39:53,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:39:53,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown"]
2016-01-15 03:39:53,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:39:53,745 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:39:53,745 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:39:53,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...GroupWithUnknowns/unknown
2016-01-15 03:39:53,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0045
2016-01-15 03:39:53,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0045/
2016-01-15 03:40:20,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000002 is : 143
2016-01-15 03:40:21,031 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000006 is : 143
2016-01-15 03:40:21,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000003 is : 143
2016-01-15 03:40:21,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000004 is : 143
2016-01-15 03:40:21,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000007 is : 143
2016-01-15 03:40:27,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0045_01_000008 is : 143
2016-01-15 03:40:28,626 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/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown/_temporary
2016-01-15 03:40:28,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:34.880, using cpu time: 00:07.940
2016-01-15 03:40:28,668 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/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown
2016-01-15 03:40:28,689 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:40:28,689 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 03:40:28,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-15 03:40:28,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:40:28,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:40:28,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-15 03:40:28,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:40:28,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSameSourceGroupSplitCoGroup"]
2016-01-15 03:40:28,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-01-15 03:40:28,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 2
2016-01-15 03:40:28,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 2
2016-01-15 03:40:28,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/2)
2016-01-15 03:40:28,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452827744728_0046
2016-01-15 03:40:28,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0046/
2016-01-15 03:40:52,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000003 is : 143
2016-01-15 03:40:53,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000002 is : 143
2016-01-15 03:40:53,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000006 is : 143
2016-01-15 03:40:53,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000004 is : 143
2016-01-15 03:40:54,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000005 is : 143
2016-01-15 03:40:59,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0046_01_000007 is : 143
2016-01-15 03:41:00,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (2/2) ...meSourceGroupSplitCoGroup
2016-01-15 03:41:01,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452827744728_0047
2016-01-15 03:41:01,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0047/
2016-01-15 03:41:18,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0047_01_000002 is : 143
2016-01-15 03:41:25,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0047_01_000003 is : 143
2016-01-15 03:41:26,838 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/cogroupfieldedpipesplatform/testSameSourceGroupSplitCoGroup/_temporary
2016-01-15 03:41:26,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:58.074, using cpu time: 00:09.980
2016-01-15 03:41:26,887 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:41:26,887 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 03:41:26,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 03:41:26,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:41:26,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:41:26,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:41:26,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:41:26,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:41:26,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull"]
2016-01-15 03:41:26,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:41:26,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:41:26,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:41:26,935 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupouterinnernull
2016-01-15 03:41:27,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0048
2016-01-15 03:41:27,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0048/
2016-01-15 03:41:50,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000002 is : 143
2016-01-15 03:41:50,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000003 is : 143
2016-01-15 03:41:50,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000005 is : 143
2016-01-15 03:41:51,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000006 is : 143
2016-01-15 03:41:51,429 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000004 is : 143
2016-01-15 03:41:57,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0048_01_000007 is : 143
2016-01-15 03:41:58,567 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/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull/_temporary
2016-01-15 03:41:58,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:31.631, using cpu time: 00:06.680
2016-01-15 03:41:58,623 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:41:58,623 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 03:41:58,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 03:41:58,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:41:58,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:41:58,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:41:58,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:41:58,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:41:58,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup"]
2016-01-15 03:41:58,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:41:58,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:41:58,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:41:58,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterinnernull-resultgroup
2016-01-15 03:41:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0049
2016-01-15 03:41:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0049/
2016-01-15 03:42:22,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0049_01_000006 is : 143
2016-01-15 03:42:23,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0049_01_000003 is : 143
2016-01-15 03:42:23,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0049_01_000004 is : 143
2016-01-15 03:42:23,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0049_01_000005 is : 143
2016-01-15 03:42:30,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0049_01_000007 is : 143
2016-01-15 03:42:31,476 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/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup/_temporary
2016-01-15 03:42:31,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:32.804, using cpu time: 00:06.850
2016-01-15 03:42:31,519 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/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull
2016-01-15 03:42:31,523 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/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup
2016-01-15 03:42:31,542 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:42:31,542 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 03:42:31,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 03:42:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:42:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:42:31,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:42:31,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:42:31,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:42:31,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull"]
2016-01-15 03:42:31,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:42:31,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:42:31,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:42:31,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerNull/cogroupinnernull
2016-01-15 03:42:31,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0050
2016-01-15 03:42:31,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0050/
2016-01-15 03:42:54,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000003 is : 143
2016-01-15 03:42:55,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000002 is : 143
2016-01-15 03:42:55,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000006 is : 143
2016-01-15 03:42:55,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000004 is : 143
2016-01-15 03:42:55,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000005 is : 143
2016-01-15 03:43:01,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0050_01_000007 is : 143
2016-01-15 03:43:02,315 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/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull/_temporary
2016-01-15 03:43:02,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:30.723, using cpu time: 00:06.780
2016-01-15 03:43:02,371 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:43:02,371 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 03:43:02,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 03:43:02,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:43:02,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:43:02,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:43:02,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-15 03:43:02,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-15 03:43:02,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup"]
2016-01-15 03:43:02,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:43:02,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:43:02,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:43:02,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupinnernull-resultgroup
2016-01-15 03:43:02,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0051
2016-01-15 03:43:02,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0051/
2016-01-15 03:43:27,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000003 is : 143
2016-01-15 03:43:28,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000002 is : 143
2016-01-15 03:43:28,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000005 is : 143
2016-01-15 03:43:28,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000004 is : 143
2016-01-15 03:43:28,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000006 is : 143
2016-01-15 03:43:34,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0051_01_000007 is : 143
2016-01-15 03:43:35,939 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/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup/_temporary
2016-01-15 03:43:35,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.518, using cpu time: 00:07.580
2016-01-15 03:43:35,971 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/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull
2016-01-15 03:43:35,975 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/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup
2016-01-15 03:43:35,994 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:43:35,994 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 03:43:36,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 03:43:36,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:43:36,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:43:36,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:43:36,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:43:36,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:43:36,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle"]
2016-01-15 03:43:36,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:43:36,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:43:36,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:43:36,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...eField/cogroupinnersingle
2016-01-15 03:43:36,201 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0052
2016-01-15 03:43:36,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0052/
2016-01-15 03:44:01,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000003 is : 143
2016-01-15 03:44:02,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000002 is : 143
2016-01-15 03:44:02,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000007 is : 143
2016-01-15 03:44:03,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000004 is : 143
2016-01-15 03:44:03,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000005 is : 143
2016-01-15 03:44:03,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000006 is : 143
2016-01-15 03:44:08,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0052_01_000008 is : 143
2016-01-15 03:44:09,848 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/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle/_temporary
2016-01-15 03:44:09,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:33.793, using cpu time: 00:08.160
2016-01-15 03:44:09,880 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/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle
2016-01-15 03:44:09,900 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:44:09,900 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 03:44:09,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-15 03:44:09,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 03:44:09,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:44:10,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:44:10,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:44:10,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:44:10,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared"]
2016-01-15 03:44:10,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:44:10,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 03:44:10,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 03:44:10,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 03:44:10,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 03:44:10,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0054
2016-01-15 03:44:10,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0054/
2016-01-15 03:44:10,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0053
2016-01-15 03:44:10,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0053/
2016-01-15 03:44:34,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000003 is : 143
2016-01-15 03:44:35,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000005 is : 143
2016-01-15 03:44:35,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000004 is : 143
2016-01-15 03:44:35,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000002 is : 143
2016-01-15 03:44:35,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000006 is : 143
2016-01-15 03:44:42,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0053_01_000007 is : 143
2016-01-15 03:45:08,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000005 is : 143
2016-01-15 03:45:08,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000003 is : 143
2016-01-15 03:45:08,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000002 is : 143
2016-01-15 03:45:09,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000004 is : 143
2016-01-15 03:45:09,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000006 is : 143
2016-01-15 03:45:14,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0054_01_000007 is : 143
2016-01-15 03:45:15,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...ared/aftereverynodeclared
2016-01-15 03:45:16,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0055
2016-01-15 03:45:16,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0055/
2016-01-15 03:45:34,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0055_01_000003 is : 143
2016-01-15 03:45:35,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0055_01_000002 is : 143
2016-01-15 03:45:41,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0055_01_000004 is : 143
2016-01-15 03:45:42,535 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/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared/_temporary
2016-01-15 03:45:42,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:32.521, using cpu time: 00:16.990
2016-01-15 03:45:42,567 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/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared
2016-01-15 03:45:42,585 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:45:42,586 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 03:45:42,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 03:45:42,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:45:42,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:45:42,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:45:42,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:45:42,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:45:42,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself"]
2016-01-15 03:45:42,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:45:42,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 03:45:42,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 03:45:42,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stCoGroupSelf/cogroupself
2016-01-15 03:45:42,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0056
2016-01-15 03:45:42,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0056/
2016-01-15 03:46:05,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000003 is : 143
2016-01-15 03:46:06,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000002 is : 143
2016-01-15 03:46:06,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000005 is : 143
2016-01-15 03:46:06,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000004 is : 143
2016-01-15 03:46:06,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000006 is : 143
2016-01-15 03:46:11,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0056_01_000007 is : 143
2016-01-15 03:46:13,035 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/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself/_temporary
2016-01-15 03:46:13,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:30.407, using cpu time: 00:07.590
2016-01-15 03:46:13,083 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/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself
2016-01-15 03:46:13,104 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:46:13,104 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 03:46:13,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-15 03:46:13,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:46:13,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 03:46:13,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 03:46:13,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:46:13,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] 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 03:46:13,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby"]
2016-01-15 03:46:13,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 03:46:13,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2016-01-15 03:46:13,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2016-01-15 03:46:13,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-15 03:46:13,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0057
2016-01-15 03:46:13,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0057/
2016-01-15 03:46:39,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000005 is : 143
2016-01-15 03:46:39,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000007 is : 143
2016-01-15 03:46:39,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000002 is : 143
2016-01-15 03:46:40,134 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000006 is : 143
2016-01-15 03:46:40,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000004 is : 143
2016-01-15 03:46:40,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000003 is : 143
2016-01-15 03:46:46,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0057_01_000008 is : 143
2016-01-15 03:46:47,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...oupGroupBy/cogroupgroupby
2016-01-15 03:46:47,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452827744728_0058
2016-01-15 03:46:47,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:56649/proxy/application_1452827744728_0058/
2016-01-15 03:47:04,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0058_01_000002 is : 143
2016-01-15 03:47:11,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452827744728_0058_01_000003 is : 143
2016-01-15 03:47:12,534 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/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby/_temporary
2016-01-15 03:47:12,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:59.358, using cpu time: 00:10.200
2016-01-15 03:47:12,567 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/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby