Class cascading.FieldedPipesPlatformTest

all > cascading > FieldedPipesPlatformTest

tests

failures

ignored

27m54.56s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testChainEndingWithEach	42.773s	passed
testChainedTaps	1m57.13s	passed
testConcatenation	49.558s	passed
testCopy	40.244s	passed
testFilter	27.171s	passed
testFilterAll	1m14.14s	passed
testFilterComplex	1m41.75s	passed
testGeneratorAggregator	37.319s	passed
testGroupByInsensitive	59.185s	passed
testGroupGroup	1m11.56s	passed
testLogicFilter	28.213s	passed
testNoGroup	36.611s	passed
testNone	34.573s	passed
testReplace	28.566s	passed
testSameSourceMergeThreeChainGroup	1m34.15s	passed
testSimpleChain	49.412s	passed
testSimpleGroup	41.162s	passed
testSimpleMerge	58.832s	passed
testSimpleMergeThree	1m6.81s	passed
testSplit	1m23.40s	passed
testSplitComplex	1m8.45s	passed
testSplitNonSafe	1m34.57s	passed
testSplitOut	1m16.43s	passed
testSplitSameSourceMerged	1m10.28s	passed
testSplitSameSourceMergedSameName	1m23.18s	passed
testSwap	36.224s	passed
testUnGroup	32.968s	passed
testUnGroupAnon	41.734s	passed
testUnGroupBySize	28.175s	passed

Standard output

