Class cascading.FieldedPipesPlatformTest

all > cascading > FieldedPipesPlatformTest
29

tests
0

failures
0

ignored
13m53.95s

duration
100%

successful

Tests

Test Duration Result
testChainEndingWithEach 21.025s passed
testChainedTaps 1m4.40s passed
testConcatenation 24.430s passed
testCopy 15.488s passed
testFilter 15.455s passed
testFilterAll 36.005s passed
testFilterComplex 44.973s passed
testGeneratorAggregator 20.739s passed
testGroupByInsensitive 28.112s passed
testGroupGroup 40.576s passed
testLogicFilter 16.892s passed
testNoGroup 19.022s passed
testNone 20.817s passed
testReplace 15.317s passed
testSameSourceMergeThreeChainGroup 46.920s passed
testSimpleChain 20.809s passed
testSimpleGroup 21.110s passed
testSimpleMerge 24.517s passed
testSimpleMergeThree 30.371s passed
testSplit 28.032s passed
testSplitComplex 37.270s passed
testSplitNonSafe 44.501s passed
testSplitOut 49.720s passed
testSplitSameSourceMerged 36.158s passed
testSplitSameSourceMergedSameName 36.154s passed
testSwap 22.205s passed
testUnGroup 18.561s passed
testUnGroupAnon 19.230s passed
testUnGroupBySize 15.143s passed

Standard output

