Class cascading.operation.assertion.AppliedAssertionsPlatformTest

6

tests

0

failures

0

ignored

5.658s

duration

100%

successful

Tests

Test Duration Result
testGroupAssertionsFail 0.223s passed
testGroupAssertionsPass 0.236s passed
testGroupAssertionsRemoval 1.462s passed
testValueAssertionsFail 0.203s passed
testValueAssertionsPass 0.234s passed
testValueAssertionsRemoval 3.300s passed

Standard output

2015-07-17 15:24:57,279 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:24:57,299 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:24:57,299 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.operation.assertion.AppliedAssertionsPlatformTest
2015-07-17 15:24:57,325 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-07-17 15:24:57,859 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:24:57,965 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 15:24:58,059 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:24:58,061 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:24:58,069 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 7DE0DEDCEAD943F0AEBEF4CEEB8288AF
2015-07-17 15:24:58,258 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:24:58,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:24:58,259 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:24:58,260 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT"]
2015-07-17 15:24:58,260 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:24:58,260 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:24:58,260 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:24:58,262 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/NONE/STRICT
2015-07-17 15:24:58,835 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local140466987_0001
2015-07-17 15:24:58,835 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:24:58,898 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:24:58,981 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:24:58,982 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,030 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/apache.10.txt"]
2015-07-17 15:24:59,030 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,138 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:24:59,138 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,148 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,148 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT"]
2015-07-17 15:24:59,201 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/appliedassertionsplatform/value/NONE/STRICT/_temporary
2015-07-17 15:24:59,251 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:24:59,252 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:24:59,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:24:59,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:24:59,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT"]
2015-07-17 15:24:59,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:24:59,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:24:59,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:24:59,279 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/value/VALID/STRICT
2015-07-17 15:24:59,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1076748774_0002
2015-07-17 15:24:59,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:24:59,432 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:24:59,476 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:24:59,477 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,484 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/apache.10.txt"]
2015-07-17 15:24:59,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,498 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:24:59,498 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,506 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,520 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT"]
2015-07-17 15:24:59,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/appliedassertionsplatform/value/VALID/STRICT/_temporary
2015-07-17 15:24:59,618 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:24:59,618 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:24:59,645 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:24:59,645 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:24:59,646 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT"]
2015-07-17 15:24:59,646 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:24:59,646 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:24:59,646 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:24:59,647 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/value/STRICT/STRICT
2015-07-17 15:24:59,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1308306089_0003
2015-07-17 15:24:59,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:24:59,878 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:24:59,931 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:24:59,931 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,938 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/apache.10.txt"]
2015-07-17 15:24:59,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,953 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:24:59,953 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:24:59,960 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:24:59,960 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT"]
2015-07-17 15:24:59,972 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:24:59,974 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:24:59,977 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1308306089_0003
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:24:59,986 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local1308306089_0003 state at FAILED
2015-07-17 15:24:59,986 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:24:59,987 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:24:59,987 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:24:59,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:24:59,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/value/STRICT/STRICT
2015-07-17 15:24:59,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:24:59,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/appliedassertionsplatform/value/STRICT/STRICT/_temporary
2015-07-17 15:25:00,020 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:00,021 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:00,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:00,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:00,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID"]
2015-07-17 15:25:00,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:00,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:00,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:00,051 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/value/NONE/VALID
2015-07-17 15:25:00,215 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1976086905_0004
2015-07-17 15:25:00,215 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:00,219 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:00,264 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:00,264 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,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/apache.10.txt"]
2015-07-17 15:25:00,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,284 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:00,284 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,290 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,291 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID"]
2015-07-17 15:25:00,321 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/appliedassertionsplatform/value/NONE/VALID/_temporary
2015-07-17 15:25:00,375 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:00,376 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:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID"]
2015-07-17 15:25:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:00,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:00,394 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/VALID/VALID
2015-07-17 15:25:00,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local415549841_0005
2015-07-17 15:25:00,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:00,521 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:00,566 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:00,566 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,573 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/apache.10.txt"]
2015-07-17 15:25:00,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,590 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:00,591 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,596 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,597 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID"]
2015-07-17 15:25:00,606 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:00,607 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:00,609 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local415549841_0005
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:00,616 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local415549841_0005 state at FAILED
2015-07-17 15:25:00,617 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:25:00,617 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:25:00,617 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:25:00,621 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:25:00,621 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/value/VALID/VALID
2015-07-17 15:25:00,621 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:25:00,622 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/appliedassertionsplatform/value/VALID/VALID/_temporary
2015-07-17 15:25:00,622 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/appliedassertionsplatform/value/STRICT/STRICT
2015-07-17 15:25:00,622 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/appliedassertionsplatform/value/VALID/STRICT
2015-07-17 15:25:00,622 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/appliedassertionsplatform/value/VALID/VALID
2015-07-17 15:25:00,623 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/appliedassertionsplatform/value/NONE/VALID
2015-07-17 15:25:00,623 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/appliedassertionsplatform/value/NONE/STRICT
2015-07-17 15:25:00,643 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:00,643 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:00,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:00,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:00,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT"]
2015-07-17 15:25:00,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:00,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:00,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:00,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/NONE/STRICT
2015-07-17 15:25:00,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2141416792_0006
2015-07-17 15:25:00,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:00,798 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:00,932 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:00,932 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,937 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/apache.10.txt"]
2015-07-17 15:25:00,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,952 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:00,953 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:00,958 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:00,958 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT"]
2015-07-17 15:25:00,998 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/appliedassertionsplatform/group/NONE/STRICT/_temporary
2015-07-17 15:25:01,039 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:01,040 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:01,056 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:01,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:01,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT"]
2015-07-17 15:25:01,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:01,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:01,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:01,058 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/group/VALID/STRICT
2015-07-17 15:25:01,219 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1287360036_0007
2015-07-17 15:25:01,219 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:01,223 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:01,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:01,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,241 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/apache.10.txt"]
2015-07-17 15:25:01,241 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,253 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:01,254 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,258 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,259 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT"]
2015-07-17 15:25:01,299 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/appliedassertionsplatform/group/VALID/STRICT/_temporary
2015-07-17 15:25:01,343 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:01,343 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:01,361 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:01,361 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:01,361 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT"]
2015-07-17 15:25:01,361 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:01,361 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:01,362 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:01,362 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/group/STRICT/STRICT
2015-07-17 15:25:01,483 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1459090690_0008
2015-07-17 15:25:01,484 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:01,487 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:01,500 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:01,500 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,505 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/apache.10.txt"]
2015-07-17 15:25:01,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,516 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:01,517 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,522 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,522 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT"]
2015-07-17 15:25:01,533 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:01,533 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:01,536 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1459090690_0008
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:01,547 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local1459090690_0008 state at FAILED
2015-07-17 15:25:01,547 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:25:01,547 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:25:01,547 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:25:01,551 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:25:01,551 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/group/STRICT/STRICT
2015-07-17 15:25:01,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:25:01,552 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/appliedassertionsplatform/group/STRICT/STRICT/_temporary
2015-07-17 15:25:01,568 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:01,568 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:01,586 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:01,587 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:01,587 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID"]
2015-07-17 15:25:01,587 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:01,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:01,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:01,589 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/group/NONE/VALID
2015-07-17 15:25:01,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1929352885_0009
2015-07-17 15:25:01,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:01,710 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:01,726 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:01,726 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,732 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/apache.10.txt"]
2015-07-17 15:25:01,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,744 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:01,745 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:01,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:01,749 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID"]
2015-07-17 15:25:01,778 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/appliedassertionsplatform/group/NONE/VALID/_temporary
2015-07-17 15:25:01,819 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:01,819 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:01,838 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:01,838 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:01,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID"]
2015-07-17 15:25:01,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:01,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:01,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:01,840 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/VALID/VALID
2015-07-17 15:25:01,998 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2143710505_0010
2015-07-17 15:25:01,998 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:02,002 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:02,020 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:02,020 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,027 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/apache.10.txt"]
2015-07-17 15:25:02,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,044 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:02,044 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,049 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,049 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID"]
2015-07-17 15:25:02,063 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,064 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,067 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2143710505_0010
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,076 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local2143710505_0010 state at FAILED
2015-07-17 15:25:02,077 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:25:02,077 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:25:02,077 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:25:02,082 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:25:02,084 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/group/VALID/VALID
2015-07-17 15:25:02,085 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:25:02,086 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/appliedassertionsplatform/group/VALID/VALID/_temporary
2015-07-17 15:25:02,086 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/appliedassertionsplatform/group/STRICT/STRICT
2015-07-17 15:25:02,086 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/appliedassertionsplatform/group/VALID/VALID
2015-07-17 15:25:02,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT
2015-07-17 15:25:02,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID
2015-07-17 15:25:02,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT
2015-07-17 15:25:02,109 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:02,109 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/fail"]
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:02,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/fail
2015-07-17 15:25:02,243 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local304993669_0011
2015-07-17 15:25:02,243 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:02,247 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:02,262 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:02,262 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,267 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/apache.10.txt"]
2015-07-17 15:25:02,267 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,280 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:02,280 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/fail"]
2015-07-17 15:25:02,297 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,298 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,301 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local304993669_0011
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
	at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,306 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local304993669_0011 state at FAILED