2015-08-12 07:48:00,007 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-12 07:48:00,061 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-12 07:48:00,062 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-08-12 07:48:00,105 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-12 07:48:01,640 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-12 07:48:02,272 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 07:48:09,560 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 07:48:09,783 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 07:48:10,037 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 07:48:10,356 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 07:48:27,611 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-12 07:48:27,944 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:48:27,951 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:48:27,979 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 3D55E12E15464D108367B375BC42F925
2015-08-12 07:48:28,495 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-12 07:48:28,505 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 07:48:28,507 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:48:28,508 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-08-12 07:48:28,510 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 07:48:28,511 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 07:48:28,512 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 07:48:28,513 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-08-12 07:48:29,958 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0001
2015-08-12 07:48:29,958 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0001/
2015-08-12 07:49:39,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0001_01_000006 is : 143
2015-08-12 07:49:41,659 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-08-12 07:49:41,830 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-08-12 07:49:41,949 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:49:41,951 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:49:42,044 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 07:49:42,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:49:42,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-08-12 07:49:42,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 07:49:42,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 07:49:42,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 07:49:42,049 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-08-12 07:49:42,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0002
2015-08-12 07:49:42,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0002/
2015-08-12 07:50:21,502 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0002_01_000004 is : 143
2015-08-12 07:50:21,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0002_01_000005 is : 143
2015-08-12 07:50:22,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0002_01_000003 is : 143
2015-08-12 07:50:29,848 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0002_01_000006 is : 143
2015-08-12 07:50:31,193 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-08-12 07:50:31,252 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-08-12 07:50:31,377 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:50:31,378 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:50:31,413 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 07:50:31,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:50:31,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-08-12 07:50:31,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 07:50:31,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 07:50:31,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 07:50:31,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-08-12 07:50:31,704 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0003
2015-08-12 07:50:31,705 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0003/
2015-08-12 07:51:01,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0003_01_000002 is : 143
2015-08-12 07:51:02,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0003_01_000005 is : 143
2015-08-12 07:51:10,720 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0003_01_000006 is : 143
2015-08-12 07:51:12,143 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-08-12 07:51:12,411 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-08-12 07:51:12,534 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:51:12,537 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:51:12,563 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-12 07:51:12,564 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 07:51:12,564 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 07:51:12,564 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-08-12 07:51:12,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-08-12 07:51:12,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-08-12 07:51:12,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-08-12 07:51:12,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-12 07:51:12,815 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439390902080_0004
2015-08-12 07:51:12,817 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0004/
2015-08-12 07:52:01,899 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0004_01_000007 is : 143
2015-08-12 07:52:02,979 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0004_01_000005 is : 143
2015-08-12 07:52:03,129 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0004_01_000006 is : 143
2015-08-12 07:52:09,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0004_01_000008 is : 143
2015-08-12 07:52:11,178 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-08-12 07:52:11,253 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-08-12 07:52:11,694 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:52:11,695 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:52:11,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 07:52:11,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:52:11,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-08-12 07:52:11,730 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 07:52:11,731 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 07:52:11,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 07:52:11,734 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-08-12 07:52:12,004 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0005
2015-08-12 07:52:12,005 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0005/
2015-08-12 07:52:43,497 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0005_01_000005 is : 143
2015-08-12 07:52:44,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0005_01_000003 is : 143
2015-08-12 07:52:44,324 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0005_01_000004 is : 143
2015-08-12 07:52:52,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0005_01_000006 is : 143
2015-08-12 07:52:53,959 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-08-12 07:52:54,015 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-08-12 07:52:54,083 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:52:54,084 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:52:54,115 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 07:52:54,115 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:52:54,116 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-08-12 07:52:54,120 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 07:52:54,121 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 07:52:54,121 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 07:52:54,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-08-12 07:52:54,513 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0006
2015-08-12 07:52:54,514 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0006/
2015-08-12 07:53:21,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0006_01_000004 is : 143
2015-08-12 07:53:22,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0006_01_000003 is : 143
2015-08-12 07:53:22,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0006_01_000002 is : 143
2015-08-12 07:53:30,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0006_01_000006 is : 143
2015-08-12 07:53:31,316 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-08-12 07:53:31,345 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-08-12 07:53:31,428 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:53:31,433 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:53:31,476 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-12 07:53:31,477 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 07:53:31,477 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 07:53:31,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 07:53:31,480 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-08-12 07:53:31,483 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-08-12 07:53:31,483 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-08-12 07:53:31,484 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-08-12 07:53:31,486 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-12 07:53:31,732 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439390902080_0007
2015-08-12 07:53:31,733 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0007/
2015-08-12 07:54:28,286 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0007_01_000003 is : 143
2015-08-12 07:54:29,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0007_01_000005 is : 143
2015-08-12 07:54:29,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0007_01_000004 is : 143
2015-08-12 07:54:29,840 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0007_01_000008 is : 143
2015-08-12 07:54:30,016 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0007_01_000009 is : 143
2015-08-12 07:54:38,104 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-08-12 07:54:38,155 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-08-12 07:54:38,209 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:54:38,210 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:54:38,318 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-12 07:54:38,319 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:54:38,319 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-08-12 07:54:38,320 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-08-12 07:54:38,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-08-12 07:54:38,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-08-12 07:54:38,323 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-08-12 07:54:38,331 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-12 07:54:38,619 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0008
2015-08-12 07:54:38,620 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0008/
2015-08-12 07:55:10,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0008_01_000002 is : 143
2015-08-12 07:55:10,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0008_01_000004 is : 143
2015-08-12 07:55:11,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0008_01_000003 is : 143
2015-08-12 07:55:12,897 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit1
2015-08-12 07:55:12,898 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit2
2015-08-12 07:55:13,104 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 07:55:13,107 WARN  protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 07:55:13,111 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable:  unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 07:55:13,148 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 07:55:13,148 WARN  protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 07:55:13,149 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable:  unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 07:55:13,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0009
2015-08-12 07:55:13,365 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0009/
2015-08-12 07:55:13,370 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0010
2015-08-12 07:55:13,372 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0010/
2015-08-12 07:56:09,363 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0010_01_000004 is : 143
2015-08-12 07:56:10,958 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0010_01_000003 is : 143
2015-08-12 07:56:11,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0010_01_000002 is : 143
2015-08-12 07:56:12,643 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-08-12 07:56:12,645 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-08-12 07:56:12,712 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-08-12 07:56:12,727 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-08-12 07:56:12,759 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:56:12,760 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:56:12,789 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-08-12 07:56:12,790 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:56:12,792 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-08-12 07:56:12,793 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-08-12 07:56:12,796 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  parallel execution is enabled: true
2015-08-12 07:56:12,796 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  starting jobs: 3
2015-08-12 07:56:12,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  allocating threads: 3
2015-08-12 07:56:12,810 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-08-12 07:56:13,034 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439390902080_0011
2015-08-12 07:56:13,035 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0011/
2015-08-12 07:56:42,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0011_01_000005 is : 143
2015-08-12 07:56:43,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0011_01_000003 is : 143
2015-08-12 07:56:43,533 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0011_01_000002 is : 143
2015-08-12 07:56:43,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0011_01_000004 is : 143
2015-08-12 07:56:50,677 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0011_01_000006 is : 143
2015-08-12 07:56:51,984 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-08-12 07:56:51,983 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-08-12 07:56:52,280 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439390902080_0013
2015-08-12 07:56:52,281 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0013/
2015-08-12 07:56:52,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439390902080_0012
2015-08-12 07:56:52,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0012/
2015-08-12 07:57:12,199 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0013_01_000002 is : 143
2015-08-12 07:57:17,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0012_01_000002 is : 143
2015-08-12 07:57:27,693 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0012_01_000003 is : 143
2015-08-12 07:57:29,044 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-08-12 07:57:29,046 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-08-12 07:57:29,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-08-12 07:57:29,159 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-08-12 07:57:29,192 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:57:29,195 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:57:29,224 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-12 07:57:29,224 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:57:29,225 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-08-12 07:57:29,225 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-08-12 07:57:29,226 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-08-12 07:57:29,226 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 2
2015-08-12 07:57:29,226 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 2
2015-08-12 07:57:29,231 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split1
2015-08-12 07:57:29,234 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split2
2015-08-12 07:57:29,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0014
2015-08-12 07:57:29,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0014/
2015-08-12 07:57:29,615 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0015
2015-08-12 07:57:29,616 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0015/
2015-08-12 07:58:06,854 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0014_01_000003 is : 143
2015-08-12 07:58:14,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0014_01_000004 is : 143
2015-08-12 07:58:46,368 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0015_01_000003 is : 143
2015-08-12 07:58:49,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0015_01_000004 is : 143
2015-08-12 07:58:49,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0015_01_000002 is : 143
2015-08-12 07:58:52,395 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-08-12 07:58:52,402 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-08-12 07:58:52,507 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-08-12 07:58:52,539 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-08-12 07:58:52,672 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 07:58:52,691 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 07:58:52,791 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-12 07:58:52,792 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 07:58:52,794 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-08-12 07:58:52,801 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-08-12 07:58:52,802 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-08-12 07:58:52,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-08-12 07:58:52,827 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-12 07:58:53,075 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439390902080_0016
2015-08-12 07:58:53,076 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0016/
2015-08-12 07:59:19,729 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0016_01_000005 is : 143
2015-08-12 07:59:20,190 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0016_01_000004 is : 143
2015-08-12 07:59:20,304 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0016_01_000002 is : 143
2015-08-12 07:59:20,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0016_01_000003 is : 143
2015-08-12 07:59:21,761 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-08-12 07:59:21,981 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439390902080_0017
2015-08-12 07:59:21,981 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0017/
2015-08-12 07:59:50,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0017_01_000003 is : 143
2015-08-12 07:59:50,749 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0017_01_000005 is : 143
2015-08-12 07:59:50,964 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0017_01_000002 is : 143
2015-08-12 08:00:01,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0017_01_000006 is : 143
2015-08-12 08:00:02,798 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-08-12 08:00:02,833 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-08-12 08:00:02,881 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:00:02,883 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:00:02,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:00:02,896 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:00:02,896 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-08-12 08:00:02,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:00:02,903 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:00:02,903 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:00:02,906 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-08-12 08:00:03,155 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0018
2015-08-12 08:00:03,156 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0018/
2015-08-12 08:00:41,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0018_01_000004 is : 143
2015-08-12 08:00:41,272 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0018_01_000003 is : 143
2015-08-12 08:00:42,878 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-08-12 08:00:42,990 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-08-12 08:00:43,167 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:00:43,169 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:00:43,206 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:00:43,210 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:00:43,214 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-08-12 08:00:43,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:00:43,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:00:43,219 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:00:43,222 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-08-12 08:00:43,525 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0019
2015-08-12 08:00:43,526 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0019/
2015-08-12 08:01:08,415 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0019_01_000003 is : 143
2015-08-12 08:01:08,886 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0019_01_000002 is : 143
2015-08-12 08:01:10,119 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0019_01_000004 is : 143
2015-08-12 08:01:10,535 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0019_01_000005 is : 143
2015-08-12 08:01:17,615 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-08-12 08:01:17,648 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-08-12 08:01:17,682 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:01:17,683 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:01:17,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:01:17,706 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:01:17,707 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-08-12 08:01:17,708 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:01:17,709 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:01:17,710 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:01:17,721 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-08-12 08:01:17,944 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0020
2015-08-12 08:01:17,945 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0020/
2015-08-12 08:01:44,846 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0020_01_000002 is : 143
2015-08-12 08:01:45,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0020_01_000004 is : 143
2015-08-12 08:01:45,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0020_01_000003 is : 143
2015-08-12 08:01:45,542 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0020_01_000005 is : 143
2015-08-12 08:01:52,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0020_01_000006 is : 143
2015-08-12 08:01:53,844 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-08-12 08:01:53,875 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-08-12 08:01:53,919 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:01:53,921 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:01:53,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:01:53,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:01:53,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-08-12 08:01:53,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:01:53,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:01:53,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:01:53,943 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-08-12 08:01:54,167 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0021
2015-08-12 08:01:54,168 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0021/
2015-08-12 08:02:20,712 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0021_01_000005 is : 143
2015-08-12 08:02:22,028 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-08-12 08:02:22,078 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-08-12 08:02:22,181 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:02:22,182 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:02:22,221 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:02:22,222 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 08:02:22,223 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-08-12 08:02:22,225 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:02:22,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:02:22,235 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:02:22,246 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-08-12 08:02:22,469 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0022
2015-08-12 08:02:22,478 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0022/
2015-08-12 08:02:50,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0022_01_000006 is : 143
2015-08-12 08:02:54,967 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-08-12 08:02:55,044 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-08-12 08:02:55,097 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:02:55,098 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:02:55,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-12 08:02:55,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:02:55,143 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-08-12 08:02:55,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-08-12 08:02:55,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-08-12 08:02:55,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  parallel execution is enabled: true
2015-08-12 08:02:55,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  starting jobs: 3
2015-08-12 08:02:55,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  allocating threads: 3
2015-08-12 08:02:55,151 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-08-12 08:02:55,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439390902080_0023
2015-08-12 08:02:55,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0023/
2015-08-12 08:03:21,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0023_01_000002 is : 143
2015-08-12 08:03:21,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0023_01_000003 is : 143
2015-08-12 08:03:22,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0023_01_000004 is : 143
2015-08-12 08:03:22,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0023_01_000005 is : 143
2015-08-12 08:03:30,286 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0023_01_000006 is : 143
2015-08-12 08:03:31,659 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-08-12 08:03:31,861 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439390902080_0024
2015-08-12 08:03:31,861 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0024/
2015-08-12 08:04:00,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0024_01_000003 is : 143
2015-08-12 08:04:00,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0024_01_000002 is : 143
2015-08-12 08:04:00,995 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0024_01_000004 is : 143
2015-08-12 08:04:01,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0024_01_000005 is : 143
2015-08-12 08:04:09,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0024_01_000006 is : 143
2015-08-12 08:04:10,654 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-08-12 08:04:10,838 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439390902080_0025
2015-08-12 08:04:10,839 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0025/
2015-08-12 08:04:42,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0025_01_000005 is : 143
2015-08-12 08:04:42,537 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0025_01_000003 is : 143
2015-08-12 08:04:50,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0025_01_000006 is : 143
2015-08-12 08:04:51,984 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-08-12 08:04:52,008 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-08-12 08:04:52,013 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-08-12 08:04:52,104 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-08-12 08:04:52,147 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-08-12 08:04:52,170 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-08-12 08:04:52,351 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:04:52,382 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:04:52,572 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:04:52,573 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:04:52,573 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-08-12 08:04:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:04:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-08-12 08:04:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-08-12 08:04:52,585 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-12 08:04:53,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0026
2015-08-12 08:04:53,415 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0026/
2015-08-12 08:05:24,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0026_01_000002 is : 143
2015-08-12 08:05:25,125 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0026_01_000004 is : 143
2015-08-12 08:05:25,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0026_01_000005 is : 143
2015-08-12 08:05:35,890 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0026_01_000006 is : 143
2015-08-12 08:05:37,164 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-08-12 08:05:37,357 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0027
2015-08-12 08:05:37,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0027/
2015-08-12 08:06:06,289 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-08-12 08:06:06,323 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-08-12 08:06:06,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:06:06,399 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:06:06,436 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-12 08:06:06,437 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:06:06,438 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-08-12 08:06:06,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-08-12 08:06:06,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-08-12 08:06:06,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-08-12 08:06:06,455 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-12 08:06:06,654 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439390902080_0028
2015-08-12 08:06:06,654 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0028/
2015-08-12 08:06:44,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0028_01_000003 is : 143
2015-08-12 08:06:45,657 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0028_01_000002 is : 143
2015-08-12 08:06:48,002 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0028_01_000005 is : 143
2015-08-12 08:06:49,693 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-08-12 08:06:49,888 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439390902080_0029
2015-08-12 08:06:49,889 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0029/
2015-08-12 08:07:19,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0029_01_000003 is : 143
2015-08-12 08:07:20,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0029_01_000005 is : 143
2015-08-12 08:07:20,993 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0029_01_000004 is : 143
2015-08-12 08:07:28,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0029_01_000006 is : 143
2015-08-12 08:07:29,464 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-08-12 08:07:29,494 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-08-12 08:07:29,545 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:07:29,546 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:07:29,577 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-08-12 08:07:29,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 08:07:29,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 08:07:29,582 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-08-12 08:07:29,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  parallel execution is enabled: true
2015-08-12 08:07:29,589 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  starting jobs: 1
2015-08-12 08:07:29,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  allocating threads: 1
2015-08-12 08:07:29,593 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-08-12 08:07:29,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1439390902080_0030
2015-08-12 08:07:29,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0030/
2015-08-12 08:08:17,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000003 is : 143
2015-08-12 08:08:18,796 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000004 is : 143
2015-08-12 08:08:18,957 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000006 is : 143
2015-08-12 08:08:19,773 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000002 is : 143
2015-08-12 08:08:20,097 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000007 is : 143
2015-08-12 08:08:20,178 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000005 is : 143
2015-08-12 08:08:27,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0030_01_000008 is : 143
2015-08-12 08:08:28,654 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-08-12 08:08:28,689 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-08-12 08:08:28,725 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:08:28,726 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:08:28,747 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:08:28,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 08:08:28,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-08-12 08:08:28,751 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:08:28,752 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:08:28,753 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:08:28,757 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-08-12 08:08:29,050 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0031
2015-08-12 08:08:29,050 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0031/
2015-08-12 08:09:07,963 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0031_01_000003 is : 143
2015-08-12 08:09:08,070 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0031_01_000006 is : 143
2015-08-12 08:09:08,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0031_01_000004 is : 143
2015-08-12 08:09:10,347 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-08-12 08:09:10,397 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-08-12 08:09:10,466 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:09:10,467 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:09:10,537 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:09:10,538 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:09:10,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-08-12 08:09:10,541 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:09:10,541 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-08-12 08:09:10,543 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-08-12 08:09:10,552 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-12 08:09:10,740 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0032
2015-08-12 08:09:10,740 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0032/
2015-08-12 08:09:43,976 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0032_01_000005 is : 143
2015-08-12 08:09:44,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0032_01_000003 is : 143
2015-08-12 08:09:44,631 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0032_01_000004 is : 143
2015-08-12 08:09:52,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0032_01_000006 is : 143
2015-08-12 08:09:53,430 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-08-12 08:09:53,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0033
2015-08-12 08:09:53,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0033/
2015-08-12 08:10:12,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0033_01_000002 is : 143
2015-08-12 08:10:20,642 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0033_01_000003 is : 143
2015-08-12 08:10:21,953 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-08-12 08:10:21,984 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-08-12 08:10:22,025 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:10:22,026 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:10:22,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-08-12 08:10:22,064 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 08:10:22,064 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-08-12 08:10:22,066 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  parallel execution is enabled: true
2015-08-12 08:10:22,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  starting jobs: 2
2015-08-12 08:10:22,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  allocating threads: 2
2015-08-12 08:10:22,072 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-08-12 08:10:22,263 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439390902080_0034
2015-08-12 08:10:22,264 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0034/
2015-08-12 08:10:53,388 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0034_01_000005 is : 143
2015-08-12 08:10:53,543 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0034_01_000004 is : 143
2015-08-12 08:10:53,728 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0034_01_000002 is : 143
2015-08-12 08:11:06,172 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-12 08:11:06,520 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439390902080_0035
2015-08-12 08:11:06,521 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0035/
2015-08-12 08:11:43,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0035_01_000007 is : 143
2015-08-12 08:11:48,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0035_01_000005 is : 143
2015-08-12 08:11:54,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0035_01_000008 is : 143
2015-08-12 08:11:56,105 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-08-12 08:11:56,136 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-08-12 08:11:56,173 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:11:56,176 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:11:56,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:11:56,195 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:11:56,195 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-08-12 08:11:56,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:11:56,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:11:56,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:11:56,200 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-08-12 08:11:56,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0036
2015-08-12 08:11:56,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0036/
2015-08-12 08:12:01,636 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439390902080_0035_01_000001
2015-08-12 08:12:22,512 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0036_01_000002 is : 143
2015-08-12 08:12:23,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0036_01_000004 is : 143
2015-08-12 08:12:24,629 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-08-12 08:12:24,694 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-08-12 08:12:24,760 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:12:24,763 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:12:24,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:12:24,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/extra+lower+upper.txt"]
2015-08-12 08:12:24,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-08-12 08:12:24,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:12:24,783 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:12:24,783 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:12:24,787 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-08-12 08:12:24,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0037
2015-08-12 08:12:24,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0037/
2015-08-12 08:12:50,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0037_01_000005 is : 143
2015-08-12 08:12:50,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0037_01_000003 is : 143
2015-08-12 08:12:52,833 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-08-12 08:12:52,871 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-08-12 08:12:52,940 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:12:52,942 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:12:52,960 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:12:52,962 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:12:52,962 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-08-12 08:12:52,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:12:52,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:12:52,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:12:52,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-08-12 08:12:53,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0038
2015-08-12 08:12:53,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0038/
2015-08-12 08:13:17,725 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0038_01_000004 is : 143
2015-08-12 08:13:17,925 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0038_01_000005 is : 143
2015-08-12 08:13:18,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0038_01_000003 is : 143
2015-08-12 08:13:18,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0038_01_000002 is : 143
2015-08-12 08:13:19,989 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-08-12 08:13:20,042 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-08-12 08:13:20,085 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:13:20,086 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:13:20,104 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-08-12 08:13:20,106 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]]]
2015-08-12 08:13:20,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-08-12 08:13:20,110 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  parallel execution is enabled: true
2015-08-12 08:13:20,110 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  starting jobs: 1
2015-08-12 08:13:20,110 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  allocating threads: 1
2015-08-12 08:13:20,112 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-08-12 08:13:20,299 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1439390902080_0039
2015-08-12 08:13:20,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0039/
2015-08-12 08:13:58,534 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0039_01_000003 is : 143
2015-08-12 08:14:01,878 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0039_01_000006 is : 143
2015-08-12 08:14:02,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0039_01_000007 is : 143
2015-08-12 08:14:08,248 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0039_01_000008 is : 143
2015-08-12 08:14:09,571 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-08-12 08:14:09,610 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-08-12 08:14:09,638 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:14:09,640 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:14:09,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-12 08:14:09,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:14:09,674 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-08-12 08:14:09,675 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-08-12 08:14:09,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-08-12 08:14:09,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-08-12 08:14:09,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-08-12 08:14:09,685 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-12 08:14:09,887 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0040
2015-08-12 08:14:09,887 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0040/
2015-08-12 08:14:41,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0040_01_000002 is : 143
2015-08-12 08:14:49,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0040_01_000006 is : 143
2015-08-12 08:14:51,091 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp1
2015-08-12 08:14:51,091 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp2
2015-08-12 08:14:51,386 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0041
2015-08-12 08:14:51,390 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0041/
2015-08-12 08:14:51,430 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439390902080_0042
2015-08-12 08:14:51,431 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0042/
2015-08-12 08:15:17,985 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-08-12 08:15:17,995 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-08-12 08:15:18,048 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-08-12 08:15:18,060 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-08-12 08:15:18,094 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 08:15:18,095 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 08:15:18,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 08:15:18,109 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 08:15:18,112 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-08-12 08:15:18,114 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-08-12 08:15:18,115 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-08-12 08:15:18,116 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-08-12 08:15:18,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-08-12 08:15:18,511 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439390902080_0043
2015-08-12 08:15:18,518 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:55675/proxy/application_1439390902080_0043/
2015-08-12 08:15:52,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0043_01_000003 is : 143
2015-08-12 08:15:52,241 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0043_01_000004 is : 143
2015-08-12 08:15:52,389 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439390902080_0043_01_000002 is : 143
2015-08-12 08:15:54,576 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-08-12 08:15:54,661 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup

Standard error

Aug 12, 2015 7:48:23 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Aug 12, 2015 7:48:23 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 7:48:23 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 7:48:23 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 7:48:23 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:24 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:25 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Aug 12, 2015 7:48:26 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 7:48:26 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 7:48:26 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 7:48:26 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 7:48:26 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Aug 12, 2015 7:48:26 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 7:48:26 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 7:48:26 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:26 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:27 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 7:48:27 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:27 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:28 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 7:48:28 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.