Class cascading.pipe.assembly.AssemblyHelpersPlatformTest

35

tests

0

failures

0

ignored

13.196s

duration

100%

successful

Tests

Test Duration Result
testAverageBy 0.281s passed
testAverageByNull 0.259s passed
testAverageMerge 0.471s passed
testCoerce 0.191s passed
testCoerceFields 0.219s passed
testCount 0.282s passed
testCountAll 0.247s passed
testCountCount 0.588s passed
testCountMerge 0.337s passed
testCountNullNotNull 0.245s passed
testDiscardNarrow 0.217s passed
testFirstBy 0.246s passed
testFirstByWithoutComparator 0.231s passed
testMaxBy 0.314s passed
testMaxByNullSafety 0.263s passed
testMaxByString 0.351s passed
testMinBy 0.268s passed
testMinByNullSafety 0.303s passed
testMinByString 0.669s passed
testParallelAggregates 0.254s passed
testParallelAggregatesMerge 2.273s passed
testParallelAggregatesMergeLegacyHash 0.286s passed
testParallelAggregatesPriorMerge 0.308s passed
testParallelAggregatesPriorMergeLegacyHash 0.331s passed
testRenameAll 0.337s passed
testRenameNamed 0.194s passed
testRenameNarrow 0.195s passed
testRetainNarrow 0.193s passed
testSameSourceMerge 0.476s passed
testSameSourceMergeThreeWay 1.089s passed
testSumBy 0.256s passed
testSumByNulls 0.253s passed
testSumMerge 0.306s passed
testUnique 0.202s passed
testUniqueMerge 0.261s passed

Standard output