2015-07-17 15:25:02,306 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:25:02,306 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:25:02,306 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:25:02,310 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:25:02,310 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...edassertionsplatform/fail
2015-07-17 15:25:02,310 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:25:02,311 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/appliedassertionsplatform/fail/_temporary
2015-07-17 15:25:02,311 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/fail
2015-07-17 15:25:02,325 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:02,326 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:02,341 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:02,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:02,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/pass"]
2015-07-17 15:25:02,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:02,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:02,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:02,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/pass
2015-07-17 15:25:02,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local453418541_0012
2015-07-17 15:25:02,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:02,455 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:02,471 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:02,471 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,475 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/apache.10.txt"]
2015-07-17 15:25:02,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,486 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:02,487 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,491 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,491 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/pass"]
2015-07-17 15:25:02,522 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/appliedassertionsplatform/pass/_temporary
2015-07-17 15:25:02,547 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/appliedassertionsplatform/pass
2015-07-17 15:25:02,560 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:02,561 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:02,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:02,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:02,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/fail"]
2015-07-17 15:25:02,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:02,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:02,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:02,579 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/fail
2015-07-17 15:25:02,683 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1132723909_0013
2015-07-17 15:25:02,683 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:02,686 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:02,702 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:02,702 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,706 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/apache.10.txt"]
2015-07-17 15:25:02,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,718 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:02,718 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/fail"]
2015-07-17 15:25:02,732 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,732 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,735 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1132723909_0013
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
	at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
	at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
	at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
	at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
	at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
	at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.operation.aggregator.Count.complete(Count.java:82)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
	at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
	at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:25:02,745 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local1132723909_0013 state at FAILED
2015-07-17 15:25:02,745 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-07-17 15:25:02,745 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-07-17 15:25:02,745 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-07-17 15:25:02,749 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-07-17 15:25:02,749 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...rtionsplatform/value/fail
2015-07-17 15:25:02,750 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-07-17 15:25:02,750 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/appliedassertionsplatform/value/fail/_temporary
2015-07-17 15:25:02,750 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/appliedassertionsplatform/value/fail
2015-07-17 15:25:02,766 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:02,766 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:02,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:02,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:02,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/pass"]
2015-07-17 15:25:02,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: false
2015-07-17 15:25:02,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-07-17 15:25:02,782 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-07-17 15:25:02,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/pass
2015-07-17 15:25:02,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1293360282_0014
2015-07-17 15:25:02,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-07-17 15:25:02,894 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-17 15:25:02,909 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:25:02,909 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,913 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/apache.10.txt"]
2015-07-17 15:25:02,914 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,925 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.0
2015-07-17 15:25:02,925 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-07-17 15:25:02,929 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-17 15:25:02,929 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/pass"]
2015-07-17 15:25:02,960 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/appliedassertionsplatform/value/pass/_temporary
2015-07-17 15:25:02,985 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/appliedassertionsplatform/value/pass

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]