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