2015-07-17 15:25:09,526 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:25:09,545 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:25:09,545 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.pipe.assembly.AssemblyHelpersPlatformTest
2015-07-17 15:25:09,574 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-07-17 15:25:10,153 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 15:25:10,267 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 15:25:10,545 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:10,547 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 15:25:10,559 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 5ADCAD45E785421390321809623A06BD
2015-07-17 15:25:10,776 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:25:10,777 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name] starting
2015-07-17 15:25:10,777 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:10,777 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:10,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  sink: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+false653"]
2015-07-17 15:25:10,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  parallel execution is enabled: false
2015-07-17 15:25:10,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  starting jobs: 1
2015-07-17 15:25:10,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  allocating threads: 1
2015-07-17 15:25:10,780 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] starting step: (1/1) ...tform/multimerge+false653
2015-07-17 15:25:11,272 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] submitted hadoop job: job_local1299156698_0001
2015-07-17 15:25:11,272 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] tracking url: http://localhost:8080/
2015-07-17 15:25:11,336 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/lhs.txt
2015-07-17 15:25:11,429 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:11,429 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:11,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:11,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:11,482 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:11,483 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 127, total: 245, max: 672
2015-07-17 15:25:11,483 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 36% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,484 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:11,484 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 127, total: 245, max: 672
2015-07-17 15:25:11,484 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 36% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,485 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:11,485 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 127, total: 245, max: 672
2015-07-17 15:25:11,485 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 36% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,485 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:11,486 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 127, total: 245, max: 672
2015-07-17 15:25:11,486 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 36% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,506 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/rhs.txt
2015-07-17 15:25:11,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:11,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:11,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:11,572 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:11,630 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:11,630 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 119, total: 346, max: 672
2015-07-17 15:25:11,630 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 51% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,631 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:11,631 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 119, total: 346, max: 672
2015-07-17 15:25:11,631 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 51% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,632 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:11,632 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 119, total: 346, max: 672
2015-07-17 15:25:11,632 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 51% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,633 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:11,633 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 119, total: 346, max: 672
2015-07-17 15:25:11,633 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 51% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:11,714 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:11,714 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:11,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:11,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+false653"]
2015-07-17 15:25:11,785 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/assemblyhelpersplatform/multimerge+false653/_temporary
2015-07-17 15:25:11,845 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/assemblyhelpersplatform/multimerge+false653
2015-07-17 15:25:11,867 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:11,868 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 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max] starting
2015-07-17 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  sink: Hfs["TextDelimited[['num', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minbystring"]
2015-07-17 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  parallel execution is enabled: false
2015-07-17 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  starting jobs: 1
2015-07-17 15:25:11,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  allocating threads: 1
2015-07-17 15:25:11,893 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] starting step: (1/1) ...lpersplatform/minbystring
2015-07-17 15:25:12,064 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] submitted hadoop job: job_local1282997980_0002
2015-07-17 15:25:12,064 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] tracking url: http://localhost:8080/
2015-07-17 15:25:12,068 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/lhs.txt
2015-07-17 15:25:12,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:12,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:12,105 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:12,106 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(max)[by:[{1}:'num']]
2015-07-17 15:25:12,107 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:12,107 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 72, total: 410, max: 672
2015-07-17 15:25:12,107 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 61% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,108 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:12,108 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 72, total: 410, max: 672
2015-07-17 15:25:12,108 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 61% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,402 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:12,403 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:12,409 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(max)[by:[{1}:'num']]
2015-07-17 15:25:12,409 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['num', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minbystring"]
2015-07-17 15:25:12,453 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/assemblyhelpersplatform/minbystring/_temporary
2015-07-17 15:25:12,516 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/assemblyhelpersplatform/minbystring
2015-07-17 15:25:12,546 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:12,547 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 15:25:12,584 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs] starting
2015-07-17 15:25:12,584 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:12,585 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:12,585 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  sink: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergeaverage"]
2015-07-17 15:25:12,585 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  parallel execution is enabled: false
2015-07-17 15:25:12,585 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  starting jobs: 1
2015-07-17 15:25:12,585 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average-lhs+average-rhs]  allocating threads: 1
2015-07-17 15:25:12,586 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average-lhs+average-rhs] starting step: (1/1) ...persplatform/mergeaverage
2015-07-17 15:25:12,800 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average-lhs+average-rhs] submitted hadoop job: job_local392464900_0003
2015-07-17 15:25:12,800 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average-lhs+average-rhs] tracking url: http://localhost:8080/
2015-07-17 15:25:12,804 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/lhs.txt
2015-07-17 15:25:12,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:12,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:12,830 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:12,830 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(average-lhs+average-rhs)[by: average-lhs:[{1}:'char'] average-rhs:[{1}:'char']]
2015-07-17 15:25:12,831 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:12,832 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 202, total: 482, max: 672
2015-07-17 15:25:12,832 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,833 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:12,833 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 202, total: 482, max: 672
2015-07-17 15:25:12,833 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,833 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:12,833 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 202, total: 482, max: 672
2015-07-17 15:25:12,834 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,834 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:12,834 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 202, total: 482, max: 672
2015-07-17 15:25:12,834 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,843 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/rhs.txt
2015-07-17 15:25:12,859 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:12,859 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:12,867 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:12,867 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(average-lhs+average-rhs)[by: average-lhs:[{1}:'char'] average-rhs:[{1}:'char']]
2015-07-17 15:25:12,871 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:12,871 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 100, total: 482, max: 672
2015-07-17 15:25:12,871 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,872 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:12,872 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 100, total: 482, max: 672
2015-07-17 15:25:12,872 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,873 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:12,873 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 100, total: 482, max: 672
2015-07-17 15:25:12,873 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,873 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:12,874 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 100, total: 482, max: 672
2015-07-17 15:25:12,874 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 71% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:12,887 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:12,888 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:12,895 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(average-lhs+average-rhs)[by: average-lhs:[{1}:'char'] average-rhs:[{1}:'char']]
2015-07-17 15:25:12,896 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergeaverage"]
2015-07-17 15:25:12,938 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/assemblyhelpersplatform/mergeaverage/_temporary
2015-07-17 15:25:12,988 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/assemblyhelpersplatform/mergeaverage
2015-07-17 15:25:13,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:13,007 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 15:25:13,025 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:13,025 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  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 15:25:13,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['line']->['item', 'element']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/renameall"]
2015-07-17 15:25:13,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:13,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:13,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:13,026 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...helpersplatform/renameall
2015-07-17 15:25:13,253 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local1272383605_0004
2015-07-17 15:25:13,253 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:13,258 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 15:25:13,268 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:13,268 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:13,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:13,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->['item', 'element']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/renameall"]
2015-07-17 15:25:13,301 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/assemblyhelpersplatform/renameall/_temporary
2015-07-17 15:25:13,326 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/assemblyhelpersplatform/renameall
2015-07-17 15:25:13,342 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:13,342 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 15:25:13,372 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 15:25:13,372 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:13,372 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextDelimited[['count', 'count2']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countcount"]
2015-07-17 15:25:13,372 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-07-17 15:25:13,373 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 2
2015-07-17 15:25:13,373 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-07-17 15:25:13,373 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/2)
2015-07-17 15:25:13,495 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local871822883_0005
2015-07-17 15:25:13,495 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 15:25:13,499 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/lhs.txt
2015-07-17 15:25:13,511 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:13,511 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:13,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:13,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:'char']]
2015-07-17 15:25:13,518 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:13,518 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 224, total: 408, max: 672
2015-07-17 15:25:13,518 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 60% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:13,519 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:13,519 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 224, total: 408, max: 672
2015-07-17 15:25:13,519 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 60% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 224, total: 408, max: 672
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 60% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 224, total: 408, max: 672
2015-07-17 15:25:13,520 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 60% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:13,535 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:13,536 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:13,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:'char']]
2015-07-17 15:25:13,542 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['count', 'count2']]"][3266998781/count/]
2015-07-17 15:25:13,561 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:13,561 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 219, total: 408, max: 672
2015-07-17 15:25:13,561 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 60% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:13,587 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (2/2) ...elpersplatform/countcount
2015-07-17 15:25:13,711 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local2052845926_0006
2015-07-17 15:25:13,711 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 15:25:13,715 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/3266998781_count_A1A9091A53BE43919ED8E31E32BEC041/part-00000
2015-07-17 15:25:13,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:13,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:13,738 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['count', 'count2']]"][3266998781/count/]
2015-07-17 15:25:13,738 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:'count']]
2015-07-17 15:25:13,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:13,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:13,831 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:'count']]
2015-07-17 15:25:13,831 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['count', 'count2']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countcount"]
2015-07-17 15:25:13,866 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/assemblyhelpersplatform/countcount/_temporary
2015-07-17 15:25:13,914 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/assemblyhelpersplatform/countcount
2015-07-17 15:25:13,933 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:13,933 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 15:25:13,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs] starting
2015-07-17 15:25:13,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:13,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:13,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  sink: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergecount"]
2015-07-17 15:25:13,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  parallel execution is enabled: false
2015-07-17 15:25:13,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  starting jobs: 1
2015-07-17 15:25:13,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs+count-rhs]  allocating threads: 1
2015-07-17 15:25:13,956 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs+count-rhs] starting step: (1/1) ...elpersplatform/mergecount
2015-07-17 15:25:14,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs+count-rhs] submitted hadoop job: job_local1458554687_0007
2015-07-17 15:25:14,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs+count-rhs] tracking url: http://localhost:8080/
2015-07-17 15:25:14,074 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/lhs.txt
2015-07-17 15:25:14,086 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:14,086 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,093 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:14,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count-lhs+count-rhs)[by: count-lhs:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:14,095 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:14,095 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 260, total: 434, max: 672
2015-07-17 15:25:14,095 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,096 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:14,096 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 260, total: 434, max: 672
2015-07-17 15:25:14,096 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,096 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:14,096 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 260, total: 434, max: 672
2015-07-17 15:25:14,097 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,097 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:14,097 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 260, total: 434, max: 672
2015-07-17 15:25:14,097 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,103 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/rhs.txt
2015-07-17 15:25:14,116 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:14,116 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:14,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count-lhs+count-rhs)[by: count-lhs:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:14,127 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:14,127 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 159, total: 434, max: 672
2015-07-17 15:25:14,127 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,128 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:14,128 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 159, total: 434, max: 672
2015-07-17 15:25:14,128 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,129 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:14,129 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 159, total: 434, max: 672
2015-07-17 15:25:14,129 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,129 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:14,129 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 159, total: 434, max: 672
2015-07-17 15:25:14,130 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 64% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,143 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:14,143 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,150 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count-lhs+count-rhs)[by: count-lhs:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:14,150 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergecount"]
2015-07-17 15:25:14,191 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/assemblyhelpersplatform/mergecount/_temporary
2015-07-17 15:25:14,252 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/assemblyhelpersplatform/mergecount
2015-07-17 15:25:14,267 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:14,267 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 15:25:14,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min] starting
2015-07-17 15:25:14,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:14,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  sink: Hfs["TextDelimited[['char', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minbynullsafety"]
2015-07-17 15:25:14,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  parallel execution is enabled: false
2015-07-17 15:25:14,285 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  starting jobs: 1
2015-07-17 15:25:14,285 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  allocating threads: 1
2015-07-17 15:25:14,285 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] starting step: (1/1) ...splatform/minbynullsafety
2015-07-17 15:25:14,432 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] submitted hadoop job: job_local1020651783_0008
2015-07-17 15:25:14,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] tracking url: http://localhost:8080/
2015-07-17 15:25:14,436 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/lhs.txt
2015-07-17 15:25:14,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:14,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,454 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:14,454 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(min)[by:[{1}:'char']]
2015-07-17 15:25:14,455 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:14,455 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 352, total: 465, max: 672
2015-07-17 15:25:14,455 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 69% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,456 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:14,456 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 352, total: 465, max: 672
2015-07-17 15:25:14,456 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 69% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,456 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:14,456 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 352, total: 465, max: 672
2015-07-17 15:25:14,457 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 69% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,457 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:14,457 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 352, total: 465, max: 672
2015-07-17 15:25:14,457 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 69% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,468 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:14,469 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,474 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(min)[by:[{1}:'char']]
2015-07-17 15:25:14,475 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minbynullsafety"]
2015-07-17 15:25:14,507 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/assemblyhelpersplatform/minbynullsafety/_temporary
2015-07-17 15:25:14,555 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/assemblyhelpersplatform/minbynullsafety
2015-07-17 15:25:14,573 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:14,574 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 15:25:14,592 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max] starting
2015-07-17 15:25:14,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:14,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  sink: Hfs["TextDelimited[['num', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxbystring"]
2015-07-17 15:25:14,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  parallel execution is enabled: false
2015-07-17 15:25:14,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  starting jobs: 1
2015-07-17 15:25:14,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  allocating threads: 1
2015-07-17 15:25:14,595 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] starting step: (1/1) ...lpersplatform/maxbystring
2015-07-17 15:25:14,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] submitted hadoop job: job_local831576036_0009
2015-07-17 15:25:14,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] tracking url: http://localhost:8080/
2015-07-17 15:25:14,761 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/lhs.txt
2015-07-17 15:25:14,785 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:14,785 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:14,796 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(max)[by:[{1}:'num']]
2015-07-17 15:25:14,797 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:14,797 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 368, total: 526, max: 672
2015-07-17 15:25:14,797 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 78% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,798 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:14,798 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 368, total: 526, max: 672
2015-07-17 15:25:14,798 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(111)) - total mem is 78% of max mem, to better utilize unused memory consider increasing the cache size
2015-07-17 15:25:14,810 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:14,810 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:14,815 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(max)[by:[{1}:'num']]
2015-07-17 15:25:14,815 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['num', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxbystring"]
2015-07-17 15:25:14,855 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/assemblyhelpersplatform/maxbystring/_temporary
2015-07-17 15:25:14,907 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/assemblyhelpersplatform/maxbystring
2015-07-17 15:25:14,925 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:14,926 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 15:25:14,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:25:14,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross.txt"]
2015-07-17 15:25:14,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/firstnfields"]
2015-07-17 15:25:14,945 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: false
2015-07-17 15:25:14,945 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-07-17 15:25:14,945 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-07-17 15:25:14,945 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...persplatform/firstnfields
2015-07-17 15:25:15,059 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_local1530429419_0010
2015-07-17 15:25:15,059 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:8080/
2015-07-17 15:25:15,062 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/lhs+rhs-cross.txt
2015-07-17 15:25:15,076 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:15,077 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross.txt"]
2015-07-17 15:25:15,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(first)[by:[{1}:'num']]
2015-07-17 15:25:15,083 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:15,083 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 418, total: 557, max: 672
2015-07-17 15:25:15,084 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:15,084 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 418, total: 557, max: 672
2015-07-17 15:25:15,095 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:15,095 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,100 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(first)[by:[{1}:'num']]
2015-07-17 15:25:15,100 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/firstnfields"]
2015-07-17 15:25:15,129 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/assemblyhelpersplatform/firstnfields/_temporary
2015-07-17 15:25:15,154 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/assemblyhelpersplatform/firstnfields
2015-07-17 15:25:15,171 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:15,172 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 15:25:15,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce] starting
2015-07-17 15:25:15,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  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 15:25:15,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  sink: Hfs["TextLine[['line']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/coercefields"]
2015-07-17 15:25:15,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  parallel execution is enabled: false
2015-07-17 15:25:15,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  starting jobs: 1
2015-07-17 15:25:15,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  allocating threads: 1
2015-07-17 15:25:15,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] starting step: (1/1) ...persplatform/coercefields
2015-07-17 15:25:15,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] submitted hadoop job: job_local672172707_0011
2015-07-17 15:25:15,301 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] tracking url: http://localhost:8080/
2015-07-17 15:25:15,304 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 15:25:15,315 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:15,315 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,319 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:15,319 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/coercefields"]
2015-07-17 15:25:15,348 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/assemblyhelpersplatform/coercefields/_temporary
2015-07-17 15:25:15,373 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/assemblyhelpersplatform/coercefields
2015-07-17 15:25:15,394 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:15,394 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 15:25:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 15:25:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/count"]
2015-07-17 15:25:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-07-17 15:25:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-07-17 15:25:15,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-07-17 15:25:15,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...mblyhelpersplatform/count
2015-07-17 15:25:15,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local859484248_0012
2015-07-17 15:25:15,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 15:25:15,520 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/lhs.txt
2015-07-17 15:25:15,534 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:15,534 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:15,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:'char']]
2015-07-17 15:25:15,541 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:15,541 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 565, max: 672
2015-07-17 15:25:15,541 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:15,541 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 565, max: 672
2015-07-17 15:25:15,542 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:15,542 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 565, max: 672
2015-07-17 15:25:15,542 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:15,542 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 565, max: 672
2015-07-17 15:25:15,555 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:15,556 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,560 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:'char']]
2015-07-17 15:25:15,561 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/count"]
2015-07-17 15:25:15,592 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/assemblyhelpersplatform/count/_temporary
2015-07-17 15:25:15,655 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/assemblyhelpersplatform/count
2015-07-17 15:25:15,678 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:15,679 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 15:25:15,712 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max] starting
2015-07-17 15:25:15,712 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:15,712 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  sink: Hfs["TextDelimited[['char', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxby"]
2015-07-17 15:25:15,713 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  parallel execution is enabled: false
2015-07-17 15:25:15,713 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  starting jobs: 1
2015-07-17 15:25:15,713 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  allocating threads: 1
2015-07-17 15:25:15,713 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] starting step: (1/1) ...mblyhelpersplatform/maxby
2015-07-17 15:25:15,848 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] submitted hadoop job: job_local1681829972_0013
2015-07-17 15:25:15,848 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] tracking url: http://localhost:8080/
2015-07-17 15:25:15,852 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/lhs.txt
2015-07-17 15:25:15,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:15,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,868 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:15,868 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(max)[by:[{1}:'char']]
2015-07-17 15:25:15,869 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:15,869 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 440, total: 565, max: 672
2015-07-17 15:25:15,870 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:15,870 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 440, total: 565, max: 672
2015-07-17 15:25:15,870 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:15,870 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 440, total: 565, max: 672
2015-07-17 15:25:15,871 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:15,871 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 440, total: 565, max: 672
2015-07-17 15:25:15,882 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:15,882 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:15,888 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(max)[by:[{1}:'char']]
2015-07-17 15:25:15,889 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxby"]
2015-07-17 15:25:15,922 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/assemblyhelpersplatform/maxby/_temporary
2015-07-17 15:25:15,970 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/assemblyhelpersplatform/maxby
2015-07-17 15:25:15,982 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:15,983 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 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min] starting
2015-07-17 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  sink: Hfs["TextDelimited[['char', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minby"]
2015-07-17 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  parallel execution is enabled: false
2015-07-17 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  starting jobs: 1
2015-07-17 15:25:15,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [min]  allocating threads: 1
2015-07-17 15:25:15,996 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] starting step: (1/1) ...mblyhelpersplatform/minby
2015-07-17 15:25:16,111 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] submitted hadoop job: job_local233396521_0014
2015-07-17 15:25:16,111 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [min] tracking url: http://localhost:8080/
2015-07-17 15:25:16,114 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/lhs.txt
2015-07-17 15:25:16,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:16,131 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,135 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:16,135 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(min)[by:[{1}:'char']]
2015-07-17 15:25:16,136 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:16,137 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 565, max: 672
2015-07-17 15:25:16,137 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:16,137 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 565, max: 672
2015-07-17 15:25:16,138 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:16,138 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 565, max: 672
2015-07-17 15:25:16,138 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:16,138 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 565, max: 672
2015-07-17 15:25:16,149 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:16,149 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,154 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(min)[by:[{1}:'char']]
2015-07-17 15:25:16,154 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'min']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/minby"]
2015-07-17 15:25:16,191 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/assemblyhelpersplatform/minby/_temporary
2015-07-17 15:25:16,238 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/assemblyhelpersplatform/minby
2015-07-17 15:25:16,253 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:16,253 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 15:25:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum] starting
2015-07-17 15:25:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  sink: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/sum"]
2015-07-17 15:25:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  parallel execution is enabled: false
2015-07-17 15:25:16,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  starting jobs: 1
2015-07-17 15:25:16,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  allocating threads: 1
2015-07-17 15:25:16,267 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] starting step: (1/1) ...semblyhelpersplatform/sum
2015-07-17 15:25:16,371 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] submitted hadoop job: job_local543235006_0015
2015-07-17 15:25:16,372 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] tracking url: http://localhost:8080/
2015-07-17 15:25:16,375 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/lhs.txt
2015-07-17 15:25:16,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:16,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:16,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(sum)[by:[{1}:'char']]
2015-07-17 15:25:16,396 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:16,396 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 442, total: 555, max: 672
2015-07-17 15:25:16,396 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:16,396 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 442, total: 555, max: 672
2015-07-17 15:25:16,397 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:16,397 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 442, total: 555, max: 672
2015-07-17 15:25:16,397 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:16,397 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 442, total: 555, max: 672
2015-07-17 15:25:16,407 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:16,408 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,412 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(sum)[by:[{1}:'char']]
2015-07-17 15:25:16,412 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/sum"]
2015-07-17 15:25:16,448 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/assemblyhelpersplatform/sum/_temporary
2015-07-17 15:25:16,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/assemblyhelpersplatform/sum
2015-07-17 15:25:16,509 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:16,509 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 15:25:16,527 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs] starting
2015-07-17 15:25:16,527 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:16,527 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:16,527 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  sink: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergesum"]
2015-07-17 15:25:16,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  parallel execution is enabled: false
2015-07-17 15:25:16,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  starting jobs: 1
2015-07-17 15:25:16,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum-lhs+sum-rhs]  allocating threads: 1
2015-07-17 15:25:16,528 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum-lhs+sum-rhs] starting step: (1/1) ...yhelpersplatform/mergesum
2015-07-17 15:25:16,635 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum-lhs+sum-rhs] submitted hadoop job: job_local521742701_0016
2015-07-17 15:25:16,636 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum-lhs+sum-rhs] tracking url: http://localhost:8080/
2015-07-17 15:25:16,640 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/lhs.txt
2015-07-17 15:25:16,655 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:16,655 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,660 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:16,661 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(sum-lhs+sum-rhs)[by: sum-lhs:[{1}:'char'] sum-rhs:[{1}:'char']]
2015-07-17 15:25:16,662 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:16,662 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:16,662 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:16,662 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:16,663 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:16,663 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:16,663 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:16,663 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:16,669 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/rhs.txt
2015-07-17 15:25:16,682 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:16,682 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:16,688 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(sum-lhs+sum-rhs)[by: sum-lhs:[{1}:'char'] sum-rhs:[{1}:'char']]
2015-07-17 15:25:16,691 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:16,691 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 350, total: 565, max: 672
2015-07-17 15:25:16,692 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:16,692 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 350, total: 565, max: 672
2015-07-17 15:25:16,693 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:16,693 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 350, total: 565, max: 672
2015-07-17 15:25:16,693 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:16,693 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 350, total: 565, max: 672
2015-07-17 15:25:16,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:16,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,713 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(sum-lhs+sum-rhs)[by: sum-lhs:[{1}:'char'] sum-rhs:[{1}:'char']]
2015-07-17 15:25:16,713 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/mergesum"]
2015-07-17 15:25:16,749 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/assemblyhelpersplatform/mergesum/_temporary
2015-07-17 15:25:16,801 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/assemblyhelpersplatform/mergesum
2015-07-17 15:25:16,813 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:16,814 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 15:25:16,827 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:16,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  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 15:25:16,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['num']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/discardnarrow"]
2015-07-17 15:25:16,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:16,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:16,828 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:16,829 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...ersplatform/discardnarrow
2015-07-17 15:25:16,949 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local929354014_0017
2015-07-17 15:25:16,949 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:16,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/lower.txt
2015-07-17 15:25:16,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:16,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:16,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:16,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['num']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/discardnarrow"]
2015-07-17 15:25:16,987 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/assemblyhelpersplatform/discardnarrow/_temporary
2015-07-17 15:25:17,018 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/assemblyhelpersplatform/discardnarrow
2015-07-17 15:25:17,035 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:17,036 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 15:25:17,062 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name] starting
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  sink: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+true654"]
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  parallel execution is enabled: false
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  starting jobs: 1
2015-07-17 15:25:17,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  allocating threads: 1
2015-07-17 15:25:17,064 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] starting step: (1/1) ...atform/multimerge+true654
2015-07-17 15:25:17,173 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] submitted hadoop job: job_local244461887_0018
2015-07-17 15:25:17,173 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] tracking url: http://localhost:8080/
2015-07-17 15:25:17,176 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/lhs.txt
2015-07-17 15:25:17,190 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:17,190 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,196 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:17,196 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,197 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:17,197 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 330, total: 565, max: 672
2015-07-17 15:25:17,198 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:17,198 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 329, total: 565, max: 672
2015-07-17 15:25:17,199 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:17,199 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 329, total: 565, max: 672
2015-07-17 15:25:17,199 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:17,199 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 329, total: 565, max: 672
2015-07-17 15:25:17,205 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/rhs.txt
2015-07-17 15:25:17,220 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:17,220 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:17,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,230 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:17,230 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:17,231 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:17,231 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:17,232 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:17,232 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:17,232 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:17,232 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 452, total: 565, max: 672
2015-07-17 15:25:17,246 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:17,247 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,255 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,255 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+true654"]
2015-07-17 15:25:17,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/assemblyhelpersplatform/multimerge+true654/_temporary
2015-07-17 15:25:17,350 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/assemblyhelpersplatform/multimerge+true654
2015-07-17 15:25:17,364 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:17,365 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 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  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 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['line']->['item', 'element']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/rename"]
2015-07-17 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:17,375 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:17,376 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...blyhelpersplatform/rename
2015-07-17 15:25:17,479 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local1746465625_0019
2015-07-17 15:25:17,479 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:17,482 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 15:25:17,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:17,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,493 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:17,493 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->['item', 'element']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/rename"]
2015-07-17 15:25:17,517 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/assemblyhelpersplatform/rename/_temporary
2015-07-17 15:25:17,544 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/assemblyhelpersplatform/rename
2015-07-17 15:25:17,562 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:17,562 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 15:25:17,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name] starting
2015-07-17 15:25:17,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:17,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:17,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  sink: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+true653"]
2015-07-17 15:25:17,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  parallel execution is enabled: false
2015-07-17 15:25:17,581 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  starting jobs: 1
2015-07-17 15:25:17,581 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  allocating threads: 1
2015-07-17 15:25:17,581 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] starting step: (1/1) ...atform/multimerge+true653
2015-07-17 15:25:17,688 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] submitted hadoop job: job_local960147395_0020
2015-07-17 15:25:17,689 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] tracking url: http://localhost:8080/
2015-07-17 15:25:17,691 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/lhs.txt
2015-07-17 15:25:17,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:17,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:17,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,713 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:17,713 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 439, total: 565, max: 672
2015-07-17 15:25:17,714 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:17,714 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 439, total: 565, max: 672
2015-07-17 15:25:17,714 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:17,714 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 439, total: 565, max: 672
2015-07-17 15:25:17,715 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:17,715 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 439, total: 565, max: 672
2015-07-17 15:25:17,720 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/rhs.txt
2015-07-17 15:25:17,734 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:17,734 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:17,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,743 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:17,743 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 337, total: 565, max: 672
2015-07-17 15:25:17,744 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:17,744 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 337, total: 565, max: 672
2015-07-17 15:25:17,744 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:17,745 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 337, total: 565, max: 672
2015-07-17 15:25:17,745 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:17,745 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 337, total: 565, max: 672
2015-07-17 15:25:17,756 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:17,756 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:17,762 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:17,762 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+true653"]
2015-07-17 15:25:17,804 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/assemblyhelpersplatform/multimerge+true653/_temporary
2015-07-17 15:25:17,852 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/assemblyhelpersplatform/multimerge+true653
2015-07-17 15:25:17,867 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:17,868 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 15:25:17,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:25:17,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:17,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/samesourcemergecount"]
2015-07-17 15:25:17,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: false
2015-07-17 15:25:17,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 2
2015-07-17 15:25:17,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-07-17 15:25:17,895 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/2)
2015-07-17 15:25:18,002 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_local1035829957_0021
2015-07-17 15:25:18,002 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://localhost:8080/
2015-07-17 15:25:18,005 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/lhs.txt
2015-07-17 15:25:18,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:18,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,023 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,023 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(first)[by:[{1}:'char']]
2015-07-17 15:25:18,026 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:18,027 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 385, total: 566, max: 672
2015-07-17 15:25:18,027 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:18,027 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 385, total: 566, max: 672
2015-07-17 15:25:18,028 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:18,028 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 385, total: 566, max: 672
2015-07-17 15:25:18,028 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:18,029 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 385, total: 566, max: 672
2015-07-17 15:25:18,038 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:18,038 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,042 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(first)[by:[{1}:'char']]
2015-07-17 15:25:18,042 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['char', 'count']]"][4088800960/first/]
2015-07-17 15:25:18,077 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (2/2) ...form/samesourcemergecount
2015-07-17 15:25:18,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_local111280405_0022
2015-07-17 15:25:18,196 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://localhost:8080/
2015-07-17 15:25:18,200 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/4088800960_first_36079F5A075E458BB4248B1EEBD453A4/part-00000
2015-07-17 15:25:18,213 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:18,213 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,219 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][4088800960/first/]
2015-07-17 15:25:18,219 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(second)[by:[{1}:'char']]
2015-07-17 15:25:18,220 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:18,220 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 451, total: 566, max: 672
2015-07-17 15:25:18,221 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:18,221 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 451, total: 566, max: 672
2015-07-17 15:25:18,232 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:18,232 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,239 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(second)[by:[{1}:'char']]
2015-07-17 15:25:18,239 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/samesourcemergecount"]
2015-07-17 15:25:18,278 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/assemblyhelpersplatform/samesourcemergecount/_temporary
2015-07-17 15:25:18,328 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/assemblyhelpersplatform/samesourcemergecount
2015-07-17 15:25:18,342 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:18,342 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 15:25:18,358 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average] starting
2015-07-17 15:25:18,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  sink: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/average"]
2015-07-17 15:25:18,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  parallel execution is enabled: false
2015-07-17 15:25:18,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  starting jobs: 1
2015-07-17 15:25:18,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  allocating threads: 1
2015-07-17 15:25:18,360 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] starting step: (1/1) ...lyhelpersplatform/average
2015-07-17 15:25:18,486 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] submitted hadoop job: job_local370926943_0023
2015-07-17 15:25:18,486 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] tracking url: http://localhost:8080/
2015-07-17 15:25:18,489 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/lhs.txt
2015-07-17 15:25:18,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:18,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(average)[by:[{1}:'char']]
2015-07-17 15:25:18,509 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:18,510 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,510 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:18,510 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,511 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:18,511 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,511 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:18,511 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,521 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:18,521 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,526 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(average)[by:[{1}:'char']]
2015-07-17 15:25:18,526 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/average"]
2015-07-17 15:25:18,564 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/assemblyhelpersplatform/average/_temporary
2015-07-17 15:25:18,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/assemblyhelpersplatform/average
2015-07-17 15:25:18,624 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:18,625 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 15:25:18,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max] starting
2015-07-17 15:25:18,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  sink: Hfs["TextDelimited[['char', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxbynullsafety"]
2015-07-17 15:25:18,637 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  parallel execution is enabled: false
2015-07-17 15:25:18,637 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  starting jobs: 1
2015-07-17 15:25:18,637 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [max]  allocating threads: 1
2015-07-17 15:25:18,637 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] starting step: (1/1) ...splatform/maxbynullsafety
2015-07-17 15:25:18,742 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] submitted hadoop job: job_local580121900_0024
2015-07-17 15:25:18,742 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [max] tracking url: http://localhost:8080/
2015-07-17 15:25:18,745 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/lhs.txt
2015-07-17 15:25:18,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:18,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,764 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,764 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(max)[by:[{1}:'char']]
2015-07-17 15:25:18,765 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:18,766 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:18,766 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:18,766 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:18,767 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:18,767 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,767 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:18,767 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 453, total: 567, max: 672
2015-07-17 15:25:18,777 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:18,777 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:18,782 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(max)[by:[{1}:'char']]
2015-07-17 15:25:18,782 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'max']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/maxbynullsafety"]
2015-07-17 15:25:18,821 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/assemblyhelpersplatform/maxbynullsafety/_temporary
2015-07-17 15:25:18,873 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/assemblyhelpersplatform/maxbynullsafety
2015-07-17 15:25:18,887 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:18,888 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 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum] starting
2015-07-17 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  sink: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/sumnulls"]
2015-07-17 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  parallel execution is enabled: false
2015-07-17 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  starting jobs: 1
2015-07-17 15:25:18,899 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [sum]  allocating threads: 1
2015-07-17 15:25:18,900 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] starting step: (1/1) ...yhelpersplatform/sumnulls
2015-07-17 15:25:19,007 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] submitted hadoop job: job_local910784726_0025
2015-07-17 15:25:19,007 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [sum] tracking url: http://localhost:8080/
2015-07-17 15:25:19,009 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/lhs.txt
2015-07-17 15:25:19,024 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:19,024 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:19,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(sum)[by:[{1}:'char']]
2015-07-17 15:25:19,034 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:19,034 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:19,034 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:19,034 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:19,035 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:19,035 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:19,035 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:19,035 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 454, total: 567, max: 672
2015-07-17 15:25:19,045 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:19,045 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,048 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(sum)[by:[{1}:'char']]
2015-07-17 15:25:19,048 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/sumnulls"]
2015-07-17 15:25:19,077 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/assemblyhelpersplatform/sumnulls/_temporary
2015-07-17 15:25:19,126 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/assemblyhelpersplatform/sumnulls
2015-07-17 15:25:19,138 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:19,138 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 15:25:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 15:25:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextDelimited[['count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countall"]
2015-07-17 15:25:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-07-17 15:25:19,149 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-07-17 15:25:19,149 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-07-17 15:25:19,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...yhelpersplatform/countall
2015-07-17 15:25:19,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local682878131_0026
2015-07-17 15:25:19,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 15:25:19,259 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/lhs.txt
2015-07-17 15:25:19,274 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:19,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:19,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{?}:NONE]]
2015-07-17 15:25:19,288 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:19,289 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{?}:NONE]]
2015-07-17 15:25:19,294 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countall"]
2015-07-17 15:25:19,328 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/assemblyhelpersplatform/countall/_temporary
2015-07-17 15:25:19,373 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/assemblyhelpersplatform/countall
2015-07-17 15:25:19,386 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:19,387 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 15:25:19,401 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name] starting
2015-07-17 15:25:19,401 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:19,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  sink: Hfs["TextDelimited[['char', 'sum', 'count', 'average', 'average2', 'first']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multi"]
2015-07-17 15:25:19,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  parallel execution is enabled: false
2015-07-17 15:25:19,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  starting jobs: 1
2015-07-17 15:25:19,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  allocating threads: 1
2015-07-17 15:25:19,402 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] starting step: (1/1) ...mblyhelpersplatform/multi
2015-07-17 15:25:19,510 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] submitted hadoop job: job_local1522359850_0027
2015-07-17 15:25:19,510 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] tracking url: http://localhost:8080/
2015-07-17 15:25:19,513 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/lhs.txt
2015-07-17 15:25:19,528 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:19,528 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:19,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:19,534 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:19,534 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 568, max: 672
2015-07-17 15:25:19,534 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:19,534 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 568, max: 672
2015-07-17 15:25:19,535 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:19,535 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 568, max: 672
2015-07-17 15:25:19,536 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:19,536 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 568, max: 672
2015-07-17 15:25:19,547 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:19,547 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,552 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(name)[by:[{1}:'char']]
2015-07-17 15:25:19,553 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum', 'count', 'average', 'average2', 'first']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multi"]
2015-07-17 15:25:19,582 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/assemblyhelpersplatform/multi/_temporary
2015-07-17 15:25:19,627 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/assemblyhelpersplatform/multi
2015-07-17 15:25:19,640 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:19,640 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 15:25:19,650 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:19,651 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  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 15:25:19,651 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['num']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/retainnarrow"]
2015-07-17 15:25:19,651 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:19,651 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:19,651 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:19,652 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...persplatform/retainnarrow
2015-07-17 15:25:19,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local847605668_0028
2015-07-17 15:25:19,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:19,763 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 15:25:19,771 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:19,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,774 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:19,774 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['num']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/retainnarrow"]
2015-07-17 15:25:19,798 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/assemblyhelpersplatform/retainnarrow/_temporary
2015-07-17 15:25:19,820 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/assemblyhelpersplatform/retainnarrow
2015-07-17 15:25:19,833 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:19,833 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 15:25:19,843 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:19,843 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  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 15:25:19,844 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['item']->['char', 'item']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/renamenarrow"]
2015-07-17 15:25:19,844 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:19,844 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:19,844 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:19,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...persplatform/renamenarrow
2015-07-17 15:25:19,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local1020356295_0029
2015-07-17 15:25:19,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:19,958 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 15:25:19,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:19,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:19,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:19,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['item']->['char', 'item']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/renamenarrow"]
2015-07-17 15:25:19,993 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/assemblyhelpersplatform/renamenarrow/_temporary
2015-07-17 15:25:20,015 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/assemblyhelpersplatform/renamenarrow
2015-07-17 15:25:20,030 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:20,030 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 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average] starting
2015-07-17 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  sink: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/averagenull"]
2015-07-17 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  parallel execution is enabled: false
2015-07-17 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  starting jobs: 1
2015-07-17 15:25:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [average]  allocating threads: 1
2015-07-17 15:25:20,043 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] starting step: (1/1) ...lpersplatform/averagenull
2015-07-17 15:25:20,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] submitted hadoop job: job_local944443622_0030
2015-07-17 15:25:20,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [average] tracking url: http://localhost:8080/
2015-07-17 15:25:20,151 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/lhs.txt
2015-07-17 15:25:20,163 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:20,163 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,167 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:20,167 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(average)[by:[{1}:'char']]
2015-07-17 15:25:20,170 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:20,170 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 398, total: 568, max: 672
2015-07-17 15:25:20,170 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:20,171 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 398, total: 568, max: 672
2015-07-17 15:25:20,171 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:20,171 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 398, total: 568, max: 672
2015-07-17 15:25:20,171 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:20,172 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 398, total: 568, max: 672
2015-07-17 15:25:20,182 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:20,182 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,188 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(average)[by:[{1}:'char']]
2015-07-17 15:25:20,188 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/averagenull"]
2015-07-17 15:25:20,224 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/assemblyhelpersplatform/averagenull/_temporary
2015-07-17 15:25:20,274 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/assemblyhelpersplatform/averagenull
2015-07-17 15:25:20,287 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:20,287 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 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce] starting
2015-07-17 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  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 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  sink: Hfs["TextLine[['line']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/coerce"]
2015-07-17 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  parallel execution is enabled: false
2015-07-17 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  starting jobs: 1
2015-07-17 15:25:20,296 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [coerce]  allocating threads: 1
2015-07-17 15:25:20,297 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] starting step: (1/1) ...blyhelpersplatform/coerce
2015-07-17 15:25:20,401 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] submitted hadoop job: job_local1651883796_0031
2015-07-17 15:25:20,401 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [coerce] tracking url: http://localhost:8080/
2015-07-17 15:25:20,404 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 15:25:20,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:20,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: 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 15:25:20,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['line']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/coerce"]
2015-07-17 15:25:20,440 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/assemblyhelpersplatform/coerce/_temporary
2015-07-17 15:25:20,466 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/assemblyhelpersplatform/coerce
2015-07-17 15:25:20,480 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:20,481 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 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross-rev.txt"]
2015-07-17 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/firstnfieldswithoutcomparator"]
2015-07-17 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: false
2015-07-17 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-07-17 15:25:20,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-07-17 15:25:20,494 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...tnfieldswithoutcomparator
2015-07-17 15:25:20,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_local444183526_0032
2015-07-17 15:25:20,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:8080/
2015-07-17 15:25:20,608 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/lhs+rhs-cross-rev.txt
2015-07-17 15:25:20,621 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:20,621 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,625 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross-rev.txt"]
2015-07-17 15:25:20,625 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(first)[by:[{1}:'num']]
2015-07-17 15:25:20,628 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:20,628 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 569, max: 672
2015-07-17 15:25:20,629 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:20,629 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 400, total: 569, max: 672
2015-07-17 15:25:20,639 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:20,639 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,642 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(first)[by:[{1}:'num']]
2015-07-17 15:25:20,643 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['num', 'lower', 'upper']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/firstnfieldswithoutcomparator"]
2015-07-17 15:25:20,671 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/assemblyhelpersplatform/firstnfieldswithoutcomparator/_temporary
2015-07-17 15:25:20,697 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/assemblyhelpersplatform/firstnfieldswithoutcomparator
2015-07-17 15:25:20,710 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:20,710 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 15:25:20,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name] starting
2015-07-17 15:25:20,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:20,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:20,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  sink: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+false654"]
2015-07-17 15:25:20,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  parallel execution is enabled: false
2015-07-17 15:25:20,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  starting jobs: 1
2015-07-17 15:25:20,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [name]  allocating threads: 1
2015-07-17 15:25:20,724 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] starting step: (1/1) ...tform/multimerge+false654
2015-07-17 15:25:20,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] submitted hadoop job: job_local221965518_0033
2015-07-17 15:25:20,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [name] tracking url: http://localhost:8080/
2015-07-17 15:25:20,831 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/lhs.txt
2015-07-17 15:25:20,846 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:20,846 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:20,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:20,851 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:20,851 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 569, max: 672
2015-07-17 15:25:20,852 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:20,852 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 569, max: 672
2015-07-17 15:25:20,852 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:20,852 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 569, max: 672
2015-07-17 15:25:20,853 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:20,853 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 455, total: 569, max: 672
2015-07-17 15:25:20,858 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/rhs.txt
2015-07-17 15:25:20,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:20,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:20,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:20,878 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:20,879 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 353, total: 569, max: 672
2015-07-17 15:25:20,880 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:20,880 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 353, total: 569, max: 672
2015-07-17 15:25:20,880 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:20,880 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 353, total: 569, max: 672
2015-07-17 15:25:20,881 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:20,881 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 353, total: 569, max: 672
2015-07-17 15:25:20,893 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:20,893 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:20,901 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(name)[by: multi-lhs:[{1}:'char'] multi-rhs:[{1}:'char']]
2015-07-17 15:25:20,901 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'sum', 'count', 'average']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/multimerge+false654"]
2015-07-17 15:25:20,935 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/assemblyhelpersplatform/multimerge+false654/_temporary
2015-07-17 15:25:20,984 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/assemblyhelpersplatform/multimerge+false654
2015-07-17 15:25:20,997 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:20,998 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 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...] starting
2015-07-17 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...]  sink: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/samesourcemergethreeway"]
2015-07-17 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...]  parallel execution is enabled: false
2015-07-17 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...]  starting jobs: 5
2015-07-17 15:25:21,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count-lhs*source*count...]  allocating threads: 1
2015-07-17 15:25:21,037 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] starting step: (1/5)
2015-07-17 15:25:21,142 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] submitted hadoop job: job_local1710816283_0034
2015-07-17 15:25:21,143 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] tracking url: http://localhost:8080/
2015-07-17 15:25:21,146 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/lhs.txt
2015-07-17 15:25:21,158 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,158 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:21,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(source)[by:[{1}:'char']]
2015-07-17 15:25:21,162 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:21,162 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 411, total: 570, max: 672
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 411, total: 570, max: 672
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 5, with capacity: 2
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 411, total: 570, max: 672
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 7, with capacity: 2
2015-07-17 15:25:21,163 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 411, total: 570, max: 672
2015-07-17 15:25:21,172 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:21,173 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(source)[by:[{1}:'char']]
2015-07-17 15:25:21,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['char', 'count']]"][7748552706/source/]
2015-07-17 15:25:21,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] starting step: (3/5)
2015-07-17 15:25:21,324 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] submitted hadoop job: job_local1886897239_0035
2015-07-17 15:25:21,324 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] tracking url: http://localhost:8080/
2015-07-17 15:25:21,327 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/7748552706_source_7456268DA32144EEA66968B4136462E5/part-00000
2015-07-17 15:25:21,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,345 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][7748552706/source/]
2015-07-17 15:25:21,345 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count-lhs)[by:[{1}:'char']]
2015-07-17 15:25:21,346 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:21,346 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 456, total: 570, max: 672
2015-07-17 15:25:21,347 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:21,347 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 456, total: 570, max: 672
2015-07-17 15:25:21,356 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:21,356 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,359 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count-lhs)[by:[{1}:'char']]
2015-07-17 15:25:21,359 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['char', 'count']]"][2270796980/count-lhs/]
2015-07-17 15:25:21,385 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] starting step: (4/5)
2015-07-17 15:25:21,505 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] submitted hadoop job: job_local766044023_0036
2015-07-17 15:25:21,505 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] tracking url: http://localhost:8080/
2015-07-17 15:25:21,508 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/7748552706_source_7456268DA32144EEA66968B4136462E5/part-00000
2015-07-17 15:25:21,523 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,523 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][7748552706/source/]
2015-07-17 15:25:21,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count-rhs)[by:[{1}:'char']]
2015-07-17 15:25:21,527 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 1, with capacity: 2
2015-07-17 15:25:21,527 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 457, total: 570, max: 672
2015-07-17 15:25:21,528 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(105)) - flushed keys num times: 3, with capacity: 2
2015-07-17 15:25:21,528 INFO  cache.LRUHashMapCache (LRUHashMapCache.java:removeEldestEntry(106)) - mem on flush (mb), free: 457, total: 570, max: 672
2015-07-17 15:25:21,536 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:21,537 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,539 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count-rhs)[by:[{1}:'char']]
2015-07-17 15:25:21,539 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['char', 'count']]"][8322182738/count-rhs/]
2015-07-17 15:25:21,569 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] starting step: (2/5)
2015-07-17 15:25:21,699 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] submitted hadoop job: job_local1257707012_0037
2015-07-17 15:25:21,699 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] tracking url: http://localhost:8080/
2015-07-17 15:25:21,702 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/8322182738_count_rhs_BB68F4F827D841B28011DAF36E5E8D35/part-00000
2015-07-17 15:25:21,718 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,718 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,723 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][8322182738/count-rhs/]
2015-07-17 15:25:21,723 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(source*count-rhs)[by: source:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:21,728 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/7748552706_source_7456268DA32144EEA66968B4136462E5/part-00000
2015-07-17 15:25:21,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,744 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][7748552706/source/]
2015-07-17 15:25:21,745 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(source*count-rhs)[by: source:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:21,755 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:21,756 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,758 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(source*count-rhs)[by: source:[{1}:'char'] count-rhs:[{1}:'char']]
2015-07-17 15:25:21,758 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[['char', 'num', 'char2', 'count']]"][1354015235/source_count-rhs/]
2015-07-17 15:25:21,771 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 15:25:21,772 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 15:25:21,793 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] starting step: (5/5) ...m/samesourcemergethreeway
2015-07-17 15:25:21,922 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] submitted hadoop job: job_local1005234251_0038
2015-07-17 15:25:21,922 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count-lhs*source*count...] tracking url: http://localhost:8080/
2015-07-17 15:25:21,925 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/1354015235_source_count_rhs_4AAC79C9652F4E1091CD82A9C9C08939/part-00000
2015-07-17 15:25:21,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,941 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'num', 'char2', 'count']]"][1354015235/source_count-rhs/]
2015-07-17 15:25:21,941 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(count-lhs*source*count-rhs)[by: count-lhs:[{1}:'char'] source*count-rhs:[{1}:'char']]
2015-07-17 15:25:21,946 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/2270796980_count_lhs_DB5E331CC855420EBDFE6DB5B427415E/part-00000
2015-07-17 15:25:21,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:21,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,963 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[['char', 'count']]"][2270796980/count-lhs/]
2015-07-17 15:25:21,963 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(count-lhs*source*count-rhs)[by: count-lhs:[{1}:'char'] source*count-rhs:[{1}:'char']]
2015-07-17 15:25:21,975 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:21,976 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:21,981 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(count-lhs*source*count-rhs)[by: count-lhs:[{1}:'char'] source*count-rhs:[{1}:'char']]
2015-07-17 15:25:21,982 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['char', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/samesourcemergethreeway"]
2015-07-17 15:25:21,993 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 15:25:21,993 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-17 15:25:22,025 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/assemblyhelpersplatform/samesourcemergethreeway/_temporary
2015-07-17 15:25:22,072 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/assemblyhelpersplatform/samesourcemergethreeway
2015-07-17 15:25:22,086 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:22,086 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 15:25:22,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] starting
2015-07-17 15:25:22,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:22,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  sink: Hfs["TextLine[['item']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/uniquemerge-nondeterministic"]
2015-07-17 15:25:22,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  parallel execution is enabled: false
2015-07-17 15:25:22,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  starting jobs: 1
2015-07-17 15:25:22,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs]  allocating threads: 1
2015-07-17 15:25:22,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] starting step: (1/1) ...quemerge-nondeterministic
2015-07-17 15:25:22,210 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] submitted hadoop job: job_local1411820279_0039
2015-07-17 15:25:22,210 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] tracking url: http://localhost:8080/
2015-07-17 15:25:22,213 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/lhs.txt
2015-07-17 15:25:22,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:22,226 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,228 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,228 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-07-17 15:25:22,235 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/rhs.txt
2015-07-17 15:25:22,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:22,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,254 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 15:25:22,254 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-07-17 15:25:22,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:22,267 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,270 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-07-17 15:25:22,270 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['item']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/uniquemerge-nondeterministic"]
2015-07-17 15:25:22,312 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/assemblyhelpersplatform/uniquemerge-nondeterministic/_temporary
2015-07-17 15:25:22,334 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/assemblyhelpersplatform/uniquemerge-nondeterministic
2015-07-17 15:25:22,345 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:22,345 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 15:25:22,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape] starting
2015-07-17 15:25:22,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  sink: Hfs["TextLine[['item']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/unique"]
2015-07-17 15:25:22,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  parallel execution is enabled: false
2015-07-17 15:25:22,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  starting jobs: 1
2015-07-17 15:25:22,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [shape]  allocating threads: 1
2015-07-17 15:25:22,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] starting step: (1/1) ...blyhelpersplatform/unique
2015-07-17 15:25:22,456 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] submitted hadoop job: job_local735510101_0040
2015-07-17 15:25:22,457 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [shape] tracking url: http://localhost:8080/
2015-07-17 15:25:22,459 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/lhs.txt
2015-07-17 15:25:22,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:22,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,476 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,476 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(shape)[by:[{1}:'num']]
2015-07-17 15:25:22,485 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:22,485 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,487 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(shape)[by:[{1}:'num']]
2015-07-17 15:25:22,488 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['item']->['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/unique"]
2015-07-17 15:25:22,513 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/assemblyhelpersplatform/unique/_temporary
2015-07-17 15:25:22,537 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/assemblyhelpersplatform/unique
2015-07-17 15:25:22,549 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:22,550 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 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-07-17 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  sink: Hfs["TextDelimited[['notnull', 'null']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countnullnotnull"]
2015-07-17 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  parallel execution is enabled: false
2015-07-17 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  starting jobs: 1
2015-07-17 15:25:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [count]  allocating threads: 1
2015-07-17 15:25:22,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...platform/countnullnotnull
2015-07-17 15:25:22,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local2130064731_0041
2015-07-17 15:25:22,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-07-17 15:25:22,669 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/lhs.txt
2015-07-17 15:25:22,684 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:22,684 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,689 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 15:25:22,689 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{?}:NONE]]
2015-07-17 15:25:22,703 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:22,703 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:22,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{?}:NONE]]
2015-07-17 15:25:22,707 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextDelimited[['notnull', 'null']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/assemblyhelpersplatform/countnullnotnull"]
2015-07-17 15:25:22,738 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/assemblyhelpersplatform/countnullnotnull/_temporary
2015-07-17 15:25:22,782 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/assemblyhelpersplatform/countnullnotnull

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]