2015-07-17 13:48:13,967 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 13:48:14,009 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 13:48:14,009 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-07-17 13:48:14,035 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-07-17 13:48:14,688 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-17 13:48:14,930 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:14,932 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 13:48:14,950 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: BAB7096E332E45359DD3A8C5CBAD30B1
2015-07-17 13:48:15,180 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 13:48:15,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:15,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:15,182 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/basicpipesplatform/simplechain"]
2015-07-17 13:48:15,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:15,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-07-17 13:48:15,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:15,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-07-17 13:48:15,863 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local232620699_0001
2015-07-17 13:48:15,864 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:15,952 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:16,042 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:16,042 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:16,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:16,094 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:16,233 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:16,233 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:16,243 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:16,243 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][9309325871/test/]
2015-07-17 13:48:16,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-07-17 13:48:16,508 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1315573973_0002
2015-07-17 13:48:16,508 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:16,517 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/9309325871_test_028DA370FEA44F008EE08E3B58C26B6A/part-00000
2015-07-17 13:48:16,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:16,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:16,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][9309325871/test/]
2015-07-17 13:48:16,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:16,615 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:16,615 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:16,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:16,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simplechain"]
2015-07-17 13:48:16,679 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/basicpipesplatform/simplechain/_temporary
2015-07-17 13:48:16,737 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/basicpipesplatform/simplechain
2015-07-17 13:48:16,793 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:16,793 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 13:48:16,822 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 13:48:16,822 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:16,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count"]
2015-07-17 13:48:16,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-07-17 13:48:16,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-07-17 13:48:16,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-07-17 13:48:16,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-07-17 13:48:17,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local671260579_0003
2015-07-17 13:48:17,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 13:48:17,056 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt
2015-07-17 13:48:17,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:17,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:17,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:17,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:17,145 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:17,146 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:17,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:17,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count"]
2015-07-17 13:48:17,205 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/basicpipesplatform/count/_temporary
2015-07-17 13:48:17,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/basicpipesplatform/count
2015-07-17 13:48:17,303 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:17,304 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 13:48:17,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:17,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:17,328 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/basicpipesplatform/swap"]
2015-07-17 13:48:17,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:17,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:17,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:17,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...1/basicpipesplatform/swap
2015-07-17 13:48:17,536 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1615729269_0004
2015-07-17 13:48:17,537 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:17,542 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:17,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:17,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:17,558 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:17,558 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/swap"]
2015-07-17 13:48:17,588 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/basicpipesplatform/swap/_temporary
2015-07-17 13:48:17,632 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/basicpipesplatform/swap
2015-07-17 13:48:17,683 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:17,684 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 13:48:17,707 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:17,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-17 13:48:17,708 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/basicpipesplatform/ungrouped"]
2015-07-17 13:48:17,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:17,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:17,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:17,709 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-07-17 13:48:17,856 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local964972596_0005
2015-07-17 13:48:17,857 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:17,861 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-17 13:48:17,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:17,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:17,882 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-17 13:48:17,882 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/ungrouped"]
2015-07-17 13:48:17,907 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/basicpipesplatform/ungrouped/_temporary
2015-07-17 13:48:17,940 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/basicpipesplatform/ungrouped
2015-07-17 13:48:17,964 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:17,965 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 13:48:17,983 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:17,983 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:17,984 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/basicpipesplatform/simplerelative"]
2015-07-17 13:48:17,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:17,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:17,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:17,985 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-07-17 13:48:18,124 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1169464675_0006
2015-07-17 13:48:18,125 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:18,129 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:18,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:18,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:18,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:18,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:18,205 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:18,206 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:18,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:18,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelative"]
2015-07-17 13:48:18,266 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/basicpipesplatform/simplerelative/_temporary
2015-07-17 13:48:18,292 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/basicpipesplatform/simplerelative
2015-07-17 13:48:18,415 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:18,415 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 13:48:18,437 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:18,437 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 13:48:18,437 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simpleresult"]
2015-07-17 13:48:18,438 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:18,438 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:18,438 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:18,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-07-17 13:48:18,555 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local768971013_0007
2015-07-17 13:48:18,555 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:18,559 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt
2015-07-17 13:48:18,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:18,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:18,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 13:48:18,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:18,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:18,675 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:18,681 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:18,682 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simpleresult"]
2015-07-17 13:48:18,722 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/basicpipesplatform/simpleresult/_temporary
2015-07-17 13:48:18,749 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/basicpipesplatform/simpleresult
2015-07-17 13:48:18,767 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:18,768 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 13:48:18,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:18,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:18,786 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/basicpipesplatform/filterall"]
2015-07-17 13:48:18,786 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:18,786 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:18,786 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:18,786 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-07-17 13:48:18,927 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1054584427_0008
2015-07-17 13:48:18,927 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:18,930 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:18,940 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:18,940 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:18,944 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:18,944 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/filterall"]
2015-07-17 13:48:18,966 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/basicpipesplatform/filterall/_temporary
2015-07-17 13:48:18,995 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/basicpipesplatform/filterall
2015-07-17 13:48:19,011 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:19,012 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 13:48:19,036 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 13:48:19,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 13:48:19,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 13:48:19,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogroup"]
2015-07-17 13:48:19,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: false
2015-07-17 13:48:19,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-07-17 13:48:19,038 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-07-17 13:48:19,038 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-07-17 13:48:19,158 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local980199555_0009
2015-07-17 13:48:19,159 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-07-17 13:48:19,162 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt
2015-07-17 13:48:19,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:19,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 13:48:19,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-07-17 13:48:19,195 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt
2015-07-17 13:48:19,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:19,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 13:48:19,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-07-17 13:48:19,243 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:19,243 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,248 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-07-17 13:48:19,249 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogroup"]
2015-07-17 13:48:19,267 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 13:48:19,267 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 13:48:19,305 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/basicpipesplatform/complexcogroup/_temporary
2015-07-17 13:48:19,362 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/basicpipesplatform/complexcogroup
2015-07-17 13:48:19,377 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:19,378 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 13:48:19,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:19,395 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/basicpipesplatform/replace"]
2015-07-17 13:48:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:19,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:19,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-07-17 13:48:19,521 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2126754963_0010
2015-07-17 13:48:19,521 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:19,525 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:19,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:19,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,538 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:19,538 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/replace"]
2015-07-17 13:48:19,560 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/basicpipesplatform/replace/_temporary
2015-07-17 13:48:19,598 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/basicpipesplatform/replace
2015-07-17 13:48:19,618 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:19,619 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 13:48:19,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 13:48:19,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:19,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count2"]
2015-07-17 13:48:19,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-07-17 13:48:19,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-07-17 13:48:19,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-07-17 13:48:19,645 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-07-17 13:48:19,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local217132064_0011
2015-07-17 13:48:19,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 13:48:19,828 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt
2015-07-17 13:48:19,848 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:19,848 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:19,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:19,868 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:19,868 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:19,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:19,875 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count2"]
2015-07-17 13:48:19,921 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/basicpipesplatform/count2/_temporary
2015-07-17 13:48:19,969 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/basicpipesplatform/count2
2015-07-17 13:48:19,985 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:19,986 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 13:48:20,001 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 13:48:20,001 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:20,002 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count3"]
2015-07-17 13:48:20,002 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-07-17 13:48:20,002 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-07-17 13:48:20,002 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-07-17 13:48:20,003 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-07-17 13:48:20,133 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local1721383200_0012
2015-07-17 13:48:20,133 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 13:48:20,137 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt
2015-07-17 13:48:20,157 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:20,157 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:20,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:20,174 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:20,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,179 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:20,180 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count3"]
2015-07-17 13:48:20,225 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/basicpipesplatform/count3/_temporary
2015-07-17 13:48:20,272 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/basicpipesplatform/count3
2015-07-17 13:48:20,289 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:20,289 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 13:48:20,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 13:48:20,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:20,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count4"]
2015-07-17 13:48:20,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-07-17 13:48:20,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-07-17 13:48:20,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-07-17 13:48:20,303 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-07-17 13:48:20,419 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local992197831_0013
2015-07-17 13:48:20,419 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 13:48:20,422 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt
2015-07-17 13:48:20,442 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:20,442 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,445 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 13:48:20,445 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:20,459 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:20,459 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,465 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-07-17 13:48:20,466 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/count4"]
2015-07-17 13:48:20,504 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/basicpipesplatform/count4/_temporary
2015-07-17 13:48:20,560 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/basicpipesplatform/count4
2015-07-17 13:48:20,575 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:20,575 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 13:48:20,586 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:20,586 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:20,586 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/basicpipesplatform/filter"]
2015-07-17 13:48:20,586 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:20,586 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:20,587 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:20,587 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-07-17 13:48:20,697 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1339382886_0014
2015-07-17 13:48:20,697 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:20,700 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:20,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:20,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:20,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/filter"]
2015-07-17 13:48:20,744 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/basicpipesplatform/filter/_temporary
2015-07-17 13:48:20,778 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/basicpipesplatform/filter
2015-07-17 13:48:20,796 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 13:48:20,796 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 13:48:20,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 13:48:20,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:20,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simple"]
2015-07-17 13:48:20,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-07-17 13:48:20,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-07-17 13:48:20,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-07-17 13:48:20,815 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-07-17 13:48:20,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local399941811_0015
2015-07-17 13:48:20,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 13:48:20,949 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 13:48:20,962 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 13:48:20,962 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 13:48:20,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:20,978 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 13:48:20,978 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 13:48:20,983 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-07-17 13:48:20,983 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/basicpipesplatform/simple"]
2015-07-17 13:48:21,019 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/basicpipesplatform/simple/_temporary
2015-07-17 13:48:21,047 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/basicpipesplatform/simple