2015-07-17 14:09:19,640 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 14:09:19,658 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 14:09:19,658 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-07-17 14:09:19,691 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 14:09:20,516 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-07-17 14:09:20,944 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 14:09:24,813 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-07-17 14:09:25,044 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-07-17 14:09:25,271 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-07-17 14:09:25,486 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-07-17 14:09:42,599 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 14:09:42,688 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:09:42,689 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:09:42,695 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 9D585EFF1FC444C18F06CC1450D70B19
2015-07-17 14:09:42,810 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 14:09:42,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:09:42,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:09:42,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-07-17 14:09:42,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:09:42,813 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:09:42,813 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:09:42,814 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-07-17 14:09:43,609 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0001
2015-07-17 14:09:43,609 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0001/
2015-07-17 14:09:58,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0001_01_000005 is : 143
2015-07-17 14:09:58,256 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0001_01_000003 is : 143
2015-07-17 14:09:58,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0001_01_000002 is : 143
2015-07-17 14:09:58,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0001_01_000004 is : 143
2015-07-17 14:10:03,310 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0001_01_000006 is : 143
2015-07-17 14:10:04,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-07-17 14:10:04,649 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-07-17 14:10:04,695 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:10:04,696 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:10:04,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:10:04,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:10:04,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-07-17 14:10:04,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:10:04,725 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:10:04,725 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:10:04,726 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-07-17 14:10:04,920 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0002
2015-07-17 14:10:04,920 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0002/
2015-07-17 14:10:18,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0002_01_000004 is : 143
2015-07-17 14:10:19,059 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0002_01_000003 is : 143
2015-07-17 14:10:19,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0002_01_000005 is : 143
2015-07-17 14:10:19,284 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0002_01_000002 is : 143
2015-07-17 14:10:24,238 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0002_01_000006 is : 143
2015-07-17 14:10:25,441 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-07-17 14:10:25,462 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-07-17 14:10:25,499 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:10:25,500 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:10:25,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:10:25,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:10:25,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-07-17 14:10:25,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:10:25,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:10:25,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:10:25,526 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-07-17 14:10:25,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0003
2015-07-17 14:10:25,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0003/
2015-07-17 14:10:39,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0003_01_000003 is : 143
2015-07-17 14:10:39,595 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0003_01_000002 is : 143
2015-07-17 14:10:39,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0003_01_000004 is : 143
2015-07-17 14:10:39,850 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0003_01_000005 is : 143
2015-07-17 14:10:45,323 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0003_01_000006 is : 143
2015-07-17 14:10:46,531 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-07-17 14:10:46,573 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-07-17 14:10:46,648 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:10:46,648 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:10:46,669 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-07-17 14:10:46,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-07-17 14:10:46,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-07-17 14:10:46,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1437167377077_0004
2015-07-17 14:10:46,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0004/
2015-07-17 14:11:04,219 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000005 is : 143
2015-07-17 14:11:04,556 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000004 is : 143
2015-07-17 14:11:04,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000003 is : 143
2015-07-17 14:11:04,822 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000002 is : 143
2015-07-17 14:11:04,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000007 is : 143
2015-07-17 14:11:04,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000006 is : 143
2015-07-17 14:11:09,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0004_01_000008 is : 143
2015-07-17 14:11:11,050 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-07-17 14:11:11,090 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-07-17 14:11:11,234 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:11:11,235 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:11:11,255 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:11:11,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-07-17 14:11:11,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0005
2015-07-17 14:11:11,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0005/
2015-07-17 14:11:25,045 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0005_01_000002 is : 143
2015-07-17 14:11:25,156 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0005_01_000003 is : 143
2015-07-17 14:11:25,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0005_01_000004 is : 143
2015-07-17 14:11:25,448 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0005_01_000005 is : 143
2015-07-17 14:11:30,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0005_01_000006 is : 143
2015-07-17 14:11:32,099 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-07-17 14:11:32,116 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-07-17 14:11:32,150 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:11:32,150 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:11:32,171 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:11:32,172 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:11:32,172 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-07-17 14:11:32,172 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:11:32,173 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:11:32,173 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:11:32,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-07-17 14:11:32,313 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0006
2015-07-17 14:11:32,313 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0006/
2015-07-17 14:11:45,857 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0006_01_000003 is : 143
2015-07-17 14:11:46,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0006_01_000004 is : 143
2015-07-17 14:11:46,134 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0006_01_000002 is : 143
2015-07-17 14:11:46,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0006_01_000005 is : 143
2015-07-17 14:11:51,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0006_01_000006 is : 143
2015-07-17 14:11:52,840 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-07-17 14:11:52,857 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-07-17 14:11:52,905 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:11:52,906 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:11:52,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-07-17 14:11:52,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:11:52,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:11:52,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:11:52,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-07-17 14:11:52,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-07-17 14:11:52,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-07-17 14:11:52,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-07-17 14:11:52,942 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-07-17 14:11:53,094 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1437167377077_0007
2015-07-17 14:11:53,094 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0007/
2015-07-17 14:12:16,096 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000007 is : 143
2015-07-17 14:12:16,310 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000003 is : 143
2015-07-17 14:12:16,344 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000002 is : 143
2015-07-17 14:12:16,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000004 is : 143
2015-07-17 14:12:16,646 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000005 is : 143
2015-07-17 14:12:16,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000010 is : 143
2015-07-17 14:12:16,712 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000009 is : 143
2015-07-17 14:12:16,757 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000006 is : 143
2015-07-17 14:12:16,856 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000008 is : 143
2015-07-17 14:12:22,006 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0007_01_000011 is : 143
2015-07-17 14:12:23,207 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-07-17 14:12:23,228 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-07-17 14:12:23,256 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:12:23,256 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:12:23,301 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-07-17 14:12:23,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-07-17 14:12:23,304 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-07-17 14:12:23,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0008
2015-07-17 14:12:23,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0008/
2015-07-17 14:12:37,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0008_01_000002 is : 143
2015-07-17 14:12:37,697 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0008_01_000003 is : 143
2015-07-17 14:12:37,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0008_01_000004 is : 143
2015-07-17 14:12:37,940 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0008_01_000005 is : 143
2015-07-17 14:12:39,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit1
2015-07-17 14:12:39,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit2
2015-07-17 14:12:39,317 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0010
2015-07-17 14:12:39,317 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0010/
2015-07-17 14:12:39,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0009
2015-07-17 14:12:39,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0009/
2015-07-17 14:12:55,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0010_01_000002 is : 143
2015-07-17 14:12:55,632 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0010_01_000003 is : 143
2015-07-17 14:12:55,852 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0010_01_000005 is : 143
2015-07-17 14:12:55,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0010_01_000004 is : 143
2015-07-17 14:13:06,210 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0009_01_000003 is : 143
2015-07-17 14:13:06,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0009_01_000004 is : 143
2015-07-17 14:13:06,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0009_01_000005 is : 143
2015-07-17 14:13:06,434 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0009_01_000002 is : 143
2015-07-17 14:13:07,657 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-07-17 14:13:07,659 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-07-17 14:13:07,703 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-07-17 14:13:07,715 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-07-17 14:13:07,755 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:13:07,755 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:13:07,774 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  parallel execution is enabled: true
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  starting jobs: 3
2015-07-17 14:13:07,775 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  allocating threads: 3
2015-07-17 14:13:07,777 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-07-17 14:13:07,905 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1437167377077_0011
2015-07-17 14:13:07,905 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0011/
2015-07-17 14:13:23,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0011_01_000003 is : 143
2015-07-17 14:13:23,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0011_01_000002 is : 143
2015-07-17 14:13:23,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0011_01_000004 is : 143
2015-07-17 14:13:23,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0011_01_000005 is : 143
2015-07-17 14:13:31,878 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0011_01_000006 is : 143
2015-07-17 14:13:33,125 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-07-17 14:13:33,125 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-07-17 14:13:33,412 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1437167377077_0012
2015-07-17 14:13:33,412 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0012/
2015-07-17 14:13:33,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1437167377077_0013
2015-07-17 14:13:33,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0013/
2015-07-17 14:13:45,546 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0012_01_000002 is : 143
2015-07-17 14:13:50,301 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0013_01_000002 is : 143
2015-07-17 14:13:56,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0013_01_000003 is : 143
2015-07-17 14:13:57,370 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-07-17 14:13:57,371 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-07-17 14:13:57,444 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-07-17 14:13:57,452 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-07-17 14:13:57,473 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:13:57,473 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:13:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-07-17 14:13:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:13:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-07-17 14:13:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-07-17 14:13:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-07-17 14:13:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 2
2015-07-17 14:13:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 2
2015-07-17 14:13:57,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split2
2015-07-17 14:13:57,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split1
2015-07-17 14:13:57,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0014
2015-07-17 14:13:57,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0014/
2015-07-17 14:13:57,652 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0015
2015-07-17 14:13:57,653 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0015/
2015-07-17 14:14:13,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0014_01_000003 is : 143
2015-07-17 14:14:13,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0014_01_000002 is : 143
2015-07-17 14:14:13,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0014_01_000005 is : 143
2015-07-17 14:14:13,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0014_01_000004 is : 143
2015-07-17 14:14:23,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0015_01_000002 is : 143
2015-07-17 14:14:24,046 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0015_01_000005 is : 143
2015-07-17 14:14:24,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0015_01_000003 is : 143
2015-07-17 14:14:24,203 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0015_01_000004 is : 143
2015-07-17 14:14:25,407 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-07-17 14:14:25,409 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-07-17 14:14:25,460 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-07-17 14:14:25,477 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-07-17 14:14:25,510 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:14:25,511 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-07-17 14:14:25,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-07-17 14:14:25,533 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-07-17 14:14:25,657 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437167377077_0016
2015-07-17 14:14:25,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0016/
2015-07-17 14:14:39,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0016_01_000003 is : 143
2015-07-17 14:14:39,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0016_01_000002 is : 143
2015-07-17 14:14:39,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0016_01_000004 is : 143
2015-07-17 14:14:39,479 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0016_01_000005 is : 143
2015-07-17 14:14:40,661 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-07-17 14:14:40,777 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437167377077_0017
2015-07-17 14:14:40,777 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0017/
2015-07-17 14:14:54,375 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0017_01_000003 is : 143
2015-07-17 14:14:54,499 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0017_01_000002 is : 143
2015-07-17 14:14:54,568 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0017_01_000004 is : 143
2015-07-17 14:14:54,620 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0017_01_000005 is : 143
2015-07-17 14:15:00,412 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0017_01_000006 is : 143
2015-07-17 14:15:01,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-07-17 14:15:01,642 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-07-17 14:15:01,672 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:15:01,672 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:15:01,682 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:15:01,682 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:15:01,682 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-07-17 14:15:01,682 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:15:01,683 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:15:01,683 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:15:01,684 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-07-17 14:15:01,806 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0018
2015-07-17 14:15:01,806 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0018/
2015-07-17 14:15:15,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0018_01_000002 is : 143
2015-07-17 14:15:15,770 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0018_01_000003 is : 143
2015-07-17 14:15:15,843 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0018_01_000005 is : 143
2015-07-17 14:15:15,878 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0018_01_000004 is : 143
2015-07-17 14:15:17,093 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-07-17 14:15:17,115 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-07-17 14:15:17,162 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:15:17,162 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:15:17,175 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:15:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:15:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-07-17 14:15:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:15:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:15:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:15:17,178 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-07-17 14:15:17,296 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0019
2015-07-17 14:15:17,296 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0019/
2015-07-17 14:15:30,820 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0019_01_000002 is : 143
2015-07-17 14:15:30,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0019_01_000003 is : 143
2015-07-17 14:15:31,029 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0019_01_000004 is : 143
2015-07-17 14:15:31,080 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0019_01_000005 is : 143
2015-07-17 14:15:36,721 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0019_01_000006 is : 143
2015-07-17 14:15:37,928 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-07-17 14:15:37,949 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-07-17 14:15:37,971 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:15:37,971 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:15:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:15:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:15:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-07-17 14:15:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:15:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:15:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:15:37,991 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-07-17 14:15:38,121 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0020
2015-07-17 14:15:38,121 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0020/
2015-07-17 14:15:53,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0020_01_000002 is : 143
2015-07-17 14:15:53,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0020_01_000003 is : 143
2015-07-17 14:15:53,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0020_01_000005 is : 143
2015-07-17 14:15:53,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0020_01_000004 is : 143
2015-07-17 14:15:58,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0020_01_000006 is : 143
2015-07-17 14:16:00,137 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-07-17 14:16:00,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-07-17 14:16:00,178 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:16:00,178 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:16:00,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:16:00,194 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-07-17 14:16:00,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0021
2015-07-17 14:16:00,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0021/
2015-07-17 14:16:15,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0021_01_000005 is : 143
2015-07-17 14:16:15,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0021_01_000002 is : 143
2015-07-17 14:16:15,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0021_01_000004 is : 143
2015-07-17 14:16:15,790 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0021_01_000003 is : 143
2015-07-17 14:16:16,992 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-07-17 14:16:17,021 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-07-17 14:16:17,116 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:16:17,116 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:16:17,139 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:16:17,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-17 14:16:17,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-07-17 14:16:17,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:16:17,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:16:17,140 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:16:17,145 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-07-17 14:16:17,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0022
2015-07-17 14:16:17,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0022/
2015-07-17 14:16:33,965 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0022_01_000002 is : 143
2015-07-17 14:16:34,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0022_01_000003 is : 143
2015-07-17 14:16:34,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0022_01_000005 is : 143
2015-07-17 14:16:34,323 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0022_01_000004 is : 143
2015-07-17 14:16:34,354 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0022_01_000006 is : 143
2015-07-17 14:16:35,572 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-07-17 14:16:35,595 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-07-17 14:16:35,633 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:16:35,633 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:16:35,665 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  parallel execution is enabled: true
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  starting jobs: 3
2015-07-17 14:16:35,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  allocating threads: 3
2015-07-17 14:16:35,668 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-07-17 14:16:35,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437167377077_0023
2015-07-17 14:16:35,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0023/
2015-07-17 14:16:51,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0023_01_000003 is : 143
2015-07-17 14:16:51,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0023_01_000002 is : 143
2015-07-17 14:16:51,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0023_01_000004 is : 143
2015-07-17 14:16:51,508 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0023_01_000005 is : 143
2015-07-17 14:16:57,286 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0023_01_000006 is : 143
2015-07-17 14:16:58,504 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-07-17 14:16:58,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437167377077_0024
2015-07-17 14:16:58,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0024/
2015-07-17 14:17:12,473 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0024_01_000003 is : 143
2015-07-17 14:17:12,598 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0024_01_000002 is : 143
2015-07-17 14:17:12,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0024_01_000005 is : 143
2015-07-17 14:17:12,735 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0024_01_000004 is : 143
2015-07-17 14:17:18,316 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0024_01_000006 is : 143
2015-07-17 14:17:19,516 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-07-17 14:17:19,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437167377077_0025
2015-07-17 14:17:19,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0025/
2015-07-17 14:17:33,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0025_01_000004 is : 143
2015-07-17 14:17:33,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0025_01_000003 is : 143
2015-07-17 14:17:33,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0025_01_000005 is : 143
2015-07-17 14:17:33,493 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0025_01_000002 is : 143
2015-07-17 14:17:38,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0025_01_000006 is : 143
2015-07-17 14:17:39,974 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-07-17 14:17:39,975 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-07-17 14:17:39,976 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-07-17 14:17:39,991 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-07-17 14:17:39,998 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-07-17 14:17:40,006 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-07-17 14:17:40,028 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:17:40,028 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:17:40,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:17:40,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:17:40,051 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-07-17 14:17:40,051 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:17:40,051 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-07-17 14:17:40,051 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-07-17 14:17:40,054 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-07-17 14:17:40,163 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0026
2015-07-17 14:17:40,164 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0026/
2015-07-17 14:17:53,704 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0026_01_000003 is : 143
2015-07-17 14:17:53,779 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0026_01_000002 is : 143
2015-07-17 14:17:53,936 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0026_01_000005 is : 143
2015-07-17 14:17:53,976 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0026_01_000004 is : 143
2015-07-17 14:17:59,428 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0026_01_000006 is : 143
2015-07-17 14:18:00,638 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-07-17 14:18:00,751 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0027
2015-07-17 14:18:00,751 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0027/
2015-07-17 14:18:09,457 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0027_01_000002 is : 143
2015-07-17 14:18:14,814 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0027_01_000003 is : 143
2015-07-17 14:18:16,002 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-07-17 14:18:16,014 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-07-17 14:18:16,032 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:18:16,033 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:18:16,052 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-07-17 14:18:16,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:18:16,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-07-17 14:18:16,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-07-17 14:18:16,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-07-17 14:18:16,053 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-07-17 14:18:16,055 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-07-17 14:18:16,170 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437167377077_0028
2015-07-17 14:18:16,170 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0028/
2015-07-17 14:18:29,851 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0028_01_000003 is : 143
2015-07-17 14:18:30,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0028_01_000002 is : 143
2015-07-17 14:18:30,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0028_01_000005 is : 143
2015-07-17 14:18:30,286 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0028_01_000004 is : 143
2015-07-17 14:18:31,487 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-07-17 14:18:31,585 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437167377077_0029
2015-07-17 14:18:31,585 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0029/
2015-07-17 14:18:45,272 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0029_01_000003 is : 143
2015-07-17 14:18:45,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0029_01_000002 is : 143
2015-07-17 14:18:45,407 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0029_01_000005 is : 143
2015-07-17 14:18:45,575 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0029_01_000004 is : 143
2015-07-17 14:18:50,948 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0029_01_000006 is : 143
2015-07-17 14:18:52,153 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-07-17 14:18:52,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-07-17 14:18:52,187 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:18:52,188 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:18:52,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-07-17 14:18:52,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:18:52,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:18:52,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-07-17 14:18:52,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  parallel execution is enabled: true
2015-07-17 14:18:52,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  starting jobs: 1
2015-07-17 14:18:52,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  allocating threads: 1
2015-07-17 14:18:52,210 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-07-17 14:18:52,329 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1437167377077_0030
2015-07-17 14:18:52,329 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0030/
2015-07-17 14:19:13,154 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000003 is : 143
2015-07-17 14:19:13,264 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000004 is : 143
2015-07-17 14:19:13,401 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000007 is : 143
2015-07-17 14:19:13,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000006 is : 143
2015-07-17 14:19:13,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000005 is : 143
2015-07-17 14:19:13,590 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000002 is : 143
2015-07-17 14:19:19,076 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0030_01_000008 is : 143
2015-07-17 14:19:20,265 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-07-17 14:19:20,280 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-07-17 14:19:20,299 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:19:20,299 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:19:20,321 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:19:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-17 14:19:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-07-17 14:19:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:19:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:19:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:19:20,324 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-07-17 14:19:20,448 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0031
2015-07-17 14:19:20,448 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0031/
2015-07-17 14:19:37,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0031_01_000003 is : 143
2015-07-17 14:19:37,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0031_01_000002 is : 143
2015-07-17 14:19:38,056 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0031_01_000005 is : 143
2015-07-17 14:19:38,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0031_01_000006 is : 143
2015-07-17 14:19:38,272 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0031_01_000004 is : 143
2015-07-17 14:19:39,468 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-07-17 14:19:39,494 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-07-17 14:19:39,537 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:19:39,538 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:19:39,557 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:19:39,558 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:19:39,558 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-07-17 14:19:39,558 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:19:39,558 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-07-17 14:19:39,558 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-07-17 14:19:39,560 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-07-17 14:19:39,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0032
2015-07-17 14:19:39,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0032/
2015-07-17 14:19:55,508 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0032_01_000002 is : 143
2015-07-17 14:19:55,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0032_01_000003 is : 143
2015-07-17 14:19:55,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0032_01_000005 is : 143
2015-07-17 14:19:55,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0032_01_000004 is : 143
2015-07-17 14:20:02,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0032_01_000006 is : 143
2015-07-17 14:20:03,183 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-07-17 14:20:03,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0033
2015-07-17 14:20:03,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0033/
2015-07-17 14:20:12,962 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0033_01_000002 is : 143
2015-07-17 14:20:18,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0033_01_000003 is : 143
2015-07-17 14:20:20,065 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-07-17 14:20:20,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-07-17 14:20:20,109 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:20:20,109 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:20:20,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-07-17 14:20:20,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:20:20,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-07-17 14:20:20,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  parallel execution is enabled: true
2015-07-17 14:20:20,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  starting jobs: 2
2015-07-17 14:20:20,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  allocating threads: 2
2015-07-17 14:20:20,140 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-07-17 14:20:20,244 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1437167377077_0034
2015-07-17 14:20:20,244 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0034/
2015-07-17 14:20:35,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000006 is : 143
2015-07-17 14:20:35,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000005 is : 143
2015-07-17 14:20:36,032 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000003 is : 143
2015-07-17 14:20:36,105 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000004 is : 143
2015-07-17 14:20:36,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000002 is : 143
2015-07-17 14:20:41,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0034_01_000007 is : 143
2015-07-17 14:20:42,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-07-17 14:20:42,468 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1437167377077_0035
2015-07-17 14:20:42,468 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0035/
2015-07-17 14:20:59,967 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000002 is : 143
2015-07-17 14:21:00,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000003 is : 143
2015-07-17 14:21:00,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000005 is : 143
2015-07-17 14:21:00,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000004 is : 143
2015-07-17 14:21:00,364 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000007 is : 143
2015-07-17 14:21:00,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000006 is : 143
2015-07-17 14:21:05,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0035_01_000008 is : 143
2015-07-17 14:21:06,992 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-07-17 14:21:07,006 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-07-17 14:21:07,026 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:21:07,026 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:21:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:21:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:21:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-07-17 14:21:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:21:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:21:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:21:07,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-07-17 14:21:07,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0036
2015-07-17 14:21:07,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0036/
2015-07-17 14:21:20,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0036_01_000003 is : 143
2015-07-17 14:21:20,837 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0036_01_000002 is : 143
2015-07-17 14:21:20,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0036_01_000005 is : 143
2015-07-17 14:21:21,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0036_01_000004 is : 143
2015-07-17 14:21:22,282 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-07-17 14:21:22,311 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-07-17 14:21:22,362 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:21:22,363 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:21:22,371 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:21:22,371 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/extra+lower+upper.txt"]
2015-07-17 14:21:22,371 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-07-17 14:21:22,371 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:21:22,371 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:21:22,372 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:21:22,373 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-07-17 14:21:22,485 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0037
2015-07-17 14:21:22,485 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0037/
2015-07-17 14:21:35,859 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0037_01_000002 is : 143
2015-07-17 14:21:36,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0037_01_000003 is : 143
2015-07-17 14:21:36,231 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0037_01_000004 is : 143
2015-07-17 14:21:36,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0037_01_000005 is : 143
2015-07-17 14:21:37,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-07-17 14:21:37,456 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-07-17 14:21:37,491 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:21:37,491 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:21:37,502 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:21:37,502 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:21:37,502 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-07-17 14:21:37,503 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:21:37,503 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:21:37,503 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:21:37,504 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-07-17 14:21:37,625 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0038
2015-07-17 14:21:37,625 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0038/
2015-07-17 14:21:51,439 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0038_01_000003 is : 143
2015-07-17 14:21:51,442 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0038_01_000004 is : 143
2015-07-17 14:21:51,512 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0038_01_000002 is : 143
2015-07-17 14:21:51,703 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0038_01_000005 is : 143
2015-07-17 14:21:52,884 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-07-17 14:21:52,911 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-07-17 14:21:52,950 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:21:52,950 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]]]
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  parallel execution is enabled: true
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  starting jobs: 1
2015-07-17 14:21:52,965 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  allocating threads: 1
2015-07-17 14:21:52,967 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-07-17 14:21:53,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1437167377077_0039
2015-07-17 14:21:53,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0039/
2015-07-17 14:22:10,252 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000004 is : 143
2015-07-17 14:22:10,364 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000003 is : 143
2015-07-17 14:22:10,453 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000002 is : 143
2015-07-17 14:22:10,535 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000005 is : 143
2015-07-17 14:22:10,576 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000007 is : 143
2015-07-17 14:22:10,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000006 is : 143
2015-07-17 14:22:16,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0039_01_000008 is : 143
2015-07-17 14:22:17,336 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-07-17 14:22:17,351 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-07-17 14:22:17,372 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:22:17,373 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:22:17,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-07-17 14:22:17,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-07-17 14:22:17,413 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-07-17 14:22:17,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0040
2015-07-17 14:22:17,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0040/
2015-07-17 14:22:30,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0040_01_000002 is : 143
2015-07-17 14:22:30,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0040_01_000003 is : 143
2015-07-17 14:22:31,136 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0040_01_000004 is : 143
2015-07-17 14:22:31,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0040_01_000005 is : 143
2015-07-17 14:22:36,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0040_01_000006 is : 143
2015-07-17 14:22:37,836 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp1
2015-07-17 14:22:37,836 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp2
2015-07-17 14:22:37,974 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0041
2015-07-17 14:22:37,974 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0041/
2015-07-17 14:22:37,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1437167377077_0042
2015-07-17 14:22:37,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0042/
2015-07-17 14:22:48,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0041_01_000002 is : 143
2015-07-17 14:22:53,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0042_01_000002 is : 143
2015-07-17 14:22:54,579 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-07-17 14:22:54,580 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-07-17 14:22:54,609 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-07-17 14:22:54,621 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-07-17 14:22:54,647 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:22:54,648 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:22:54,656 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 14:22:54,657 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:22:54,657 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-07-17 14:22:54,657 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-07-17 14:22:54,657 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 14:22:54,657 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 14:22:54,660 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-07-17 14:22:54,791 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437167377077_0043
2015-07-17 14:22:54,791 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:55859/proxy/application_1437167377077_0043/
2015-07-17 14:23:12,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0043_01_000004 is : 143
2015-07-17 14:23:12,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0043_01_000003 is : 143
2015-07-17 14:23:12,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0043_01_000002 is : 143
2015-07-17 14:23:12,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437167377077_0043_01_000005 is : 143
2015-07-17 14:23:13,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-07-17 14:23:13,635 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 2:09:37 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jul 17, 2015 2:09:37 PM 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.
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 2:09:38 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:38 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:39 PM 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.
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 2:09:39 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:39 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:39 PM 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.
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 2:09:40 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:40 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:40 PM 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.
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 2:09:41 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 2:09:41 PM 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.