2016-05-18 09:08:05,141 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 09:08:05,162 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 09:08:05,193 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 09:08:06,186 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 09:08:06,847 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 09:08:10,661 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:10,865 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:11,047 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:11,225 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:29,823 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 09:08:29,943 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:08:29,944 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 09:08:30,008 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 1ACB1F03A62B4B068ADD5AD2FF500300
2016-05-18 09:08:30,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-18 09:08:30,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:08:30,156 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 09:08:30,286 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 09:08:30,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:08:30,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:30,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 09:08:30,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-05-18 09:08:30,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:08:30,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:08:30,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:08:30,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-05-18 09:08:31,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0001
2016-05-18 09:08:31,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0001/
2016-05-18 09:08:52,107 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000006 is : 143
2016-05-18 09:08:52,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000004 is : 143
2016-05-18 09:08:52,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000005 is : 143
2016-05-18 09:08:52,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000002 is : 143
2016-05-18 09:08:52,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000003 is : 143
2016-05-18 09:08:54,264 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-05-18 09:08:54,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:23.972, using cpu time: 00:05.640
2016-05-18 09:08:54,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-05-18 09:08:54,408 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:08:54,408 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 09:08:54,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-18 09:08:54,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:08:54,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:08:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 09:08:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-05-18 09:08:54,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] parallel execution of steps is enabled: true
2016-05-18 09:08:54,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executing total steps: 2
2016-05-18 09:08:54,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] allocating management threads: 2
2016-05-18 09:08:54,550 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/2)
2016-05-18 09:08:54,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0002
2016-05-18 09:08:54,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0002/
2016-05-18 09:09:20,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000006 is : 143
2016-05-18 09:09:20,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000004 is : 143
2016-05-18 09:09:20,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000005 is : 143
2016-05-18 09:09:21,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000003 is : 143
2016-05-18 09:09:21,074 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000002 is : 143
2016-05-18 09:09:22,243 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-05-18 09:09:22,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0003
2016-05-18 09:09:22,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0003/
2016-05-18 09:09:47,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000006 is : 143
2016-05-18 09:09:48,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000005 is : 143
2016-05-18 09:09:48,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000002 is : 143
2016-05-18 09:09:48,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000003 is : 143
2016-05-18 09:09:48,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000004 is : 143
2016-05-18 09:09:50,036 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-05-18 09:09:50,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] completed in: 00:55.483, using cpu time: 00:12.000
2016-05-18 09:09:50,107 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-05-18 09:09:50,170 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:09:50,171 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 09:09:50,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2016-05-18 09:09:50,280 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:09:50,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:09:50,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting
2016-05-18 09:09:50,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:09:50,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:09:50,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:09:50,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-05-18 09:09:50,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] parallel execution of steps is enabled: true
2016-05-18 09:09:50,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] executing total steps: 2
2016-05-18 09:09:50,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] allocating management threads: 2
2016-05-18 09:09:50,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (1/2)
2016-05-18 09:09:50,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463562504321_0004
2016-05-18 09:09:50,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0004/
2016-05-18 09:10:15,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000004 is : 143
2016-05-18 09:10:15,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000002 is : 143
2016-05-18 09:10:16,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000005 is : 143
2016-05-18 09:10:16,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000003 is : 143
2016-05-18 09:10:16,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000006 is : 143
2016-05-18 09:10:17,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-05-18 09:10:18,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463562504321_0005
2016-05-18 09:10:18,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0005/
2016-05-18 09:10:42,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000006 is : 143
2016-05-18 09:10:43,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000005 is : 143
2016-05-18 09:10:43,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000003 is : 143
2016-05-18 09:10:43,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000002 is : 143
2016-05-18 09:10:43,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000004 is : 143
2016-05-18 09:10:44,999 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-05-18 09:10:45,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] completed in: 00:54.685, using cpu time: 00:12.340
2016-05-18 09:10:45,061 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-05-18 09:10:45,097 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:10:45,098 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 09:10:45,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-05-18 09:10:45,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:10:45,172 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 09:10:45,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting
2016-05-18 09:10:45,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:10:45,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:10:45,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-05-18 09:10:45,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] parallel execution of steps is enabled: true
2016-05-18 09:10:45,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executing total steps: 1
2016-05-18 09:10:45,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] allocating management threads: 1
2016-05-18 09:10:45,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-05-18 09:10:45,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] submitted hadoop job: job_1463562504321_0006
2016-05-18 09:10:45,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0006/
2016-05-18 09:11:10,259 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000002 is : 143
2016-05-18 09:11:10,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000003 is : 143
2016-05-18 09:11:10,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000006 is : 143
2016-05-18 09:11:10,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000005 is : 143
2016-05-18 09:11:12,113 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-05-18 09:11:12,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] completed in: 00:26.910, using cpu time: 00:05.960
2016-05-18 09:11:12,182 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-05-18 09:11:12,215 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:11:12,215 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 09:11:12,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 09:11:12,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:11:12,310 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 09:11:12,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:11:12,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:11:12,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:11:12,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-05-18 09:11:12,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:11:12,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 09:11:12,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 09:11:12,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 09:11:12,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 09:11:12,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0008
2016-05-18 09:11:12,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0008/
2016-05-18 09:11:12,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0007
2016-05-18 09:11:12,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0007/
2016-05-18 09:11:37,440 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000002 is : 143
2016-05-18 09:11:37,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000003 is : 143
2016-05-18 09:11:38,081 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000005 is : 143
2016-05-18 09:11:38,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000004 is : 143
2016-05-18 09:11:38,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000006 is : 143
2016-05-18 09:11:44,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000007 is : 143
2016-05-18 09:12:11,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000006 is : 143
2016-05-18 09:12:11,813 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000003 is : 143
2016-05-18 09:12:12,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000002 is : 143
2016-05-18 09:12:12,466 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000005 is : 143
2016-05-18 09:12:18,386 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000007 is : 143
2016-05-18 09:12:19,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-05-18 09:12:19,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0009
2016-05-18 09:12:19,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0009/
2016-05-18 09:12:36,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0009_01_000002 is : 143
2016-05-18 09:12:38,043 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-05-18 09:12:38,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:25.677, using cpu time: 00:14.960
2016-05-18 09:12:38,079 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-05-18 09:12:38,206 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:12:38,207 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 09:12:38,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.190
2016-05-18 09:12:38,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 6, nodes: 12
2016-05-18 09:12:38,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:12:38,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:12:38,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:12:38,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:12:38,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join"]
2016-05-18 09:12:38,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] parallel execution of steps is enabled: true
2016-05-18 09:12:38,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executing total steps: 6
2016-05-18 09:12:38,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] allocating management threads: 6
2016-05-18 09:12:38,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/6)
2016-05-18 09:12:38,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/6)
2016-05-18 09:12:38,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0011
2016-05-18 09:12:38,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0011/
2016-05-18 09:12:38,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0010
2016-05-18 09:12:38,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0010/
2016-05-18 09:13:04,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000003 is : 143
2016-05-18 09:13:04,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000002 is : 143
2016-05-18 09:13:04,708 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000006 is : 143
2016-05-18 09:13:04,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000004 is : 143
2016-05-18 09:13:05,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000005 is : 143
2016-05-18 09:13:11,139 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000007 is : 143
2016-05-18 09:13:38,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000006 is : 143
2016-05-18 09:13:38,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000003 is : 143
2016-05-18 09:13:39,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000005 is : 143
2016-05-18 09:13:39,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000004 is : 143
2016-05-18 09:13:39,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000002 is : 143
2016-05-18 09:13:45,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000007 is : 143
2016-05-18 09:13:46,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (3/6)
2016-05-18 09:13:46,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0012
2016-05-18 09:13:46,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0012/
2016-05-18 09:14:05,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000002 is : 143
2016-05-18 09:14:05,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000003 is : 143
2016-05-18 09:14:12,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000004 is : 143
2016-05-18 09:14:14,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (4/6)
2016-05-18 09:14:14,137 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (5/6)
2016-05-18 09:14:14,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0013
2016-05-18 09:14:14,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0013/
2016-05-18 09:14:14,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0014
2016-05-18 09:14:14,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0014/
2016-05-18 09:14:39,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000002 is : 143
2016-05-18 09:14:39,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000003 is : 143
2016-05-18 09:14:39,837 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000005 is : 143
2016-05-18 09:14:40,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000006 is : 143
2016-05-18 09:14:40,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000004 is : 143
2016-05-18 09:14:46,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000007 is : 143
2016-05-18 09:15:12,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000002 is : 143
2016-05-18 09:15:12,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000003 is : 143
2016-05-18 09:15:12,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000005 is : 143
2016-05-18 09:15:13,091 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000004 is : 143
2016-05-18 09:15:13,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000006 is : 143
2016-05-18 09:15:19,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000007 is : 143
2016-05-18 09:15:21,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (6/6) ...HashJoinCoGroupAgain/join
2016-05-18 09:15:21,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0015
2016-05-18 09:15:21,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0015/
2016-05-18 09:15:40,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000003 is : 143
2016-05-18 09:15:40,270 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000002 is : 143
2016-05-18 09:15:47,007 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000004 is : 143
2016-05-18 09:15:48,188 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join/_temporary
2016-05-18 09:15:48,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] completed in: 03:09.611, using cpu time: 00:44.280
2016-05-18 09:15:48,226 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join
2016-05-18 09:15:48,281 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:15:48,282 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 09:15:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 09:15:48,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:15:48,355 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:15:48,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:15:48,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:15:48,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] parallel execution of steps is enabled: true
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executing total steps: 1
2016-05-18 09:15:48,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] allocating management threads: 1
2016-05-18 09:15:48,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-05-18 09:15:48,522 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0016
2016-05-18 09:15:48,522 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0016/
2016-05-18 09:16:13,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000002 is : 143
2016-05-18 09:16:14,445 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000003 is : 143
2016-05-18 09:16:14,520 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000004 is : 143
2016-05-18 09:16:14,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000006 is : 143
2016-05-18 09:16:14,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000005 is : 143
2016-05-18 09:16:20,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000007 is : 143
2016-05-18 09:16:21,544 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-05-18 09:16:21,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] completed in: 00:33.161, using cpu time: 00:07.640
2016-05-18 09:16:21,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-05-18 09:16:21,619 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:16:21,619 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 09:16:21,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-05-18 09:16:21,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 09:16:21,700 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 09:16:21,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-18 09:16:21,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:16:21,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:16:21,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 09:16:21,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-05-18 09:16:21,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-05-18 09:16:21,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] parallel execution of steps is enabled: true
2016-05-18 09:16:21,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executing total steps: 3
2016-05-18 09:16:21,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] allocating management threads: 3
2016-05-18 09:16:21,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/3)
2016-05-18 09:16:22,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0017
2016-05-18 09:16:22,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0017/
2016-05-18 09:16:46,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000002 is : 143
2016-05-18 09:16:46,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000003 is : 143
2016-05-18 09:16:46,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000006 is : 143
2016-05-18 09:16:47,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000005 is : 143
2016-05-18 09:16:47,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000004 is : 143
2016-05-18 09:16:53,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000007 is : 143
2016-05-18 09:16:54,778 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-05-18 09:16:54,781 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-05-18 09:16:54,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0019
2016-05-18 09:16:54,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0019/
2016-05-18 09:16:55,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0018
2016-05-18 09:16:55,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0018/
2016-05-18 09:17:13,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0018_01_000002 is : 143
2016-05-18 09:17:32,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0019_01_000002 is : 143
2016-05-18 09:17:33,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-05-18 09:17:33,250 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-05-18 09:17:33,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] completed in: 01:11.511, using cpu time: 00:09.080
2016-05-18 09:17:33,315 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-05-18 09:17:33,320 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-05-18 09:17:33,345 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:17:33,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 09:17:33,421 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 09:17:33,425 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:17:33,425 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:17:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:17:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:17:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:17:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:17:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:17:33,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-05-18 09:17:33,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] parallel execution of steps is enabled: true
2016-05-18 09:17:33,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executing total steps: 2
2016-05-18 09:17:33,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] allocating management threads: 2
2016-05-18 09:17:33,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 09:17:33,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0020
2016-05-18 09:17:33,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0020/
2016-05-18 09:17:59,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000002 is : 143
2016-05-18 09:17:59,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000003 is : 143
2016-05-18 09:17:59,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000004 is : 143
2016-05-18 09:17:59,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000006 is : 143
2016-05-18 09:17:59,571 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000005 is : 143
2016-05-18 09:18:00,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-05-18 09:18:01,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0021
2016-05-18 09:18:01,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0021/
2016-05-18 09:18:26,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000003 is : 143
2016-05-18 09:18:26,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000005 is : 143
2016-05-18 09:18:26,645 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000006 is : 143
2016-05-18 09:18:26,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000002 is : 143
2016-05-18 09:18:26,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000004 is : 143
2016-05-18 09:18:33,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000007 is : 143
2016-05-18 09:18:34,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-05-18 09:18:34,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] completed in: 01:01.125, using cpu time: 00:13.540
2016-05-18 09:18:34,621 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-05-18 09:18:34,643 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:18:34,644 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 09:18:34,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 09:18:34,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:18:34,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:18:34,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:18:34,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:18:34,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:18:34,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:18:34,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:18:34,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-05-18 09:18:34,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] parallel execution of steps is enabled: true
2016-05-18 09:18:34,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executing total steps: 2
2016-05-18 09:18:34,748 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] allocating management threads: 2
2016-05-18 09:18:34,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 09:18:35,063 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0022
2016-05-18 09:18:35,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0022/
2016-05-18 09:19:00,657 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000006 is : 143
2016-05-18 09:19:00,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000005 is : 143
2016-05-18 09:19:01,172 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000003 is : 143
2016-05-18 09:19:01,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000004 is : 143
2016-05-18 09:19:01,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000002 is : 143
2016-05-18 09:19:02,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-05-18 09:19:02,596 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0023
2016-05-18 09:19:02,596 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0023/
2016-05-18 09:19:29,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000005 is : 143
2016-05-18 09:19:29,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000002 is : 143
2016-05-18 09:19:29,478 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000004 is : 143
2016-05-18 09:19:29,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000003 is : 143
2016-05-18 09:19:29,688 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000006 is : 143
2016-05-18 09:19:36,700 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000007 is : 143
2016-05-18 09:19:37,869 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-05-18 09:19:37,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] completed in: 01:03.119, using cpu time: 00:14.950
2016-05-18 09:19:37,904 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-05-18 09:19:37,936 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:19:37,936 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 09:19:37,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 09:19:37,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:19:37,975 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 09:19:37,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:19:37,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:19:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:19:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-05-18 09:19:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:19:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:19:37,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:19:37,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-05-18 09:19:38,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0024
2016-05-18 09:19:38,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0024/
2016-05-18 09:20:03,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000006 is : 143
2016-05-18 09:20:03,859 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000002 is : 143
2016-05-18 09:20:04,182 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000005 is : 143
2016-05-18 09:20:04,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000003 is : 143
2016-05-18 09:20:04,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000004 is : 143
2016-05-18 09:20:05,567 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-05-18 09:20:05,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.578, using cpu time: 00:09.020
2016-05-18 09:20:05,626 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-05-18 09:20:05,654 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:20:05,654 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 09:20:05,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-18 09:20:05,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:20:05,734 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:20:05,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting
2016-05-18 09:20:05,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] parallel execution of steps is enabled: true
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] executing total steps: 2
2016-05-18 09:20:05,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] allocating management threads: 2
2016-05-18 09:20:05,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (1/2)
2016-05-18 09:20:05,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463562504321_0025
2016-05-18 09:20:05,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0025/
2016-05-18 09:20:31,015 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000003 is : 143
2016-05-18 09:20:31,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000002 is : 143
2016-05-18 09:20:31,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000004 is : 143
2016-05-18 09:20:37,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000007 is : 143
2016-05-18 09:20:38,793 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-05-18 09:20:39,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463562504321_0026
2016-05-18 09:20:39,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0026/
2016-05-18 09:20:56,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0026_01_000002 is : 143
2016-05-18 09:20:57,873 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-05-18 09:20:57,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] completed in: 00:52.113, using cpu time: 00:08.430
2016-05-18 09:20:57,906 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-05-18 09:20:57,926 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:20:57,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 09:20:57,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 09:20:57,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:20:57,957 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 09:20:57,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 09:20:57,975 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.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:20:57,975 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.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:20:57,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2016-05-18 09:20:57,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-18 09:20:57,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 1
2016-05-18 09:20:57,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 1
2016-05-18 09:20:57,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-05-18 09:20:58,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0027
2016-05-18 09:20:58,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0027/
2016-05-18 09:21:20,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000003 is : 143
2016-05-18 09:21:21,150 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000004 is : 143
2016-05-18 09:21:21,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000002 is : 143
2016-05-18 09:21:21,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000005 is : 143
2016-05-18 09:21:22,389 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2016-05-18 09:21:22,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:24.413, using cpu time: 00:04.990
2016-05-18 09:21:22,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2016-05-18 09:21:22,467 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:21:22,467 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 09:21:22,499 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 09:21:22,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:21:22,501 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 09:21:22,511 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:21:22,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:21:22,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:21:22,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2016-05-18 09:21:22,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:21:22,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:21:22,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:21:22,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-05-18 09:21:22,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0028
2016-05-18 09:21:22,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0028/
2016-05-18 09:21:46,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000006 is : 143
2016-05-18 09:21:47,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000002 is : 143
2016-05-18 09:21:47,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000005 is : 143
2016-05-18 09:21:47,657 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000004 is : 143
2016-05-18 09:21:47,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000003 is : 143
2016-05-18 09:21:49,007 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2016-05-18 09:21:49,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.494, using cpu time: 00:05.830
2016-05-18 09:21:49,052 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2016-05-18 09:21:49,081 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:21:49,082 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 09:21:49,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.106
2016-05-18 09:21:49,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:21:49,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:21:49,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:21:49,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:21:49,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:21:49,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:21:49,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-05-18 09:21:49,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-05-18 09:21:49,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] parallel execution of steps is enabled: true
2016-05-18 09:21:49,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executing total steps: 3
2016-05-18 09:21:49,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] allocating management threads: 3
2016-05-18 09:21:49,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 09:21:49,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0029
2016-05-18 09:21:49,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0029/
2016-05-18 09:22:13,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000002 is : 143
2016-05-18 09:22:14,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000003 is : 143
2016-05-18 09:22:14,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000004 is : 143
2016-05-18 09:22:14,695 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000005 is : 143
2016-05-18 09:22:14,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000006 is : 143
2016-05-18 09:22:16,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/rhs
2016-05-18 09:22:16,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/lhs
2016-05-18 09:22:16,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0030
2016-05-18 09:22:16,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0030/
2016-05-18 09:22:16,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0031
2016-05-18 09:22:16,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0031/
2016-05-18 09:22:41,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000003 is : 143
2016-05-18 09:22:42,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000002 is : 143
2016-05-18 09:22:42,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000004 is : 143
2016-05-18 09:22:42,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000006 is : 143
2016-05-18 09:22:42,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000005 is : 143
2016-05-18 09:22:48,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000007 is : 143
2016-05-18 09:23:12,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000003 is : 143
2016-05-18 09:23:13,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000005 is : 143
2016-05-18 09:23:13,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000002 is : 143
2016-05-18 09:23:13,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000004 is : 143
2016-05-18 09:23:19,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000006 is : 143
2016-05-18 09:23:20,774 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-05-18 09:23:20,775 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-05-18 09:23:20,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] completed in: 01:31.517, using cpu time: 00:19.620
2016-05-18 09:23:20,812 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-05-18 09:23:20,817 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-05-18 09:23:20,839 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:23:20,839 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 09:23:20,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 09:23:20,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:23:20,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:23:20,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting
2016-05-18 09:23:20,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:23:20,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:23:20,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:23:20,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:23:20,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-05-18 09:23:20,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] parallel execution of steps is enabled: true
2016-05-18 09:23:20,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] executing total steps: 1
2016-05-18 09:23:20,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] allocating management threads: 1
2016-05-18 09:23:20,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-05-18 09:23:21,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] submitted hadoop job: job_1463562504321_0032
2016-05-18 09:23:21,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0032/
2016-05-18 09:23:47,682 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000002 is : 143
2016-05-18 09:23:48,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000003 is : 143
2016-05-18 09:23:48,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000006 is : 143
2016-05-18 09:23:48,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000004 is : 143
2016-05-18 09:23:48,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000005 is : 143
2016-05-18 09:23:48,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000007 is : 143
2016-05-18 09:23:54,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000008 is : 143
2016-05-18 09:23:56,100 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-05-18 09:23:56,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] completed in: 00:35.175, using cpu time: 00:08.720
2016-05-18 09:23:56,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-05-18 09:23:56,164 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:23:56,165 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 09:23:56,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 09:23:56,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:23:56,197 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 09:23:56,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:23:56,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:23:56,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:23:56,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-05-18 09:23:56,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:23:56,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:23:56,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:23:56,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-05-18 09:23:56,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0033
2016-05-18 09:23:56,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0033/
2016-05-18 09:24:21,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000006 is : 143
2016-05-18 09:24:21,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000003 is : 143
2016-05-18 09:24:21,601 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000004 is : 143
2016-05-18 09:24:21,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000002 is : 143
2016-05-18 09:24:21,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000005 is : 143
2016-05-18 09:24:23,017 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-05-18 09:24:23,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.807, using cpu time: 00:05.910
2016-05-18 09:24:23,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-05-18 09:24:23,102 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:24:23,102 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 09:24:23,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 09:24:23,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:24:23,140 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 09:24:23,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 09:24:23,152 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.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:24:23,152 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.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:23,153 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.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:23,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-05-18 09:24:23,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-05-18 09:24:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executing total steps: 1
2016-05-18 09:24:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] allocating management threads: 1
2016-05-18 09:24:23,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-05-18 09:24:23,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0034
2016-05-18 09:24:23,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0034/
2016-05-18 09:24:48,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000003 is : 143
2016-05-18 09:24:48,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000005 is : 143
2016-05-18 09:24:48,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000004 is : 143
2016-05-18 09:24:49,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000002 is : 143
2016-05-18 09:24:49,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000006 is : 143
2016-05-18 09:24:50,511 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-05-18 09:24:50,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] completed in: 00:27.354, using cpu time: 00:06.100
2016-05-18 09:24:50,557 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-05-18 09:24:50,597 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:24:50,598 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 09:24:50,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 09:24:50,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:24:50,628 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 09:24:50,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:24:50,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:50,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:24:50,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-05-18 09:24:50,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:24:50,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:24:50,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:24:50,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-05-18 09:24:50,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0035
2016-05-18 09:24:50,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0035/
2016-05-18 09:25:15,438 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000005 is : 143
2016-05-18 09:25:15,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000003 is : 143
2016-05-18 09:25:15,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000004 is : 143
2016-05-18 09:25:15,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000002 is : 143
2016-05-18 09:25:15,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000006 is : 143
2016-05-18 09:25:17,180 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-05-18 09:25:17,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:26.539, using cpu time: 00:05.880
2016-05-18 09:25:17,228 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2016-05-18 09:25:17,252 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:25:17,252 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 09:25:17,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 09:25:17,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:25:17,293 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 09:25:17,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:25:17,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:25:17,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:25:17,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-05-18 09:25:17,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:25:17,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 2
2016-05-18 09:25:17,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 2
2016-05-18 09:25:17,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:25:17,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0036
2016-05-18 09:25:17,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0036/
2016-05-18 09:25:42,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000002 is : 143
2016-05-18 09:25:42,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000005 is : 143
2016-05-18 09:25:42,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000004 is : 143
2016-05-18 09:25:43,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000003 is : 143
2016-05-18 09:25:43,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000006 is : 143
2016-05-18 09:25:44,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-05-18 09:25:44,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0037
2016-05-18 09:25:44,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0037/
2016-05-18 09:26:10,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000003 is : 143
2016-05-18 09:26:10,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000006 is : 143
2016-05-18 09:26:10,532 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000004 is : 143
2016-05-18 09:26:10,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000002 is : 143
2016-05-18 09:26:11,266 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000005 is : 143
2016-05-18 09:26:12,457 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-05-18 09:26:12,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:55.143, using cpu time: 00:11.820
2016-05-18 09:26:12,504 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2016-05-18 09:26:12,530 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:26:12,531 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 09:26:12,630 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.096
2016-05-18 09:26:12,632 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 8
2016-05-18 09:26:12,632 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:26:12,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting
2016-05-18 09:26:12,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:26:12,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink"]
2016-05-18 09:26:12,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2"]
2016-05-18 09:26:12,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] parallel execution of steps is enabled: true
2016-05-18 09:26:12,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] executing total steps: 5
2016-05-18 09:26:12,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] allocating management threads: 5
2016-05-18 09:26:12,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (1/5)
2016-05-18 09:26:12,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (2/5)
2016-05-18 09:26:12,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0038
2016-05-18 09:26:12,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0038/
2016-05-18 09:26:12,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0039
2016-05-18 09:26:12,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0039/
2016-05-18 09:26:17,656 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463562504321_0037_01_000001
2016-05-18 09:26:37,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000003 is : 143
2016-05-18 09:26:37,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000002 is : 143
2016-05-18 09:26:38,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000004 is : 143
2016-05-18 09:26:38,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000005 is : 143
2016-05-18 09:26:38,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000006 is : 143
2016-05-18 09:26:45,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000007 is : 143
2016-05-18 09:26:46,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (3/5)
2016-05-18 09:26:46,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0040
2016-05-18 09:26:46,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0040/
2016-05-18 09:27:12,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000002 is : 143
2016-05-18 09:27:13,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000004 is : 143
2016-05-18 09:27:13,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000005 is : 143
2016-05-18 09:27:13,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000006 is : 143
2016-05-18 09:27:20,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000007 is : 143
2016-05-18 09:27:21,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (4/5) ...undSplitGroupByJoin/sink2
2016-05-18 09:27:21,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0041
2016-05-18 09:27:21,258 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0041/
2016-05-18 09:27:39,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0040_01_000002 is : 143
2016-05-18 09:27:46,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0040_01_000003 is : 143
2016-05-18 09:27:47,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (5/5) ...oundSplitGroupByJoin/sink
2016-05-18 09:27:47,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0042
2016-05-18 09:27:47,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0042/
2016-05-18 09:28:04,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0041_01_000002 is : 143
2016-05-18 09:28:23,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0042_01_000002 is : 143
2016-05-18 09:28:25,177 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2/_temporary
2016-05-18 09:28:25,178 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink/_temporary
2016-05-18 09:28:25,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] completed in: 02:12.459, using cpu time: 00:17.760
2016-05-18 09:28:25,216 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2
2016-05-18 09:28:25,220 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink
2016-05-18 09:28:25,240 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:28:25,240 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 09:28:25,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-05-18 09:28:25,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 09:28:25,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:28:25,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:28:25,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:28:25,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:28:25,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:28:25,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-05-18 09:28:25,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-05-18 09:28:25,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] parallel execution of steps is enabled: true
2016-05-18 09:28:25,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executing total steps: 3
2016-05-18 09:28:25,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] allocating management threads: 3
2016-05-18 09:28:25,334 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 09:28:25,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0043
2016-05-18 09:28:25,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0043/
2016-05-18 09:28:47,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000002 is : 143
2016-05-18 09:28:48,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000004 is : 143
2016-05-18 09:28:48,376 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000005 is : 143
2016-05-18 09:28:49,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000003 is : 143
2016-05-18 09:28:50,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2016-05-18 09:28:50,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2016-05-18 09:28:50,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0045
2016-05-18 09:28:50,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0045/
2016-05-18 09:28:50,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0044
2016-05-18 09:28:50,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0044/
2016-05-18 09:29:13,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000002 is : 143
2016-05-18 09:29:13,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000005 is : 143
2016-05-18 09:29:14,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000004 is : 143
2016-05-18 09:29:38,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000003 is : 143
2016-05-18 09:29:38,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000005 is : 143
2016-05-18 09:29:38,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000004 is : 143
2016-05-18 09:29:38,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000002 is : 143
2016-05-18 09:29:40,082 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-05-18 09:29:40,083 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-05-18 09:29:40,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] completed in: 01:14.749, using cpu time: 00:15.320
2016-05-18 09:29:40,132 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-05-18 09:29:40,143 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-05-18 09:29:40,171 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:29:40,171 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 09:29:40,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 09:29:40,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:29:40,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:29:40,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting
2016-05-18 09:29:40,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:29:40,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:29:40,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:29:40,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-05-18 09:29:40,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] parallel execution of steps is enabled: true
2016-05-18 09:29:40,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] executing total steps: 2
2016-05-18 09:29:40,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] allocating management threads: 2
2016-05-18 09:29:40,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (1/2)
2016-05-18 09:29:40,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463562504321_0046
2016-05-18 09:29:40,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0046/
2016-05-18 09:30:06,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000004 is : 143
2016-05-18 09:30:06,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000002 is : 143
2016-05-18 09:30:06,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000003 is : 143
2016-05-18 09:30:06,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000006 is : 143
2016-05-18 09:30:07,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000005 is : 143
2016-05-18 09:30:08,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-05-18 09:30:08,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463562504321_0047
2016-05-18 09:30:08,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0047/
2016-05-18 09:30:32,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000002 is : 143
2016-05-18 09:30:33,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000005 is : 143
2016-05-18 09:30:33,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000004 is : 143
2016-05-18 09:30:33,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000006 is : 143
2016-05-18 09:30:33,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000003 is : 143
2016-05-18 09:30:34,931 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-05-18 09:30:34,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] completed in: 00:54.690, using cpu time: 00:12.330
2016-05-18 09:30:34,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-05-18 09:30:35,003 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:30:35,003 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 09:30:35,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 09:30:35,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 09:30:35,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:30:35,132 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting
2016-05-18 09:30:35,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:30:35,134 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:30:35,136 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join"]
2016-05-18 09:30:35,136 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] parallel execution of steps is enabled: true
2016-05-18 09:30:35,136 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] executing total steps: 4
2016-05-18 09:30:35,136 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] allocating management threads: 4
2016-05-18 09:30:35,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (1/4)
2016-05-18 09:30:35,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (2/4)
2016-05-18 09:30:35,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0048
2016-05-18 09:30:35,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0048/
2016-05-18 09:30:35,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0049
2016-05-18 09:30:35,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0049/
2016-05-18 09:31:00,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000002 is : 143
2016-05-18 09:31:00,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000006 is : 143
2016-05-18 09:31:00,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000003 is : 143
2016-05-18 09:31:01,011 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000005 is : 143
2016-05-18 09:31:01,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000004 is : 143
2016-05-18 09:31:07,043 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000007 is : 143
2016-05-18 09:31:34,982 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000006 is : 143
2016-05-18 09:31:35,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000004 is : 143
2016-05-18 09:31:35,381 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000002 is : 143
2016-05-18 09:31:35,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000005 is : 143
2016-05-18 09:31:41,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000007 is : 143
2016-05-18 09:31:42,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (3/4)
2016-05-18 09:31:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0050
2016-05-18 09:31:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0050/
2016-05-18 09:32:02,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000002 is : 143
2016-05-18 09:32:02,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000003 is : 143
2016-05-18 09:32:08,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000004 is : 143
2016-05-18 09:32:09,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (4/4) ...kCoGroupThenHashJoin/join
2016-05-18 09:32:09,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0051
2016-05-18 09:32:09,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0051/
2016-05-18 09:32:35,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000002 is : 143
2016-05-18 09:32:35,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000003 is : 143
2016-05-18 09:32:35,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000006 is : 143
2016-05-18 09:32:36,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000004 is : 143
2016-05-18 09:32:36,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000005 is : 143
2016-05-18 09:32:37,453 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join/_temporary
2016-05-18 09:32:37,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] completed in: 02:02.316, using cpu time: 00:30.950
2016-05-18 09:32:37,507 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join
2016-05-18 09:32:37,531 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:32:37,531 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 09:32:37,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 09:32:37,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:32:37,568 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 09:32:37,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:32:37,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:32:37,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join"]
2016-05-18 09:32:37,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:32:37,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 2
2016-05-18 09:32:37,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 2
2016-05-18 09:32:37,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:32:37,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0052
2016-05-18 09:32:37,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0052/
2016-05-18 09:33:03,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000004 is : 143
2016-05-18 09:33:04,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000002 is : 143
2016-05-18 09:33:04,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000003 is : 143
2016-05-18 09:33:04,440 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000005 is : 143
2016-05-18 09:33:04,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000006 is : 143
2016-05-18 09:33:05,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testForkThenJoin/join
2016-05-18 09:33:05,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0053
2016-05-18 09:33:05,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0053/
2016-05-18 09:33:30,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000006 is : 143
2016-05-18 09:33:31,501 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000002 is : 143
2016-05-18 09:33:31,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000003 is : 143
2016-05-18 09:33:31,753 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000004 is : 143
2016-05-18 09:33:32,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000005 is : 143
2016-05-18 09:33:33,301 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join/_temporary
2016-05-18 09:33:33,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:55.714, using cpu time: 00:15.830
2016-05-18 09:33:33,345 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join
2016-05-18 09:33:33,371 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:33:33,371 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 09:33:33,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 09:33:33,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:33:33,418 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 09:33:33,438 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:33:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:33:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:33:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-05-18 09:33:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:33:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 2
2016-05-18 09:33:33,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 2
2016-05-18 09:33:33,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:33:33,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0054
2016-05-18 09:33:33,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0054/
2016-05-18 09:33:38,451 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463562504321_0053_01_000001
2016-05-18 09:33:57,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000006 is : 143
2016-05-18 09:33:58,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000004 is : 143
2016-05-18 09:33:58,671 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000002 is : 143
2016-05-18 09:33:58,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000003 is : 143
2016-05-18 09:33:59,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000005 is : 143
2016-05-18 09:34:05,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000007 is : 143
2016-05-18 09:34:06,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-05-18 09:34:06,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0055
2016-05-18 09:34:06,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0055/
2016-05-18 09:34:31,498 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000003 is : 143
2016-05-18 09:34:31,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000002 is : 143
2016-05-18 09:34:32,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000006 is : 143
2016-05-18 09:34:32,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000005 is : 143
2016-05-18 09:34:32,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000004 is : 143
2016-05-18 09:34:33,664 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-05-18 09:34:33,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:00.223, using cpu time: 00:12.940
2016-05-18 09:34:33,709 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-05-18 09:34:33,733 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:34:33,734 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 09:34:33,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 09:34:33,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 09:34:33,810 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 09:34:33,841 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 09:34:33,842 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.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:34:33,842 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.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:34:33,842 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.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:34:33,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-05-18 09:34:33,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2016-05-18 09:34:33,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executing total steps: 3
2016-05-18 09:34:33,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] allocating management threads: 3
2016-05-18 09:34:33,848 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/3)
2016-05-18 09:34:33,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0056
2016-05-18 09:34:33,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0056/
2016-05-18 09:34:58,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000002 is : 143
2016-05-18 09:34:58,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000003 is : 143
2016-05-18 09:34:58,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000006 is : 143
2016-05-18 09:34:59,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000005 is : 143
2016-05-18 09:34:59,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000004 is : 143
2016-05-18 09:35:00,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (2/3)
2016-05-18 09:35:00,880 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0057
2016-05-18 09:35:00,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0057/
2016-05-18 09:35:26,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000002 is : 143
2016-05-18 09:35:26,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000006 is : 143
2016-05-18 09:35:27,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000003 is : 143
2016-05-18 09:35:27,284 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000004 is : 143
2016-05-18 09:35:27,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000005 is : 143
2016-05-18 09:35:28,662 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-05-18 09:35:28,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0058
2016-05-18 09:35:28,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0058/
2016-05-18 09:35:54,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000002 is : 143
2016-05-18 09:35:54,871 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000006 is : 143
2016-05-18 09:35:55,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000004 is : 143
2016-05-18 09:35:55,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000005 is : 143
2016-05-18 09:35:56,445 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-05-18 09:35:56,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] completed in: 01:22.596, using cpu time: 00:18.540
2016-05-18 09:35:56,491 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-05-18 09:35:56,519 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:35:56,519 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 09:35:56,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 09:35:56,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:35:56,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:35:56,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:35:56,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:35:56,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:35:56,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:35:56,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:35:56,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-05-18 09:35:56,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] parallel execution of steps is enabled: true
2016-05-18 09:35:56,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executing total steps: 1
2016-05-18 09:35:56,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] allocating management threads: 1
2016-05-18 09:35:56,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-05-18 09:35:56,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0059
2016-05-18 09:35:56,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0059/
2016-05-18 09:36:24,131 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000002 is : 143
2016-05-18 09:36:24,517 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000007 is : 143
2016-05-18 09:36:24,851 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000005 is : 143
2016-05-18 09:36:25,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000003 is : 143
2016-05-18 09:36:25,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000004 is : 143
2016-05-18 09:36:25,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000006 is : 143
2016-05-18 09:36:30,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000008 is : 143
2016-05-18 09:36:31,632 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-05-18 09:36:31,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] completed in: 00:35.031, using cpu time: 00:08.780
2016-05-18 09:36:31,666 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-05-18 09:36:31,711 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:36:31,711 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 09:36:31,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 09:36:31,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:36:31,737 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 09:36:31,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:36:31,753 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.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 09:36:31,753 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.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 09:36:31,753 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.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-05-18 09:36:31,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:36:31,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:36:31,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:36:31,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-05-18 09:36:31,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0060
2016-05-18 09:36:31,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0060/
2016-05-18 09:36:57,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000003 is : 143
2016-05-18 09:36:57,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000006 is : 143
2016-05-18 09:36:57,578 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000002 is : 143
2016-05-18 09:36:57,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000004 is : 143
2016-05-18 09:36:57,972 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000005 is : 143
2016-05-18 09:36:59,152 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-05-18 09:36:59,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.398, using cpu time: 00:05.870
2016-05-18 09:36:59,197 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2016-05-18 09:36:59,222 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:36:59,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 09:36:59,271 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 09:36:59,272 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:36:59,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:36:59,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:36:59,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:36:59,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:36:59,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-05-18 09:36:59,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-05-18 09:36:59,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] parallel execution of steps is enabled: true
2016-05-18 09:36:59,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executing total steps: 2
2016-05-18 09:36:59,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] allocating management threads: 2
2016-05-18 09:36:59,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...latform/testJoinSplit/rhs
2016-05-18 09:36:59,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...latform/testJoinSplit/lhs
2016-05-18 09:36:59,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0062
2016-05-18 09:36:59,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0062/
2016-05-18 09:36:59,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0061
2016-05-18 09:36:59,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0061/
2016-05-18 09:37:22,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000004 is : 143
2016-05-18 09:37:22,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000003 is : 143
2016-05-18 09:37:23,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000002 is : 143
2016-05-18 09:37:47,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000004 is : 143
2016-05-18 09:37:47,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000002 is : 143
2016-05-18 09:37:47,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000005 is : 143
2016-05-18 09:37:48,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000003 is : 143
2016-05-18 09:37:49,276 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-05-18 09:37:49,278 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-05-18 09:37:49,284 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] completed in: 00:49.981, using cpu time: 00:09.910
2016-05-18 09:37:49,347 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2016-05-18 09:37:49,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2016-05-18 09:37:49,383 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:37:49,384 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 09:37:49,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 09:37:49,438 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:37:49,438 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 09:37:49,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 09:37:49,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:37:49,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-05-18 09:37:49,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-18 09:37:49,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 2
2016-05-18 09:37:49,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 2
2016-05-18 09:37:49,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/2)
2016-05-18 09:37:49,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0063
2016-05-18 09:37:49,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0063/
2016-05-18 09:38:13,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000006 is : 143
2016-05-18 09:38:14,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000002 is : 143
2016-05-18 09:38:14,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000005 is : 143
2016-05-18 09:38:14,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000004 is : 143
2016-05-18 09:38:14,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000003 is : 143
2016-05-18 09:38:19,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000007 is : 143
2016-05-18 09:38:20,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-05-18 09:38:20,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0064
2016-05-18 09:38:20,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0064/
2016-05-18 09:38:45,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000002 is : 143
2016-05-18 09:38:45,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000006 is : 143
2016-05-18 09:38:45,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000003 is : 143
2016-05-18 09:38:46,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000005 is : 143
2016-05-18 09:38:46,785 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000004 is : 143
2016-05-18 09:38:47,983 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-05-18 09:38:47,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:58.522, using cpu time: 00:13.160
2016-05-18 09:38:48,027 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-05-18 09:38:48,053 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:38:48,053 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 09:38:48,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 09:38:48,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:38:48,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:38:48,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 09:38:48,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:38:48,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:38:48,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-05-18 09:38:48,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] parallel execution of steps is enabled: true
2016-05-18 09:38:48,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executing total steps: 3
2016-05-18 09:38:48,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] allocating management threads: 3
2016-05-18 09:38:48,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/3)
2016-05-18 09:38:48,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/3)
2016-05-18 09:38:48,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0066
2016-05-18 09:38:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0066/
2016-05-18 09:38:48,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0065
2016-05-18 09:38:48,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0065/
2016-05-18 09:39:13,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000002 is : 143
2016-05-18 09:39:13,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000003 is : 143
2016-05-18 09:39:14,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000005 is : 143
2016-05-18 09:39:14,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000006 is : 143
2016-05-18 09:39:14,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000004 is : 143
2016-05-18 09:39:20,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000007 is : 143
2016-05-18 09:39:46,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000003 is : 143
2016-05-18 09:39:46,589 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000002 is : 143
2016-05-18 09:39:46,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000006 is : 143
2016-05-18 09:39:46,986 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000004 is : 143
2016-05-18 09:39:47,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000005 is : 143
2016-05-18 09:39:52,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000007 is : 143
2016-05-18 09:39:54,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-05-18 09:39:54,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0067
2016-05-18 09:39:54,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0067/
2016-05-18 09:40:11,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0067_01_000002 is : 143
2016-05-18 09:40:12,953 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-05-18 09:40:12,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] completed in: 01:24.791, using cpu time: 00:15.470
2016-05-18 09:40:12,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-05-18 09:40:13,028 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:13,028 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 09:40:13,066 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.034
2016-05-18 09:40:13,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 09:40:13,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-05-18 09:40:13,082 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:13,082 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 09:40:13,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:40:13,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:40:13,104 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 09:40:13,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 09:40:13,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:40:13,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-05-18 09:40:13,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 09:40:13,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 09:40:13,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 09:40:13,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-05-18 09:40:13,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463562504321_0068
2016-05-18 09:40:13,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0068/
2016-05-18 09:40:38,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000005 is : 143
2016-05-18 09:40:38,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000003 is : 143
2016-05-18 09:40:38,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000006 is : 143
2016-05-18 09:40:38,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000004 is : 143
2016-05-18 09:40:38,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000002 is : 143
2016-05-18 09:40:40,143 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-05-18 09:40:40,146 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:27.023, using cpu time: 00:05.460
2016-05-18 09:40:40,190 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-05-18 09:40:40,225 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:40,225 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 09:40:40,245 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:40:40,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:40:40,246 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 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting
2016-05-18 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-05-18 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] parallel execution of steps is enabled: true
2016-05-18 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executing total steps: 1
2016-05-18 09:40:40,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] allocating management threads: 1
2016-05-18 09:40:40,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-05-18 09:40:40,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] submitted hadoop job: job_1463562504321_0069
2016-05-18 09:40:40,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0069/
2016-05-18 09:41:04,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000005 is : 143
2016-05-18 09:41:05,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000003 is : 143
2016-05-18 09:41:05,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000002 is : 143
2016-05-18 09:41:05,493 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000006 is : 143
2016-05-18 09:41:05,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000004 is : 143
2016-05-18 09:41:07,122 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-05-18 09:41:07,124 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] completed in: 00:26.866, using cpu time: 00:05.250
2016-05-18 09:41:07,180 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-05-18 09:41:07,205 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:41:07,205 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 09:41:07,236 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 09:41:07,237 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:41:07,237 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 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:41:07,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:41:07,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-05-18 09:41:07,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0070
2016-05-18 09:41:07,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0070/
2016-05-18 09:41:31,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000002 is : 143
2016-05-18 09:41:31,795 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000003 is : 143
2016-05-18 09:41:32,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000006 is : 143
2016-05-18 09:41:32,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000004 is : 143
2016-05-18 09:41:32,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000005 is : 143
2016-05-18 09:41:38,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000007 is : 143
2016-05-18 09:41:39,698 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-05-18 09:41:39,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:32.445, using cpu time: 00:07.380
2016-05-18 09:41:39,733 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-05-18 09:41:39,752 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:41:39,753 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:41:39,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 09:41:39,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 6
2016-05-18 09:41:39,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:41:39,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting
2016-05-18 09:41:39,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:41:39,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink"]
2016-05-18 09:41:39,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] parallel execution of steps is enabled: true
2016-05-18 09:41:39,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] executing total steps: 4
2016-05-18 09:41:39,860 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] allocating management threads: 4
2016-05-18 09:41:39,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (1/4)
2016-05-18 09:41:39,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0071
2016-05-18 09:41:39,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0071/
2016-05-18 09:42:05,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000006 is : 143
2016-05-18 09:42:05,499 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000004 is : 143
2016-05-18 09:42:05,695 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000003 is : 143
2016-05-18 09:42:05,861 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000005 is : 143
2016-05-18 09:42:05,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000002 is : 143
2016-05-18 09:42:12,770 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000007 is : 143
2016-05-18 09:42:13,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (2/4)
2016-05-18 09:42:14,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0072
2016-05-18 09:42:14,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0072/
2016-05-18 09:42:32,172 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0072_01_000002 is : 143
2016-05-18 09:42:33,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (3/4)
2016-05-18 09:42:33,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0073
2016-05-18 09:42:33,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0073/
2016-05-18 09:42:51,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0073_01_000002 is : 143
2016-05-18 09:42:57,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0073_01_000003 is : 143
2016-05-18 09:42:59,080 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (4/4) ...plitSplitGroupByJoin/sink
2016-05-18 09:42:59,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0074
2016-05-18 09:42:59,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0074/
2016-05-18 09:43:16,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0074_01_000002 is : 143
2016-05-18 09:43:17,683 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink/_temporary
2016-05-18 09:43:17,687 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] completed in: 01:37.819, using cpu time: 00:10.940
2016-05-18 09:43:17,717 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink
2016-05-18 09:43:17,734 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:43:17,735 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 09:43:17,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:43:17,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:43:17,757 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 09:43:17,764 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 09:43:17,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:43:17,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-05-18 09:43:17,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 09:43:17,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 09:43:17,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 09:43:17,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-05-18 09:43:17,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463562504321_0075
2016-05-18 09:43:17,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0075/
2016-05-18 09:43:43,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000004 is : 143
2016-05-18 09:43:44,150 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000006 is : 143
2016-05-18 09:43:44,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000005 is : 143
2016-05-18 09:43:44,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000003 is : 143
2016-05-18 09:43:45,531 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-05-18 09:43:45,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:27.764, using cpu time: 00:05.470
2016-05-18 09:43:45,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-05-18 09:43:45,611 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:43:45,612 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 09:43:45,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-05-18 09:43:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 09:43:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:43:45,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting
2016-05-18 09:43:45,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:43:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-05-18 09:43:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] parallel execution of steps is enabled: true
2016-05-18 09:43:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] executing total steps: 4
2016-05-18 09:43:45,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] allocating management threads: 4
2016-05-18 09:43:45,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (1/4)
2016-05-18 09:43:46,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0076
2016-05-18 09:43:46,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0076/
2016-05-18 09:44:11,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000006 is : 143
2016-05-18 09:44:11,101 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000003 is : 143
2016-05-18 09:44:11,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000002 is : 143
2016-05-18 09:44:11,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000004 is : 143
2016-05-18 09:44:12,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000005 is : 143
2016-05-18 09:44:17,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000007 is : 143
2016-05-18 09:44:19,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (2/4)
2016-05-18 09:44:19,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0077
2016-05-18 09:44:19,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0077/
2016-05-18 09:44:36,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0077_01_000002 is : 143
2016-05-18 09:44:43,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0077_01_000003 is : 143
2016-05-18 09:44:44,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (3/4)
2016-05-18 09:44:44,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0078
2016-05-18 09:44:44,879 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0078/
2016-05-18 09:45:02,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0078_01_000002 is : 143
2016-05-18 09:45:10,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0078_01_000003 is : 143
2016-05-18 09:45:11,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-05-18 09:45:11,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0079
2016-05-18 09:45:11,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0079/
2016-05-18 09:45:28,506 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0079_01_000002 is : 143
2016-05-18 09:45:29,724 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-05-18 09:45:29,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] completed in: 01:43.987, using cpu time: 00:12.390
2016-05-18 09:45:29,766 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-05-18 09:45:29,786 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:45:29,786 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 09:45:29,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 09:45:29,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:45:29,812 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 09:45:29,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:45:29,823 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.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 09:45:29,823 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.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 09:45:29,824 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.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-05-18 09:45:29,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:45:29,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:45:29,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:45:29,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-05-18 09:45:29,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0080
2016-05-18 09:45:29,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0080/
2016-05-18 09:45:54,831 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000002 is : 143
2016-05-18 09:45:54,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000003 is : 143
2016-05-18 09:45:55,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000005 is : 143
2016-05-18 09:45:55,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000004 is : 143
2016-05-18 09:45:55,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000006 is : 143
2016-05-18 09:45:56,864 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-05-18 09:45:56,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.039, using cpu time: 00:05.990
2016-05-18 09:45:56,921 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-05-18 09:45:56,947 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:45:56,947 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 09:45:56,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 09:45:56,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:45:56,978 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 09:45:56,990 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:45:56,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:45:56,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:45:56,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-05-18 09:45:56,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 09:45:56,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 09:45:56,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 09:45:56,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-05-18 09:45:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0081
2016-05-18 09:45:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0081/
2016-05-18 09:46:22,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000003 is : 143
2016-05-18 09:46:22,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000004 is : 143
2016-05-18 09:46:22,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000005 is : 143
2016-05-18 09:46:23,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000002 is : 143
2016-05-18 09:46:24,276 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-05-18 09:46:24,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:27.284, using cpu time: 00:05.810
2016-05-18 09:46:24,320 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields