2016-05-18 04:16:01,338 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 04:16:01,368 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.CoGroupFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 04:16:01,407 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 04:16:02,216 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-05-18 04:16:02,833 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 04:16:03,365 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:16:06,488 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 04:16:06,641 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 04:16:06,754 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 04:16:06,866 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 04:16:18,721 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:16:19,633 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:16:19,633 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 04:16:23,950 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 04:16:24,093 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:16:24,094 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:16:24,162 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: D0E96F92DEE9421F932F3388A618CE57
2016-05-18 04:16:24,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2016-05-18 04:16:24,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:16:24,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:16:24,470 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 04:16:24,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:16:24,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:16:24,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:16:24,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner"]
2016-05-18 04:16:24,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:16:24,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:16:24,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:16:24,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...CoGroupInner/cogroupinner
2016-05-18 04:16:25,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0001
2016-05-18 04:16:25,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0001/
2016-05-18 04:16:43,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000003 is : 143
2016-05-18 04:16:43,557 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000002 is : 143
2016-05-18 04:16:44,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000005 is : 143
2016-05-18 04:16:44,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000006 is : 143
2016-05-18 04:16:44,634 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000004 is : 143
2016-05-18 04:16:50,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0001_01_000007 is : 143
2016-05-18 04:16:51,334 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner/_temporary
2016-05-18 04:16:51,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.860, using cpu time: 00:06.880
2016-05-18 04:16:51,416 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:16:51,417 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:16:51,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-18 04:16:51,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:16:51,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:16:51,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:16:51,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:16:51,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:16:51,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup"]
2016-05-18 04:16:51,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:16:51,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:16:51,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:16:51,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) .../cogroupinner-resultgroup
2016-05-18 04:16:51,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0002
2016-05-18 04:16:51,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0002/
2016-05-18 04:17:10,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000003 is : 143
2016-05-18 04:17:10,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000002 is : 143
2016-05-18 04:17:11,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000004 is : 143
2016-05-18 04:17:11,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000005 is : 143
2016-05-18 04:17:11,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000006 is : 143
2016-05-18 04:17:16,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0002_01_000007 is : 143
2016-05-18 04:17:18,071 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup/_temporary
2016-05-18 04:17:18,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.552, using cpu time: 00:06.890
2016-05-18 04:17:18,125 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup
2016-05-18 04:17:18,131 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner
2016-05-18 04:17:18,218 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:17:18,218 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:17:18,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 04:17:18,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:17:18,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:17:18,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] starting
2016-05-18 04:17:18,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:17:18,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:17:18,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 04:17:18,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] sink: Hfs["TextDelimited[[0:5 | String, String, String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed"]
2016-05-18 04:17:18,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] parallel execution of steps is enabled: true
2016-05-18 04:17:18,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] executing total steps: 1
2016-05-18 04:17:18,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] allocating management threads: 1
2016-05-18 04:17:18,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] starting step: (1/1) ...CoGroupMixed/cogroupmixed
2016-05-18 04:17:18,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] submitted hadoop job: job_1463544978449_0003
2016-05-18 04:17:18,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0003/
2016-05-18 04:17:45,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000002 is : 143
2016-05-18 04:17:45,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000003 is : 143
2016-05-18 04:17:46,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000006 is : 143
2016-05-18 04:17:47,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000007 is : 143
2016-05-18 04:17:47,445 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000009 is : 143
2016-05-18 04:17:47,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000008 is : 143
2016-05-18 04:17:47,549 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000010 is : 143
2016-05-18 04:17:51,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0003_01_000011 is : 143
2016-05-18 04:17:52,862 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed/_temporary
2016-05-18 04:17:52,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [loweroffset*upper*lower] completed in: 00:34.523, using cpu time: 00:11.450
2016-05-18 04:17:52,905 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed
2016-05-18 04:17:52,932 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:17:52,932 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:17:52,984 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 04:17:52,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:17:52,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:17:53,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:17:53,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:17:53,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:17:53,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter"]
2016-05-18 04:17:53,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:17:53,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:17:53,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:17:53,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...CoGroupOuter/cogroupouter
2016-05-18 04:17:53,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0004
2016-05-18 04:17:53,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0004/
2016-05-18 04:18:11,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000003 is : 143
2016-05-18 04:18:11,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000002 is : 143
2016-05-18 04:18:11,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000006 is : 143
2016-05-18 04:18:11,830 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000004 is : 143
2016-05-18 04:18:11,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000005 is : 143
2016-05-18 04:18:18,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0004_01_000007 is : 143
2016-05-18 04:18:19,285 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter/_temporary
2016-05-18 04:18:19,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.270, using cpu time: 00:06.890
2016-05-18 04:18:19,345 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:18:19,345 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:18:19,393 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 04:18:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:18:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:18:19,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:18:19,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:18:19,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:18:19,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup"]
2016-05-18 04:18:19,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:18:19,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:18:19,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:18:19,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) .../cogroupouter-resultgroup
2016-05-18 04:18:19,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0005
2016-05-18 04:18:19,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0005/
2016-05-18 04:18:37,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000002 is : 143
2016-05-18 04:18:37,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000006 is : 143
2016-05-18 04:18:37,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000003 is : 143
2016-05-18 04:18:37,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000004 is : 143
2016-05-18 04:18:38,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000005 is : 143
2016-05-18 04:18:44,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0005_01_000007 is : 143
2016-05-18 04:18:45,475 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup/_temporary
2016-05-18 04:18:45,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.058, using cpu time: 00:06.650
2016-05-18 04:18:45,523 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter
2016-05-18 04:18:45,528 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup
2016-05-18 04:18:45,580 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:18:45,580 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:18:45,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-18 04:18:45,656 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:18:45,656 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:18:45,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting
2016-05-18 04:18:45,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.10.txt"]
2016-05-18 04:18:45,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.10.txt"]
2016-05-18 04:18:45,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 04:18:45,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2"]
2016-05-18 04:18:45,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] parallel execution of steps is enabled: true
2016-05-18 04:18:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] executing total steps: 2
2016-05-18 04:18:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] allocating management threads: 2
2016-05-18 04:18:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting step: (1/2)
2016-05-18 04:18:45,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] submitted hadoop job: job_1463544978449_0006
2016-05-18 04:18:45,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0006/
2016-05-18 04:19:02,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000003 is : 143
2016-05-18 04:19:03,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000002 is : 143
2016-05-18 04:19:04,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000006 is : 143
2016-05-18 04:19:04,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000004 is : 143
2016-05-18 04:19:04,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000005 is : 143
2016-05-18 04:19:09,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0006_01_000007 is : 143
2016-05-18 04:19:10,938 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting step: (2/2) ...pWith/cogroupacogroupopt2
2016-05-18 04:19:11,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] submitted hadoop job: job_1463544978449_0007
2016-05-18 04:19:11,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0007/
2016-05-18 04:19:29,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000006 is : 143
2016-05-18 04:19:29,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000002 is : 143
2016-05-18 04:19:29,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000005 is : 143
2016-05-18 04:19:29,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000004 is : 143
2016-05-18 04:19:29,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000003 is : 143
2016-05-18 04:19:35,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0007_01_000007 is : 143
2016-05-18 04:19:36,787 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2/_temporary
2016-05-18 04:19:36,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] completed in: 00:51.094, using cpu time: 00:13.000
2016-05-18 04:19:36,836 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2
2016-05-18 04:19:36,857 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:19:36,857 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:19:36,928 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-05-18 04:19:36,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:19:36,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:19:36,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting
2016-05-18 04:19:36,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.10.txt"]
2016-05-18 04:19:36,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.10.txt"]
2016-05-18 04:19:36,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 04:19:36,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1"]
2016-05-18 04:19:36,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] parallel execution of steps is enabled: true
2016-05-18 04:19:36,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] executing total steps: 2
2016-05-18 04:19:36,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] allocating management threads: 2
2016-05-18 04:19:36,965 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting step: (1/2)
2016-05-18 04:19:37,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] submitted hadoop job: job_1463544978449_0008
2016-05-18 04:19:37,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0008/
2016-05-18 04:19:54,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000002 is : 143
2016-05-18 04:19:54,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000003 is : 143
2016-05-18 04:19:55,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000004 is : 143
2016-05-18 04:19:55,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000005 is : 143
2016-05-18 04:19:55,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000006 is : 143
2016-05-18 04:20:01,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0008_01_000007 is : 143
2016-05-18 04:20:02,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] starting step: (2/2) ...thout/cogroupacogroupopt1
2016-05-18 04:20:02,651 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] submitted hadoop job: job_1463544978449_0009
2016-05-18 04:20:02,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0009/
2016-05-18 04:20:20,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000006 is : 143
2016-05-18 04:20:20,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000003 is : 143
2016-05-18 04:20:20,905 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000005 is : 143
2016-05-18 04:20:21,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000004 is : 143
2016-05-18 04:20:21,321 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000002 is : 143
2016-05-18 04:20:27,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0009_01_000007 is : 143
2016-05-18 04:20:28,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1/_temporary
2016-05-18 04:20:28,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroupopt] completed in: 00:51.662, using cpu time: 00:13.340
2016-05-18 04:20:28,662 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1
2016-05-18 04:20:28,683 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:20:28,683 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:20:28,764 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2016-05-18 04:20:28,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:20:28,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:20:28,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 04:20:28,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:20:28,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:20:28,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:20:28,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup"]
2016-05-18 04:20:28,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-05-18 04:20:28,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executing total steps: 2
2016-05-18 04:20:28,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] allocating management threads: 2
2016-05-18 04:20:28,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/2)
2016-05-18 04:20:28,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463544978449_0010
2016-05-18 04:20:28,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0010/
2016-05-18 04:20:49,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000007 is : 143
2016-05-18 04:20:49,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000003 is : 143
2016-05-18 04:20:49,639 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000006 is : 143
2016-05-18 04:20:49,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000004 is : 143
2016-05-18 04:20:49,963 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000005 is : 143
2016-05-18 04:20:50,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000002 is : 143
2016-05-18 04:20:55,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0010_01_000008 is : 143
2016-05-18 04:20:57,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (2/2) ...ndCoGroup/cogroupacogroup
2016-05-18 04:20:57,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463544978449_0011
2016-05-18 04:20:57,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0011/
2016-05-18 04:21:16,859 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000007 is : 143
2016-05-18 04:21:17,448 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000006 is : 143
2016-05-18 04:21:17,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000005 is : 143
2016-05-18 04:21:18,081 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000004 is : 143
2016-05-18 04:21:18,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000002 is : 143
2016-05-18 04:21:18,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000003 is : 143
2016-05-18 04:21:23,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0011_01_000008 is : 143
2016-05-18 04:21:25,035 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup/_temporary
2016-05-18 04:21:25,037 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] completed in: 00:56.228, using cpu time: 00:15.650
2016-05-18 04:21:25,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup
2016-05-18 04:21:25,088 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:21:25,088 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:21:25,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:21:25,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:21:25,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:21:25,146 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:21:25,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:21:25,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:21:25,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter"]
2016-05-18 04:21:25,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:21:25,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:21:25,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:21:25,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...erOuter/cogroupinnerouter
2016-05-18 04:21:25,284 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0012
2016-05-18 04:21:25,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0012/
2016-05-18 04:21:42,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000003 is : 143
2016-05-18 04:21:43,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000002 is : 143
2016-05-18 04:21:43,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000004 is : 143
2016-05-18 04:21:43,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000006 is : 143
2016-05-18 04:21:43,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000005 is : 143
2016-05-18 04:21:48,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0012_01_000007 is : 143
2016-05-18 04:21:50,105 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter/_temporary
2016-05-18 04:21:50,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:24.957, using cpu time: 00:06.960
2016-05-18 04:21:50,153 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:21:50,154 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:21:50,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:21:50,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:21:50,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:21:50,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:21:50,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:21:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:21:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup"]
2016-05-18 04:21:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:21:50,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:21:50,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:21:50,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...oupinnerouter-resultgroup
2016-05-18 04:21:50,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0013
2016-05-18 04:21:50,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0013/
2016-05-18 04:22:08,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000002 is : 143
2016-05-18 04:22:08,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000006 is : 143
2016-05-18 04:22:08,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000003 is : 143
2016-05-18 04:22:08,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000005 is : 143
2016-05-18 04:22:08,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000004 is : 143
2016-05-18 04:22:15,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0013_01_000007 is : 143
2016-05-18 04:22:16,386 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup/_temporary
2016-05-18 04:22:16,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.170, using cpu time: 00:07.130
2016-05-18 04:22:16,420 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter
2016-05-18 04:22:16,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup
2016-05-18 04:22:16,444 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:22:16,444 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:22:16,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-05-18 04:22:16,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:22:16,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:22:16,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:22:16,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:22:16,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:22:16,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields"]
2016-05-18 04:22:16,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:22:16,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:22:16,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:22:16,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...roupDiffFields/difffields
2016-05-18 04:22:16,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0014
2016-05-18 04:22:16,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0014/
2016-05-18 04:22:36,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000002 is : 143
2016-05-18 04:22:36,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000003 is : 143
2016-05-18 04:22:37,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000006 is : 143
2016-05-18 04:22:37,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000004 is : 143
2016-05-18 04:22:37,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000005 is : 143
2016-05-18 04:22:37,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000007 is : 143
2016-05-18 04:22:42,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0014_01_000008 is : 143
2016-05-18 04:22:43,664 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields/_temporary
2016-05-18 04:22:43,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.135, using cpu time: 00:08.000
2016-05-18 04:22:43,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields
2016-05-18 04:22:43,715 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:22:43,715 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:22:43,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 04:22:43,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:22:43,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:22:43,767 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 04:22:43,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:22:43,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2"]
2016-05-18 04:22:43,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 04:22:43,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 04:22:43,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 04:22:43,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...oGroupSamePipe2/samepipe2
2016-05-18 04:22:43,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463544978449_0015
2016-05-18 04:22:43,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0015/
2016-05-18 04:23:01,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0015_01_000005 is : 143
2016-05-18 04:23:02,232 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0015_01_000006 is : 143
2016-05-18 04:23:02,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0015_01_000002 is : 143
2016-05-18 04:23:02,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0015_01_000003 is : 143
2016-05-18 04:23:08,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0015_01_000007 is : 143
2016-05-18 04:23:09,617 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2/_temporary
2016-05-18 04:23:09,618 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:25.848, using cpu time: 00:06.620
2016-05-18 04:23:09,650 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2
2016-05-18 04:23:09,668 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:23:09,669 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:23:09,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 04:23:09,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:23:09,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:23:09,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting
2016-05-18 04:23:09,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:23:09,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3"]
2016-05-18 04:23:09,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] parallel execution of steps is enabled: true
2016-05-18 04:23:09,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executing total steps: 1
2016-05-18 04:23:09,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] allocating management threads: 1
2016-05-18 04:23:09,713 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting step: (1/1) ...oGroupSamePipe3/samepipe3
2016-05-18 04:23:09,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] submitted hadoop job: job_1463544978449_0016
2016-05-18 04:23:09,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0016/
2016-05-18 04:23:27,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000003 is : 143
2016-05-18 04:23:27,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000006 is : 143
2016-05-18 04:23:27,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000005 is : 143
2016-05-18 04:23:27,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000004 is : 143
2016-05-18 04:23:28,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000002 is : 143
2016-05-18 04:23:34,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0016_01_000007 is : 143
2016-05-18 04:23:35,605 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3/_temporary
2016-05-18 04:23:35,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] completed in: 00:25.892, using cpu time: 00:06.530
2016-05-18 04:23:35,649 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3
2016-05-18 04:23:35,702 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:23:35,702 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:23:35,740 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 04:23:35,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:23:35,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:23:35,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 04:23:35,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 04:23:35,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 04:23:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross"]
2016-05-18 04:23:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-18 04:23:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 1
2016-05-18 04:23:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 1
2016-05-18 04:23:35,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-05-18 04:23:35,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463544978449_0017
2016-05-18 04:23:35,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0017/
2016-05-18 04:23:53,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000006 is : 143
2016-05-18 04:23:54,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000002 is : 143
2016-05-18 04:23:54,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000005 is : 143
2016-05-18 04:23:54,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000003 is : 143
2016-05-18 04:23:54,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000004 is : 143
2016-05-18 04:24:00,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0017_01_000007 is : 143
2016-05-18 04:24:01,852 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross/_temporary
2016-05-18 04:24:01,854 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:26.090, using cpu time: 00:06.890
2016-05-18 04:24:01,885 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross
2016-05-18 04:24:01,912 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:24:01,912 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:24:01,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:24:01,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:24:01,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:24:01,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 04:24:01,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:24:01,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe"]
2016-05-18 04:24:01,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 04:24:01,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 04:24:01,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 04:24:01,969 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...tCoGroupSamePipe/samepipe
2016-05-18 04:24:02,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463544978449_0018
2016-05-18 04:24:02,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0018/
2016-05-18 04:24:19,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000006 is : 143
2016-05-18 04:24:20,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000003 is : 143
2016-05-18 04:24:20,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000005 is : 143
2016-05-18 04:24:20,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000002 is : 143
2016-05-18 04:24:20,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000004 is : 143
2016-05-18 04:24:25,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0018_01_000007 is : 143
2016-05-18 04:24:27,131 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe/_temporary
2016-05-18 04:24:27,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:25.162, using cpu time: 00:06.760
2016-05-18 04:24:27,163 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe
2016-05-18 04:24:27,181 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:24:27,181 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:24:27,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 04:24:27,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:24:27,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:24:27,237 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:24:27,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:24:27,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:24:27,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone"]
2016-05-18 04:24:27,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:24:27,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:24:27,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:24:27,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-05-18 04:24:27,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0019
2016-05-18 04:24:27,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0019/
2016-05-18 04:24:47,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000003 is : 143
2016-05-18 04:24:47,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000002 is : 143
2016-05-18 04:24:48,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000004 is : 143
2016-05-18 04:24:48,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000006 is : 143
2016-05-18 04:24:48,241 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000007 is : 143
2016-05-18 04:24:48,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000005 is : 143
2016-05-18 04:24:53,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0019_01_000008 is : 143
2016-05-18 04:24:54,322 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-05-18 04:24:54,324 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.084, using cpu time: 00:07.930
2016-05-18 04:24:54,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone
2016-05-18 04:24:54,374 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:24:54,375 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:24:54,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.096
2016-05-18 04:24:54,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 04:24:54,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:24:54,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:24:54,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:24:54,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:24:54,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery"]
2016-05-18 04:24:54,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:24:54,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 04:24:54,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 04:24:54,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 04:24:54,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 04:24:54,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0020
2016-05-18 04:24:54,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0020/
2016-05-18 04:24:54,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0021
2016-05-18 04:24:54,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0021/
2016-05-18 04:25:15,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000006 is : 143
2016-05-18 04:25:16,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000004 is : 143
2016-05-18 04:25:16,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000002 is : 143
2016-05-18 04:25:16,719 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000005 is : 143
2016-05-18 04:25:16,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000003 is : 143
2016-05-18 04:25:30,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000004 is : 143
2016-05-18 04:25:30,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000003 is : 143
2016-05-18 04:25:30,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000006 is : 143
2016-05-18 04:25:31,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000005 is : 143
2016-05-18 04:25:31,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000002 is : 143
2016-05-18 04:25:32,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0020_01_000007 is : 143
2016-05-18 04:25:37,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0021_01_000007 is : 143
2016-05-18 04:25:38,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...roupAfterEvery/afterevery
2016-05-18 04:25:38,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0022
2016-05-18 04:25:38,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0022/
2016-05-18 04:25:50,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0022_01_000002 is : 143
2016-05-18 04:25:50,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0022_01_000003 is : 143
2016-05-18 04:25:57,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0022_01_000004 is : 143
2016-05-18 04:25:58,790 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery/_temporary
2016-05-18 04:25:58,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:04.249, using cpu time: 00:16.930
2016-05-18 04:25:58,828 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery
2016-05-18 04:25:58,864 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:25:58,865 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:25:59,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.144
2016-05-18 04:25:59,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 10
2016-05-18 04:25:59,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:25:59,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting
2016-05-18 04:25:59,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-05-18 04:25:59,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-05-18 04:25:59,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer"]
2016-05-18 04:25:59,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner"]
2016-05-18 04:25:59,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left"]
2016-05-18 04:25:59,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right"]
2016-05-18 04:25:59,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] parallel execution of steps is enabled: true
2016-05-18 04:25:59,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] executing total steps: 5
2016-05-18 04:25:59,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] allocating management threads: 5
2016-05-18 04:25:59,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (1/5)
2016-05-18 04:25:59,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0023
2016-05-18 04:25:59,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0023/
2016-05-18 04:26:15,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0023_01_000005 is : 143
2016-05-18 04:26:15,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0023_01_000003 is : 143
2016-05-18 04:26:15,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0023_01_000004 is : 143
2016-05-18 04:26:15,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0023_01_000002 is : 143
2016-05-18 04:26:21,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0023_01_000006 is : 143
2016-05-18 04:26:22,928 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (2/5) ...tform/testMultiJoin/right
2016-05-18 04:26:22,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (3/5) ...tform/testMultiJoin/outer
2016-05-18 04:26:22,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (4/5) ...atform/testMultiJoin/left
2016-05-18 04:26:22,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (5/5) ...tform/testMultiJoin/inner
2016-05-18 04:26:23,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0024
2016-05-18 04:26:23,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0024/
2016-05-18 04:26:23,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0025
2016-05-18 04:26:23,249 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0025/
2016-05-18 04:26:23,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0026
2016-05-18 04:26:23,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0026/
2016-05-18 04:26:23,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0027
2016-05-18 04:26:23,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0027/
2016-05-18 04:26:43,318 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000002 is : 143
2016-05-18 04:26:43,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000003 is : 143
2016-05-18 04:26:43,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000004 is : 143
2016-05-18 04:26:43,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000005 is : 143
2016-05-18 04:26:44,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000006 is : 143
2016-05-18 04:26:54,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0024_01_000007 is : 143
2016-05-18 04:27:01,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000004 is : 143
2016-05-18 04:27:01,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000003 is : 143
2016-05-18 04:27:02,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000005 is : 143
2016-05-18 04:27:02,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000007 is : 143
2016-05-18 04:27:02,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000006 is : 143
2016-05-18 04:27:09,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0025_01_000008 is : 143
2016-05-18 04:27:23,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000005 is : 143
2016-05-18 04:27:24,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000004 is : 143
2016-05-18 04:27:24,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000003 is : 143
2016-05-18 04:27:24,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000006 is : 143
2016-05-18 04:27:24,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000002 is : 143
2016-05-18 04:27:31,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0026_01_000007 is : 143
2016-05-18 04:27:41,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000002 is : 143
2016-05-18 04:27:42,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000003 is : 143
2016-05-18 04:27:42,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000004 is : 143
2016-05-18 04:27:43,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000005 is : 143
2016-05-18 04:27:43,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000006 is : 143
2016-05-18 04:27:48,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0027_01_000007 is : 143
2016-05-18 04:27:49,804 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right/_temporary
2016-05-18 04:27:49,806 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer/_temporary
2016-05-18 04:27:49,807 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left/_temporary
2016-05-18 04:27:49,808 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner/_temporary
2016-05-18 04:27:49,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] completed in: 01:50.685, using cpu time: 00:34.380
2016-05-18 04:27:49,872 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right
2016-05-18 04:27:49,876 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner
2016-05-18 04:27:49,880 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left
2016-05-18 04:27:49,884 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer
2016-05-18 04:27:49,915 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:27:49,915 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:27:49,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 04:27:49,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:27:49,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:27:49,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] starting
2016-05-18 04:27:49,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:27:49,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:27:49,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields"]
2016-05-18 04:27:49,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] parallel execution of steps is enabled: true
2016-05-18 04:27:49,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] executing total steps: 1
2016-05-18 04:27:49,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] allocating management threads: 1
2016-05-18 04:27:49,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] starting step: (1/1) ...meFile/samefiledifffields
2016-05-18 04:27:50,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] submitted hadoop job: job_1463544978449_0028
2016-05-18 04:27:50,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0028/
2016-05-18 04:28:10,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000006 is : 143
2016-05-18 04:28:10,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000007 is : 143
2016-05-18 04:28:10,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000005 is : 143
2016-05-18 04:28:11,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000004 is : 143
2016-05-18 04:28:11,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000002 is : 143
2016-05-18 04:28:11,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000003 is : 143
2016-05-18 04:28:17,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0028_01_000008 is : 143
2016-05-18 04:28:18,843 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields/_temporary
2016-05-18 04:28:18,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offsetLower*lower] completed in: 00:28.868, using cpu time: 00:07.730
2016-05-18 04:28:18,874 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields
2016-05-18 04:28:18,893 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:28:18,893 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:28:18,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 04:28:18,931 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:28:18,931 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:28:18,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:28:18,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:28:18,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:28:18,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner"]
2016-05-18 04:28:18,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:28:18,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:28:18,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:28:18,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...erInner/cogroupouterinner
2016-05-18 04:28:19,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0029
2016-05-18 04:28:19,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0029/
2016-05-18 04:28:37,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000003 is : 143
2016-05-18 04:28:37,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000006 is : 143
2016-05-18 04:28:37,430 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000005 is : 143
2016-05-18 04:28:37,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000002 is : 143
2016-05-18 04:28:37,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000004 is : 143
2016-05-18 04:28:43,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0029_01_000007 is : 143
2016-05-18 04:28:44,814 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner/_temporary
2016-05-18 04:28:44,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.866, using cpu time: 00:06.920
2016-05-18 04:28:44,868 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:28:44,869 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:28:44,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 04:28:44,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:28:44,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:28:44,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:28:44,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:28:44,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:28:44,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup"]
2016-05-18 04:28:44,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:28:44,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:28:44,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:28:44,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...oupouterinner-resultgroup
2016-05-18 04:28:45,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0030
2016-05-18 04:28:45,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0030/
2016-05-18 04:29:03,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0030_01_000002 is : 143
2016-05-18 04:29:04,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0030_01_000006 is : 143
2016-05-18 04:29:04,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0030_01_000005 is : 143
2016-05-18 04:29:09,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0030_01_000007 is : 143
2016-05-18 04:29:10,275 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup/_temporary
2016-05-18 04:29:10,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.355, using cpu time: 00:07.050
2016-05-18 04:29:10,307 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup
2016-05-18 04:29:10,312 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner
2016-05-18 04:29:10,334 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:29:10,334 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:29:10,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.112
2016-05-18 04:29:10,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 8
2016-05-18 04:29:10,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:29:10,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting
2016-05-18 04:29:10,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2016-05-18 04:29:10,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs"]
2016-05-18 04:29:10,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs"]
2016-05-18 04:29:10,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs"]
2016-05-18 04:29:10,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs"]
2016-05-18 04:29:10,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] parallel execution of steps is enabled: true
2016-05-18 04:29:10,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] executing total steps: 4
2016-05-18 04:29:10,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] allocating management threads: 4
2016-05-18 04:29:10,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (1/4) ...JoinWithSplits/uniquesRhs
2016-05-18 04:29:10,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (2/4) ...tiJoinWithSplits/innerRhs
2016-05-18 04:29:10,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (4/4) ...JoinWithSplits/uniquesLhs
2016-05-18 04:29:10,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] starting step: (3/4) ...tiJoinWithSplits/innerLhs
2016-05-18 04:29:10,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0031
2016-05-18 04:29:10,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0031/
2016-05-18 04:29:10,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0032
2016-05-18 04:29:10,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0032/
2016-05-18 04:29:10,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0033
2016-05-18 04:29:10,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0033/
2016-05-18 04:29:10,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] submitted hadoop job: job_1463544978449_0034
2016-05-18 04:29:10,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0034/
2016-05-18 04:29:30,091 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0031_01_000002 is : 143
2016-05-18 04:29:30,722 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0031_01_000005 is : 143
2016-05-18 04:29:30,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0031_01_000004 is : 143
2016-05-18 04:29:42,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0032_01_000005 is : 143
2016-05-18 04:29:42,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0032_01_000004 is : 143
2016-05-18 04:29:43,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0032_01_000003 is : 143
2016-05-18 04:29:43,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0032_01_000002 is : 143
2016-05-18 04:29:44,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0031_01_000006 is : 143
2016-05-18 04:29:49,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0032_01_000006 is : 143
2016-05-18 04:30:10,584 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0033_01_000003 is : 143
2016-05-18 04:30:10,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0033_01_000002 is : 143
2016-05-18 04:30:10,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0033_01_000004 is : 143
2016-05-18 04:30:10,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0033_01_000005 is : 143
2016-05-18 04:30:23,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0034_01_000003 is : 143
2016-05-18 04:30:23,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0034_01_000005 is : 143
2016-05-18 04:30:23,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0034_01_000004 is : 143
2016-05-18 04:30:23,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0034_01_000002 is : 143
2016-05-18 04:30:25,498 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0033_01_000006 is : 143
2016-05-18 04:30:29,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0034_01_000006 is : 143
2016-05-18 04:30:31,085 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs/_temporary
2016-05-18 04:30:31,090 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs/_temporary
2016-05-18 04:30:31,091 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs/_temporary
2016-05-18 04:30:31,093 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs/_temporary
2016-05-18 04:30:31,095 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-joins] completed in: 01:20.571, using cpu time: 00:24.420
2016-05-18 04:30:31,256 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs
2016-05-18 04:30:31,260 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs
2016-05-18 04:30:31,263 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs
2016-05-18 04:30:31,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs
2016-05-18 04:30:31,285 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:30:31,286 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:30:31,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 04:30:31,320 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:30:31,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:30:31,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:30:31,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:30:31,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:30:31,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull"]
2016-05-18 04:30:31,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:30:31,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:30:31,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:30:31,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ull/cogroupinnerouternull
2016-05-18 04:30:31,478 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0035
2016-05-18 04:30:31,478 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0035/
2016-05-18 04:30:50,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000005 is : 143
2016-05-18 04:30:51,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000004 is : 143
2016-05-18 04:30:51,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000003 is : 143
2016-05-18 04:30:51,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000002 is : 143
2016-05-18 04:30:51,740 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000006 is : 143
2016-05-18 04:30:57,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0035_01_000007 is : 143
2016-05-18 04:30:58,739 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull/_temporary
2016-05-18 04:30:58,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.399, using cpu time: 00:06.910
2016-05-18 04:30:58,794 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:30:58,795 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:30:58,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 04:30:58,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:30:58,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:30:58,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:30:58,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:30:58,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:30:58,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup"]
2016-05-18 04:30:58,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:30:58,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:30:58,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:30:58,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...nnerouternull-resultgroup
2016-05-18 04:30:58,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0036
2016-05-18 04:30:58,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0036/
2016-05-18 04:31:17,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000006 is : 143
2016-05-18 04:31:17,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000003 is : 143
2016-05-18 04:31:17,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000005 is : 143
2016-05-18 04:31:17,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000004 is : 143
2016-05-18 04:31:17,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000002 is : 143
2016-05-18 04:31:23,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0036_01_000007 is : 143
2016-05-18 04:31:25,114 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup/_temporary
2016-05-18 04:31:25,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.271, using cpu time: 00:06.860
2016-05-18 04:31:25,146 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup
2016-05-18 04:31:25,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull
2016-05-18 04:31:25,167 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:31:25,167 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:31:25,207 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 04:31:25,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:31:25,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:31:25,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:31:25,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:31:25,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:31:25,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull"]
2016-05-18 04:31:25,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:31:25,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:31:25,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:31:25,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...uterNull/cogroupouternull
2016-05-18 04:31:25,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0037
2016-05-18 04:31:25,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0037/
2016-05-18 04:31:43,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000002 is : 143
2016-05-18 04:31:43,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000004 is : 143
2016-05-18 04:31:43,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000003 is : 143
2016-05-18 04:31:43,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000006 is : 143
2016-05-18 04:31:43,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000005 is : 143
2016-05-18 04:31:49,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0037_01_000007 is : 143
2016-05-18 04:31:51,103 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull/_temporary
2016-05-18 04:31:51,105 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.876, using cpu time: 00:06.840
2016-05-18 04:31:51,156 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:31:51,156 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:31:51,189 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 04:31:51,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:31:51,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:31:51,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:31:51,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:31:51,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:31:51,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup"]
2016-05-18 04:31:51,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:31:51,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:31:51,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:31:51,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...roupouternull-resultgroup
2016-05-18 04:31:51,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0038
2016-05-18 04:31:51,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0038/
2016-05-18 04:32:09,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000002 is : 143
2016-05-18 04:32:09,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000003 is : 143
2016-05-18 04:32:10,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000006 is : 143
2016-05-18 04:32:10,141 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000004 is : 143
2016-05-18 04:32:10,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000005 is : 143
2016-05-18 04:32:15,351 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0038_01_000007 is : 143
2016-05-18 04:32:16,550 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup/_temporary
2016-05-18 04:32:16,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.346, using cpu time: 00:06.930
2016-05-18 04:32:16,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup
2016-05-18 04:32:16,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull
2016-05-18 04:32:16,615 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:32:16,616 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:32:16,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 04:32:16,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:32:16,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:32:16,687 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-18 04:32:16,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:32:16,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:32:16,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:32:16,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:32:16,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs"]
2016-05-18 04:32:16,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs"]
2016-05-18 04:32:16,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] parallel execution of steps is enabled: true
2016-05-18 04:32:16,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executing total steps: 2
2016-05-18 04:32:16,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] allocating management threads: 2
2016-05-18 04:32:16,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/2) ...Self/splitcogroupself/rhs
2016-05-18 04:32:16,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (2/2) ...Self/splitcogroupself/lhs
2016-05-18 04:32:16,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463544978449_0039
2016-05-18 04:32:16,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0039/
2016-05-18 04:32:16,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463544978449_0040
2016-05-18 04:32:16,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0040/
2016-05-18 04:32:38,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000003 is : 143
2016-05-18 04:32:38,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000004 is : 143
2016-05-18 04:32:38,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000002 is : 143
2016-05-18 04:32:38,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000005 is : 143
2016-05-18 04:32:39,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000006 is : 143
2016-05-18 04:32:53,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000002 is : 143
2016-05-18 04:32:54,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000005 is : 143
2016-05-18 04:32:54,686 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000006 is : 143
2016-05-18 04:32:54,752 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000004 is : 143
2016-05-18 04:32:54,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000003 is : 143
2016-05-18 04:32:56,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0039_01_000007 is : 143
2016-05-18 04:33:00,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0040_01_000007 is : 143
2016-05-18 04:33:01,400 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs/_temporary
2016-05-18 04:33:01,401 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs/_temporary
2016-05-18 04:33:01,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] completed in: 00:44.711, using cpu time: 00:13.520
2016-05-18 04:33:01,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs
2016-05-18 04:33:01,437 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs
2016-05-18 04:33:01,454 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:33:01,454 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:33:01,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:33:01,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:33:01,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:33:01,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting
2016-05-18 04:33:01,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:33:01,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:33:01,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes"]
2016-05-18 04:33:01,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] parallel execution of steps is enabled: true
2016-05-18 04:33:01,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executing total steps: 1
2016-05-18 04:33:01,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] allocating management threads: 1
2016-05-18 04:33:01,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-05-18 04:33:01,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] submitted hadoop job: job_1463544978449_0041
2016-05-18 04:33:01,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0041/
2016-05-18 04:33:23,790 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000005 is : 143
2016-05-18 04:33:23,812 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000006 is : 143
2016-05-18 04:33:24,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000007 is : 143
2016-05-18 04:33:24,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000002 is : 143
2016-05-18 04:33:24,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000004 is : 143
2016-05-18 04:33:24,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000003 is : 143
2016-05-18 04:33:31,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0041_01_000008 is : 143
2016-05-18 04:33:32,246 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes/_temporary
2016-05-18 04:33:32,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] completed in: 00:30.726, using cpu time: 00:07.830
2016-05-18 04:33:32,276 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes
2016-05-18 04:33:32,295 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:33:32,295 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:33:32,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-18 04:33:32,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:33:32,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:33:32,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:33:32,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:33:32,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:33:32,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch"]
2016-05-18 04:33:32,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:33:32,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 2
2016-05-18 04:33:32,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 2
2016-05-18 04:33:32,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 04:33:32,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0042
2016-05-18 04:33:32,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0042/
2016-05-18 04:33:50,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000002 is : 143
2016-05-18 04:33:50,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000005 is : 143
2016-05-18 04:33:50,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000003 is : 143
2016-05-18 04:33:51,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000006 is : 143
2016-05-18 04:33:51,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000004 is : 143
2016-05-18 04:33:57,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0042_01_000007 is : 143
2016-05-18 04:33:58,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...nch/cogroupfilteredbranch
2016-05-18 04:33:58,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0043
2016-05-18 04:33:58,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0043/
2016-05-18 04:34:18,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000003 is : 143
2016-05-18 04:34:19,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000006 is : 143
2016-05-18 04:34:19,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000002 is : 143
2016-05-18 04:34:19,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000004 is : 143
2016-05-18 04:34:19,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000005 is : 143
2016-05-18 04:34:19,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000007 is : 143
2016-05-18 04:34:25,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0043_01_000008 is : 143
2016-05-18 04:34:26,682 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch/_temporary
2016-05-18 04:34:26,688 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:54.284, using cpu time: 00:14.540
2016-05-18 04:34:26,732 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch
2016-05-18 04:34:26,751 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:34:26,751 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:34:26,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 04:34:26,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:34:26,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:34:26,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:34:26,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:34:26,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:34:26,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup"]
2016-05-18 04:34:26,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:34:26,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:34:26,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:34:26,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...tform/testCoGroup/cogroup
2016-05-18 04:34:26,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0044
2016-05-18 04:34:26,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0044/
2016-05-18 04:34:47,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000002 is : 143
2016-05-18 04:34:47,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000003 is : 143
2016-05-18 04:34:47,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000004 is : 143
2016-05-18 04:34:47,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000005 is : 143
2016-05-18 04:34:48,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000007 is : 143
2016-05-18 04:34:48,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000006 is : 143
2016-05-18 04:34:53,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0044_01_000008 is : 143
2016-05-18 04:34:55,013 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup/_temporary
2016-05-18 04:34:55,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:28.216, using cpu time: 00:08.390
2016-05-18 04:34:55,044 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup
2016-05-18 04:34:55,062 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:34:55,062 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:34:55,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 04:34:55,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:34:55,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown"]
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:34:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:34:55,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:34:55,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...GroupWithUnknowns/unknown
2016-05-18 04:34:55,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0045
2016-05-18 04:34:55,243 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0045/
2016-05-18 04:35:15,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000002 is : 143
2016-05-18 04:35:15,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000003 is : 143
2016-05-18 04:35:15,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000004 is : 143
2016-05-18 04:35:16,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000007 is : 143
2016-05-18 04:35:16,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000005 is : 143
2016-05-18 04:35:16,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000006 is : 143
2016-05-18 04:35:21,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0045_01_000008 is : 143
2016-05-18 04:35:23,173 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown/_temporary
2016-05-18 04:35:23,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:28.066, using cpu time: 00:07.770
2016-05-18 04:35:23,204 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown
2016-05-18 04:35:23,222 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:35:23,222 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:35:23,268 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-18 04:35:23,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:35:23,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:35:23,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 04:35:23,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:35:23,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSameSourceGroupSplitCoGroup"]
2016-05-18 04:35:23,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-18 04:35:23,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 2
2016-05-18 04:35:23,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 2
2016-05-18 04:35:23,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/2)
2016-05-18 04:35:23,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463544978449_0046
2016-05-18 04:35:23,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0046/
2016-05-18 04:35:41,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000003 is : 143
2016-05-18 04:35:41,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000002 is : 143
2016-05-18 04:35:41,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000005 is : 143
2016-05-18 04:35:41,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000006 is : 143
2016-05-18 04:35:41,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000004 is : 143
2016-05-18 04:35:48,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0046_01_000007 is : 143
2016-05-18 04:35:49,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (2/2) ...meSourceGroupSplitCoGroup
2016-05-18 04:35:49,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463544978449_0047
2016-05-18 04:35:49,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0047/
2016-05-18 04:35:59,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0047_01_000002 is : 143
2016-05-18 04:36:06,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0047_01_000003 is : 143
2016-05-18 04:36:07,355 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSameSourceGroupSplitCoGroup/_temporary
2016-05-18 04:36:07,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:44.056, using cpu time: 00:08.680
2016-05-18 04:36:07,401 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:36:07,402 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:36:07,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 04:36:07,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:36:07,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:36:07,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:36:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:36:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:36:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull"]
2016-05-18 04:36:07,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:36:07,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:36:07,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:36:07,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ull/cogroupouterinnernull
2016-05-18 04:36:07,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0048
2016-05-18 04:36:07,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0048/
2016-05-18 04:36:25,857 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000006 is : 143
2016-05-18 04:36:26,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000003 is : 143
2016-05-18 04:36:26,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000002 is : 143
2016-05-18 04:36:26,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000005 is : 143
2016-05-18 04:36:26,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000004 is : 143
2016-05-18 04:36:32,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0048_01_000007 is : 143
2016-05-18 04:36:33,783 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull/_temporary
2016-05-18 04:36:33,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.327, using cpu time: 00:06.550
2016-05-18 04:36:33,836 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:36:33,837 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:36:33,865 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 04:36:33,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:36:33,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:36:33,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:36:33,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:36:33,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:36:33,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup"]
2016-05-18 04:36:33,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:36:33,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:36:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:36:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...uterinnernull-resultgroup
2016-05-18 04:36:34,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0049
2016-05-18 04:36:34,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0049/
2016-05-18 04:36:51,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000003 is : 143
2016-05-18 04:36:52,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000006 is : 143
2016-05-18 04:36:52,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000004 is : 143
2016-05-18 04:36:52,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000005 is : 143
2016-05-18 04:36:52,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000002 is : 143
2016-05-18 04:36:58,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0049_01_000007 is : 143
2016-05-18 04:36:59,774 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup/_temporary
2016-05-18 04:36:59,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.888, using cpu time: 00:06.910
2016-05-18 04:36:59,805 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup
2016-05-18 04:36:59,809 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull
2016-05-18 04:36:59,826 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:36:59,826 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:36:59,854 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 04:36:59,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:36:59,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:36:59,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:36:59,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:36:59,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:36:59,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull"]
2016-05-18 04:36:59,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:36:59,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:36:59,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:36:59,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...nnerNull/cogroupinnernull
2016-05-18 04:37:00,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0050
2016-05-18 04:37:00,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0050/
2016-05-18 04:37:18,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0050_01_000003 is : 143
2016-05-18 04:37:18,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0050_01_000006 is : 143
2016-05-18 04:37:18,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0050_01_000004 is : 143
2016-05-18 04:37:18,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0050_01_000005 is : 143
2016-05-18 04:37:24,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0050_01_000007 is : 143
2016-05-18 04:37:25,881 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull/_temporary
2016-05-18 04:37:25,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.005, using cpu time: 00:06.720
2016-05-18 04:37:25,925 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:37:25,926 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:37:25,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 04:37:25,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:37:25,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:37:25,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:37:25,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:37:25,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:37:25,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup"]
2016-05-18 04:37:25,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:37:25,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:37:25,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:37:25,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...roupinnernull-resultgroup
2016-05-18 04:37:26,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0051
2016-05-18 04:37:26,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0051/
2016-05-18 04:37:44,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000002 is : 143
2016-05-18 04:37:44,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000003 is : 143
2016-05-18 04:37:44,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000005 is : 143
2016-05-18 04:37:44,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000006 is : 143
2016-05-18 04:37:44,885 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000004 is : 143
2016-05-18 04:37:50,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0051_01_000007 is : 143
2016-05-18 04:37:51,717 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup/_temporary
2016-05-18 04:37:51,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.744, using cpu time: 00:06.650
2016-05-18 04:37:51,748 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup
2016-05-18 04:37:51,751 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull
2016-05-18 04:37:51,769 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:37:51,769 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:37:51,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 04:37:51,805 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:37:51,805 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:37:51,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:37:51,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:37:51,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 04:37:51,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle"]
2016-05-18 04:37:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:37:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:37:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:37:51,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...eField/cogroupinnersingle
2016-05-18 04:37:51,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0052
2016-05-18 04:37:51,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0052/
2016-05-18 04:38:12,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000002 is : 143
2016-05-18 04:38:12,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000004 is : 143
2016-05-18 04:38:12,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000006 is : 143
2016-05-18 04:38:13,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000005 is : 143
2016-05-18 04:38:13,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000007 is : 143
2016-05-18 04:38:18,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0052_01_000008 is : 143
2016-05-18 04:38:19,947 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle/_temporary
2016-05-18 04:38:19,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:28.126, using cpu time: 00:07.770
2016-05-18 04:38:19,980 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle
2016-05-18 04:38:19,999 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:38:19,999 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:38:20,072 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-05-18 04:38:20,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 04:38:20,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:38:20,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:38:20,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:38:20,105 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:38:20,105 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared"]
2016-05-18 04:38:20,105 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:38:20,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 04:38:20,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 04:38:20,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 04:38:20,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 04:38:20,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0053
2016-05-18 04:38:20,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0053/
2016-05-18 04:38:20,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0054
2016-05-18 04:38:20,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0054/
2016-05-18 04:38:39,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000006 is : 143
2016-05-18 04:38:39,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000005 is : 143
2016-05-18 04:38:40,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000002 is : 143
2016-05-18 04:38:40,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000004 is : 143
2016-05-18 04:38:40,636 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000003 is : 143
2016-05-18 04:38:49,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0053_01_000007 is : 143
2016-05-18 04:38:57,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000005 is : 143
2016-05-18 04:38:57,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000006 is : 143
2016-05-18 04:38:57,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000004 is : 143
2016-05-18 04:38:58,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000007 is : 143
2016-05-18 04:38:58,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000003 is : 143
2016-05-18 04:39:04,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0054_01_000008 is : 143
2016-05-18 04:39:05,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...ared/aftereverynodeclared
2016-05-18 04:39:05,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0055
2016-05-18 04:39:05,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0055/
2016-05-18 04:39:17,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0055_01_000003 is : 143
2016-05-18 04:39:17,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0055_01_000002 is : 143
2016-05-18 04:39:24,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0055_01_000004 is : 143
2016-05-18 04:39:25,580 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared/_temporary
2016-05-18 04:39:25,582 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:05.466, using cpu time: 00:17.130
2016-05-18 04:39:25,609 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared
2016-05-18 04:39:25,625 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:39:25,626 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:39:25,651 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 04:39:25,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:39:25,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:39:25,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:39:25,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:39:25,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:39:25,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself"]
2016-05-18 04:39:25,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:39:25,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:39:25,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:39:25,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...stCoGroupSelf/cogroupself
2016-05-18 04:39:25,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0056
2016-05-18 04:39:25,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0056/
2016-05-18 04:39:44,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0056_01_000002 is : 143
2016-05-18 04:39:44,360 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0056_01_000003 is : 143
2016-05-18 04:39:44,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0056_01_000005 is : 143
2016-05-18 04:39:44,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0056_01_000006 is : 143
2016-05-18 04:39:50,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0056_01_000007 is : 143
2016-05-18 04:39:51,943 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself/_temporary
2016-05-18 04:39:51,945 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.278, using cpu time: 00:06.760
2016-05-18 04:39:51,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself
2016-05-18 04:39:51,991 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:39:51,991 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:39:52,034 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 04:39:52,036 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:39:52,036 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 04:39:52,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:39:52,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:39:52,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:39:52,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby"]
2016-05-18 04:39:52,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 04:39:52,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 2
2016-05-18 04:39:52,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 2
2016-05-18 04:39:52,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 04:39:52,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0057
2016-05-18 04:39:52,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0057/
2016-05-18 04:40:11,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000002 is : 143
2016-05-18 04:40:12,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000003 is : 143
2016-05-18 04:40:13,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000005 is : 143
2016-05-18 04:40:13,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000007 is : 143
2016-05-18 04:40:13,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000006 is : 143
2016-05-18 04:40:13,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000004 is : 143
2016-05-18 04:40:18,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0057_01_000008 is : 143
2016-05-18 04:40:19,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...oupGroupBy/cogroupgroupby
2016-05-18 04:40:19,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463544978449_0058
2016-05-18 04:40:19,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:40060/proxy/application_1463544978449_0058/
2016-05-18 04:40:30,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0058_01_000002 is : 143
2016-05-18 04:40:36,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463544978449_0058_01_000003 is : 143
2016-05-18 04:40:37,866 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby/_temporary
2016-05-18 04:40:37,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:45.803, using cpu time: 00:10.170
2016-05-18 04:40:37,896 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby