Test results - Class cascading.MergePipesPlatformTest\nall > cascading > MergePipesPlatformTest\ntestHashJoinMergeIntoHashJoinAccumulated 48.061s passed\ntestHashJoinMergeIntoHashJoinAccumulatedAccumulated 1m12.11s passed\ntestHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 1m12.48s passed\ntestHashJoinMergeIntoHashJoinAccumulatedStreamed 1m11.65s passed\ntestHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 1m9.55s passed\ntestHashJoinMergeIntoHashJoinStreamed 45.097s passed\ntestHashJoinMergeIntoHashJoinStreamedAccumulated 1m11.52s passed\ntestHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 1m15.12s passed\ntestHashJoinMergeIntoHashJoinStreamedStreamed 48.511s passed\ntestHashJoinMergeIntoHashJoinStreamedStreamedMerge 1m20.64s passed\ntestMergeIntoHashJoinAccumulated 45.378s passed\ntestMergeIntoHashJoinStreamed 24.841s passed\ntestSameSourceMergeThreeChainGroup 1m3.08s passed\ntestSimpleMerge 34.253s passed\ntestSimpleMergeFail 0.024s passed\ntestSimpleMergeThree 30.060s passed\ntestSimpleMergeThreeChain 27.147s passed\ntestSimpleMergeThreeChainCoGroup 38.210s passed\ntestSimpleMergeThreeChainGroup 39.456s passed\ntestSplitSameSourceMerged 21.427s passed\ntestSplitSameSourceMergedComplex 21.074s passed\n2015-08-13 17:57:32,579 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath\n2015-08-13 17:57:32,629 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop\n2015-08-13 17:57:32,630 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest\n2015-08-13 17:57:32,670 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(128)) - using cluster\n2015-08-13 17:57:33,572 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-namenode.properties, hadoop-metrics2.properties\n2015-08-13 17:57:34,642 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties\n2015-08-13 17:57:34,643 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control\n2015-08-13 17:57:40,107 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties\n2015-08-13 17:57:40,108 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control\n2015-08-13 17:57:40,184 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo\n2015-08-13 17:57:40,515 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties\n2015-08-13 17:57:40,516 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control\n2015-08-13 17:57:40,590 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo\n2015-08-13 17:57:40,872 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-datanode.properties, hadoop-metrics2.properties\n2015-08-13 17:57:40,873 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=MetricsSystem,sub=Control\n2015-08-13 17:57:40,951 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=DataNode,name=DataNodeInfo\n2015-08-13 17:57:41,301 WARN  impl.MetricsSystemImpl (MetricsSystemImpl.java:init(137)) - Metrics system not started: Cannot locate configuration: tried hadoop-metrics2-jobtracker.properties, hadoop-metrics2.properties\n2015-08-13 17:57:41,302 WARN  util.MBeans (MBeans.java:register(59)) - Hadoop:service=JobTracker,name=MetricsSystem,sub=Control\n2015-08-13 17:57:42,285 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable\n2015-08-13 17:57:42,368 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.\n2015-08-13 17:57:42,664 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.\n2015-08-13 17:57:42,939 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.\n2015-08-13 17:57:43,203 WARN  mapred.TaskTracker (TaskTracker.java:setTaskMemoryManagerEnabledFlag(4162)) - TaskTracker's totalMemoryAllottedForTasks is -1. TaskMemoryManager is disabled.\n2015-08-13 17:57:43,473 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:\n2015-08-13 17:57:43,594 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 17:57:43,595 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 17:57:43,607 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 3FC44EE8C1644D95A0C45B719FD53928\n2015-08-13 17:57:43,788 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1\n2015-08-13 17:57:43,789 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting\n2015-08-13 17:57:43,790 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 17:57:43,790 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 17:57:43,791 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemerge"]\n2015-08-13 17:57:43,791 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true\n2015-08-13 17:57:43,791 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1\n2015-08-13 17:57:43,792 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1\n2015-08-13 17:57:43,793 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge\n2015-08-13 17:57:44,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813175741247_0001\n2015-08-13 17:57:44,135 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0001\n2015-08-13 17:58:06,793 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemerge/_temporary\n2015-08-13 17:58:06,894 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemerge\n2015-08-13 17:58:06,973 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 17:58:06,974 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 17:58:07,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting\n2015-08-13 17:58:07,154 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 17:58:07,154 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 17:58:07,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 17:58:07,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]\n2015-08-13 17:58:07,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true\n2015-08-13 17:58:07,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3\n2015-08-13 17:58:07,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3\n2015-08-13 17:58:07,157 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)\n2015-08-13 17:58:07,472 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0001 being deleted.\n2015-08-13 17:58:07,692 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:07,743 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0002\n2015-08-13 17:58:07,743 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0002\n2015-08-13 17:58:08,160 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:08,223 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:08,348 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:08,503 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:08,678 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:31,271 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)\n2015-08-13 17:58:31,488 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0002 being deleted.\n2015-08-13 17:58:31,805 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0003\n2015-08-13 17:58:31,806 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0003\n2015-08-13 17:58:32,133 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:32,440 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:34,001 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:34,767 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:35,080 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:35,368 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:55,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge\n2015-08-13 17:58:55,504 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0003 being deleted.\n2015-08-13 17:58:55,758 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:55,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0004\n2015-08-13 17:58:55,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0004\n2015-08-13 17:58:56,606 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:58,017 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:58,807 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:59,224 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:58:59,253 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:19,366 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary\n2015-08-13 17:59:19,391 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge\n2015-08-13 17:59:19,429 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 17:59:19,429 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 17:59:19,519 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0004 being deleted.\n2015-08-13 17:59:19,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting\n2015-08-13 17:59:19,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 17:59:19,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 17:59:19,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 17:59:19,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]\n2015-08-13 17:59:19,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true\n2015-08-13 17:59:19,555 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3\n2015-08-13 17:59:19,555 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3\n2015-08-13 17:59:19,557 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)\n2015-08-13 17:59:19,952 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:20,080 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0005\n2015-08-13 17:59:20,081 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0005\n2015-08-13 17:59:20,318 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:22,046 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:22,658 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:23,138 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:23,143 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:43,405 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)\n2015-08-13 17:59:43,531 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0005 being deleted.\n2015-08-13 17:59:43,628 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0006\n2015-08-13 17:59:43,628 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0006\n2015-08-13 17:59:44,254 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:44,792 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:46,073 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:46,839 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:47,210 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 17:59:47,443 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:10,597 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge\n2015-08-13 18:00:11,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0007\n2015-08-13 18:00:11,121 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0007\n2015-08-13 18:00:11,313 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:11,785 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:13,112 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:13,203 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:13,575 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:13,956 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:14,232 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:14,656 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:39,992 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary\n2015-08-13 18:00:40,025 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge\n2015-08-13 18:00:40,067 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:00:40,068 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:00:40,094 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting\n2015-08-13 18:00:40,094 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:00:40,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:00:40,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:00:40,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethree"]\n2015-08-13 18:00:40,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true\n2015-08-13 18:00:40,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1\n2015-08-13 18:00:40,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1\n2015-08-13 18:00:40,097 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree\n2015-08-13 18:00:40,233 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_20150813175741247_0008\n2015-08-13 18:00:40,233 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0008\n2015-08-13 18:00:40,244 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:40,299 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:40,410 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:40,801 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:40,874 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:41,061 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:41,245 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:00:41,329 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:10,055 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethree/_temporary\n2015-08-13 18:01:10,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemergethree\n2015-08-13 18:01:10,132 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:01:10,132 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:01:10,197 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting\n2015-08-13 18:01:10,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:01:10,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:01:10,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:01:10,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]\n2015-08-13 18:01:10,199 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  parallel execution is enabled: true\n2015-08-13 18:01:10,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  starting jobs: 2\n2015-08-13 18:01:10,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  allocating threads: 2\n2015-08-13 18:01:10,202 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)\n2015-08-13 18:01:10,221 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:10,247 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:10,734 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813175741247_0009\n2015-08-13 18:01:10,735 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0009\n2015-08-13 18:01:10,792 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:10,934 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:11,174 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:11,217 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:11,218 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:11,640 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:34,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge\n2015-08-13 18:01:34,224 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_20150813175741247_0010\n2015-08-13 18:01:34,224 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0010\n2015-08-13 18:01:34,649 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0009 being deleted.\n2015-08-13 18:01:34,990 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:35,139 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:35,250 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:35,618 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:35,794 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:35,860 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:58,581 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary\n2015-08-13 18:01:58,605 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge\n2015-08-13 18:01:58,640 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:01:58,641 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:01:58,661 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0010 being deleted.\n2015-08-13 18:01:58,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting\n2015-08-13 18:01:58,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:01:58,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:01:58,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:01:58,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechain"]\n2015-08-13 18:01:58,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true\n2015-08-13 18:01:58,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1\n2015-08-13 18:01:58,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1\n2015-08-13 18:01:58,674 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain\n2015-08-13 18:01:58,919 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:59,232 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813175741247_0011\n2015-08-13 18:01:59,232 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0011\n2015-08-13 18:01:59,539 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:59,792 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:01:59,853 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:01,297 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:01,932 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:25,717 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechain/_temporary\n2015-08-13 18:02:25,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemergethreechain\n2015-08-13 18:02:25,790 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:02:25,791 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:02:25,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting\n2015-08-13 18:02:25,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:02:25,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:02:25,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:02:25,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]\n2015-08-13 18:02:25,868 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true\n2015-08-13 18:02:25,868 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3\n2015-08-13 18:02:25,869 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3\n2015-08-13 18:02:25,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)\n2015-08-13 18:02:25,989 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0012\n2015-08-13 18:02:25,990 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0012\n2015-08-13 18:02:26,318 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:26,969 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:28,524 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:28,782 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:29,020 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:29,026 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:29,103 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:29,235 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:49,676 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)\n2015-08-13 18:02:49,724 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0012 being deleted.\n2015-08-13 18:02:49,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0013\n2015-08-13 18:02:49,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0013\n2015-08-13 18:02:50,027 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:51,254 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:52,344 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:53,354 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:54,082 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:02:54,136 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:14,117 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0013 being deleted.\n2015-08-13 18:03:14,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge\n2015-08-13 18:03:14,255 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0014\n2015-08-13 18:03:14,255 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0014\n2015-08-13 18:03:14,718 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:15,114 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:16,375 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:17,149 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:17,804 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:18,043 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:37,256 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary\n2015-08-13 18:03:37,278 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge\n2015-08-13 18:03:37,321 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:03:37,321 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:03:37,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting\n2015-08-13 18:03:37,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]\n2015-08-13 18:03:37,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/splitsourcemerged"]\n2015-08-13 18:03:37,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true\n2015-08-13 18:03:37,343 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1\n2015-08-13 18:03:37,343 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1\n2015-08-13 18:03:37,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged\n2015-08-13 18:03:37,454 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813175741247_0015\n2015-08-13 18:03:37,455 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0015\n2015-08-13 18:03:37,823 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:38,133 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0014 being deleted.\n2015-08-13 18:03:38,165 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:38,577 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:39,104 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:58,687 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/splitsourcemerged/_temporary\n2015-08-13 18:03:58,707 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/splitsourcemerged\n2015-08-13 18:03:58,735 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:03:58,736 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:03:58,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting\n2015-08-13 18:03:58,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 2\n2015-08-13 18:03:58,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 2\n2015-08-13 18:03:58,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)\n2015-08-13 18:03:58,877 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:58,901 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:58,909 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813175741247_0016\n2015-08-13 18:03:58,909 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0016\n2015-08-13 18:03:59,317 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:03:59,349 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:00,008 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:00,015 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:20,199 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed\n2015-08-13 18:04:20,347 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813175741247_0017\n2015-08-13 18:04:20,348 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0017\n2015-08-13 18:04:20,787 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:21,046 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:21,100 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:21,605 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:22,705 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0016 being deleted.\n2015-08-13 18:04:22,861 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:23,480 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:43,776 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary\n2015-08-13 18:04:43,801 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinstreamed\n2015-08-13 18:04:43,830 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:04:43,831 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:04:43,839 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemergefail\n2015-08-13 18:04:43,856 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:04:43,856 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:04:43,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup"]\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true\n2015-08-13 18:04:43,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1\n2015-08-13 18:04:43,896 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1\n2015-08-13 18:04:43,896 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup\n2015-08-13 18:04:44,213 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0017 being deleted.\n2015-08-13 18:04:44,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813175741247_0018\n2015-08-13 18:04:44,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0018\n2015-08-13 18:04:44,660 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:44,851 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:44,928 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:45,160 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:45,562 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:04:45,756 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:23,236 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechaingroup/_temporary\n2015-08-13 18:05:23,291 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemergethreechaingroup\n2015-08-13 18:05:23,314 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:05:23,314 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:05:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting\n2015-08-13 18:05:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:05:23,387 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:05:23,387 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:05:23,388 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]\n2015-08-13 18:05:23,388 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true\n2015-08-13 18:05:23,389 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3\n2015-08-13 18:05:23,389 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3\n2015-08-13 18:05:23,392 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)\n2015-08-13 18:05:23,465 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:23,505 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0019\n2015-08-13 18:05:23,506 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0019\n2015-08-13 18:05:23,569 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:24,444 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:24,470 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:24,519 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:24,645 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:24,848 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:25,966 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:26,641 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:47,285 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)\n2015-08-13 18:05:47,295 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0019 being deleted.\n2015-08-13 18:05:47,792 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0020\n2015-08-13 18:05:47,793 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0020\n2015-08-13 18:05:48,315 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:48,601 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:49,991 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:50,788 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:51,774 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:05:51,833 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:11,330 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0020 being deleted.\n2015-08-13 18:06:11,332 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge\n2015-08-13 18:06:11,439 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_20150813175741247_0021\n2015-08-13 18:06:11,439 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0021\n2015-08-13 18:06:11,921 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:12,521 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:14,011 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:14,578 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:15,342 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:15,408 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:34,904 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary\n2015-08-13 18:06:34,934 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge\n2015-08-13 18:06:34,963 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:06:34,964 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:06:34,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting\n2015-08-13 18:06:34,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:06:34,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:06:34,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:06:34,989 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed"]\n2015-08-13 18:06:34,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true\n2015-08-13 18:06:34,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1\n2015-08-13 18:06:34,990 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1\n2015-08-13 18:06:34,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed\n2015-08-13 18:06:35,342 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0021 being deleted.\n2015-08-13 18:06:35,506 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813175741247_0022\n2015-08-13 18:06:35,506 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0022\n2015-08-13 18:06:35,824 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:36,068 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:36,286 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:36,342 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:36,414 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:06:59,738 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0022 being deleted.\n2015-08-13 18:06:59,742 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinstreamed/_temporary\n2015-08-13 18:06:59,772 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinstreamed\n2015-08-13 18:06:59,805 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:06:59,806 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:06:59,832 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting\n2015-08-13 18:06:59,832 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup"]\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1\n2015-08-13 18:06:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1\n2015-08-13 18:06:59,835 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup\n2015-08-13 18:06:59,957 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_20150813175741247_0023\n2015-08-13 18:06:59,957 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0023\n2015-08-13 18:07:00,202 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:00,562 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:00,665 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:00,722 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:02,083 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:02,826 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:37,979 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/simplemergethreechaincogroup/_temporary\n2015-08-13 18:07:37,994 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/simplemergethreechaincogroup\n2015-08-13 18:07:38,016 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:07:38,017 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:07:38,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting\n2015-08-13 18:07:38,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:07:38,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup"]\n2015-08-13 18:07:38,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true\n2015-08-13 18:07:38,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 2\n2015-08-13 18:07:38,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 2\n2015-08-13 18:07:38,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)\n2015-08-13 18:07:38,152 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:38,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813175741247_0024\n2015-08-13 18:07:38,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0024\n2015-08-13 18:07:38,782 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:38,862 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,007 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,032 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,116 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,134 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,160 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:07:39,177 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:08,823 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup\n2015-08-13 18:08:09,345 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_20150813175741247_0025\n2015-08-13 18:08:09,346 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0025\n2015-08-13 18:08:09,507 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:09,703 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:10,045 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:10,222 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:10,996 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0024 being deleted.\n2015-08-13 18:08:12,899 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:12,933 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:41,058 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/samemergethreechaingroup/_temporary\n2015-08-13 18:08:41,073 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/samemergethreechaingroup\n2015-08-13 18:08:41,098 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:08:41,099 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:08:41,178 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting\n2015-08-13 18:08:41,179 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:08:41,179 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:08:41,179 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:08:41,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]\n2015-08-13 18:08:41,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true\n2015-08-13 18:08:41,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3\n2015-08-13 18:08:41,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3\n2015-08-13 18:08:41,182 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)\n2015-08-13 18:08:41,624 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:41,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0026\n2015-08-13 18:08:41,699 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0026\n2015-08-13 18:08:41,720 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:41,852 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0025 being deleted.\n2015-08-13 18:08:42,000 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:42,411 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:43,001 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:43,040 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:08:43,055 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:02,893 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)\n2015-08-13 18:09:03,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0027\n2015-08-13 18:09:03,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0027\n2015-08-13 18:09:03,422 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:04,285 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:05,069 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0026 being deleted.\n2015-08-13 18:09:06,789 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:06,934 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:07,172 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:07,264 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:26,522 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge\n2015-08-13 18:09:26,807 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:26,903 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0027 being deleted.\n2015-08-13 18:09:27,039 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_20150813175741247_0028\n2015-08-13 18:09:27,039 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0028\n2015-08-13 18:09:27,523 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:28,007 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:28,104 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:28,124 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:28,191 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:50,592 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary\n2015-08-13 18:09:50,616 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge\n2015-08-13 18:09:50,647 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:09:50,647 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:09:50,676 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting\n2015-08-13 18:09:50,676 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:09:50,676 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:09:50,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:09:50,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated"]\n2015-08-13 18:09:50,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true\n2015-08-13 18:09:50,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2\n2015-08-13 18:09:50,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2\n2015-08-13 18:09:50,680 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)\n2015-08-13 18:09:50,793 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813175741247_0029\n2015-08-13 18:09:50,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0029\n2015-08-13 18:09:50,924 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0028 being deleted.\n2015-08-13 18:09:51,045 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:51,510 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:52,056 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:52,092 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:52,164 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:09:52,257 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:11,936 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated\n2015-08-13 18:10:12,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:12,475 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813175741247_0030\n2015-08-13 18:10:12,476 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0030\n2015-08-13 18:10:13,130 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:13,139 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:13,349 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:14,590 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0029 being deleted.\n2015-08-13 18:10:15,841 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:16,002 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:35,971 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0030 being deleted.\n2015-08-13 18:10:35,977 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/mergeintohashjoinaccumulated/_temporary\n2015-08-13 18:10:35,998 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/mergeintohashjoinaccumulated\n2015-08-13 18:10:36,026 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:10:36,027 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:10:36,052 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting\n2015-08-13 18:10:36,052 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]\n2015-08-13 18:10:36,052 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex"]\n2015-08-13 18:10:36,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true\n2015-08-13 18:10:36,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1\n2015-08-13 18:10:36,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1\n2015-08-13 18:10:36,054 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex\n2015-08-13 18:10:36,177 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_20150813175741247_0031\n2015-08-13 18:10:36,179 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0031\n2015-08-13 18:10:36,441 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:37,083 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:38,777 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:39,486 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:39,873 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:39,899 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:57,012 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/splitsourcemergedcomplex/_temporary\n2015-08-13 18:10:57,073 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/splitsourcemergedcomplex\n2015-08-13 18:10:57,102 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:10:57,102 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:10:57,143 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting\n2015-08-13 18:10:57,143 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:10:57,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:10:57,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:10:57,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]\n2015-08-13 18:10:57,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true\n2015-08-13 18:10:57,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2\n2015-08-13 18:10:57,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2\n2015-08-13 18:10:57,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)\n2015-08-13 18:10:57,267 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813175741247_0032\n2015-08-13 18:10:57,267 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0032\n2015-08-13 18:10:57,591 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:58,035 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:10:59,796 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:00,345 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:00,987 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:01,079 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:21,033 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0032 being deleted.\n2015-08-13 18:11:21,035 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated\n2015-08-13 18:11:21,137 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_20150813175741247_0033\n2015-08-13 18:11:21,137 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0033\n2015-08-13 18:11:22,099 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:22,319 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:23,817 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:24,621 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:25,297 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:25,327 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:45,105 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0033 being deleted.\n2015-08-13 18:11:45,111 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary\n2015-08-13 18:11:45,133 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated\n2015-08-13 18:11:45,170 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:11:45,170 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:11:45,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting\n2015-08-13 18:11:45,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:11:45,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:11:45,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:11:45,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]\n2015-08-13 18:11:45,240 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  parallel execution is enabled: true\n2015-08-13 18:11:45,241 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  starting jobs: 3\n2015-08-13 18:11:45,241 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  allocating threads: 3\n2015-08-13 18:11:45,245 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)\n2015-08-13 18:11:45,629 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:45,763 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813175741247_0034\n2015-08-13 18:11:45,764 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0034\n2015-08-13 18:11:46,000 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:46,032 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:46,093 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:11:46,171 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:09,191 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)\n2015-08-13 18:12:09,702 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813175741247_0035\n2015-08-13 18:12:09,702 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0035\n2015-08-13 18:12:10,340 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:10,650 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:12,167 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0034 being deleted.\n2015-08-13 18:12:12,515 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:13,167 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:13,527 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:13,582 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:33,206 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge\n2015-08-13 18:12:33,367 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0035 being deleted.\n2015-08-13 18:12:33,728 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_20150813175741247_0036\n2015-08-13 18:12:33,728 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0036\n2015-08-13 18:12:33,811 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:34,493 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:36,330 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:37,001 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:37,341 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:37,493 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:57,221 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary\n2015-08-13 18:12:57,243 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge\n2015-08-13 18:12:57,279 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster\n2015-08-13 18:12:57,280 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar\n2015-08-13 18:12:57,350 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting\n2015-08-13 18:12:57,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]\n2015-08-13 18:12:57,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]\n2015-08-13 18:12:57,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower-offset.txt"]\n2015-08-13 18:12:57,352 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]\n2015-08-13 18:12:57,353 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true\n2015-08-13 18:12:57,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3\n2015-08-13 18:12:57,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3\n2015-08-13 18:12:57,357 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)\n2015-08-13 18:12:57,381 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0036 being deleted.\n2015-08-13 18:12:57,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0037\n2015-08-13 18:12:57,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0037\n2015-08-13 18:12:58,138 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:58,210 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:58,317 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:58,347 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:12:58,352 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:21,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)\n2015-08-13 18:13:22,194 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0038\n2015-08-13 18:13:22,194 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0038\n2015-08-13 18:13:22,233 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:22,654 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:22,733 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:22,797 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:24,234 WARN  mapred.TaskTracker (TaskTracker.java:purgeJob(1993)) - Unknown job job_20150813175741247_0037 being deleted.\n2015-08-13 18:13:25,434 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:25,513 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:48,282 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge\n2015-08-13 18:13:48,430 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:48,499 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:48,545 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:48,832 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_20150813175741247_0039\n2015-08-13 18:13:48,833 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://localhost:50250/jobdetails.jsp?jobid=job_20150813175741247_0039\n2015-08-13 18:13:48,940 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:49,145 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:49,218 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:49,357 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:13:49,529 WARN  mapred.DefaultTaskController (DefaultTaskController.java:launchTask(137)) - Exit code from task is : 143\n2015-08-13 18:14:12,342 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary\n2015-08-13 18:14:12,364 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge\nGenerated by Gradle 1.9 at Aug 13, 2015 7:43:38 PM