2015-07-21 12:23:23,495 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 12:23:23,515 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.operation.assertion.AppliedAssertionsPlatformTest, with platform: hadoop2-mr1
2015-07-21 12:23:23,547 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-07-21 12:23:24,133 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-21 12:23:24,242 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-07-21 12:23:24,359 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:24,361 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:24,451 INFO property.AppProps (AppProps.java:getAppID(174)) - using app.id: ED972F1CEB034111A6F2DDB1C5908152
2015-07-21 12:23:24,604 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.095
2015-07-21 12:23:24,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:24,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:24,759 INFO util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 12:23:24,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:24,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:24,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2015-07-21 12:23:24,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:24,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:24,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:24,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/NONE/STRICT
2015-07-21 12:23:25,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1762488225_0001
2015-07-21 12:23:25,354 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:25,429 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:25,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:25,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:25,524 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B52CEE3D84224D1CA490638A6061A20A, ordinal: 0
2015-07-21 12:23:25,561 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:25,561 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:25,562 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B52CEE3D84224D1CA490638A6061A20A, mem on start (mb), free: 125, total: 245, max: 672
2015-07-21 12:23:25,576 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B52CEE3D84224D1CA490638A6061A20A, mem on close (mb), free: 124, total: 245, max: 672
2015-07-21 12:23:25,689 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:25,689 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:25,699 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A6FA8FC688984F6291C44A85D9CEA2E7, ordinal: 1
2015-07-21 12:23:25,703 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:25,703 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2015-07-21 12:23:25,703 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6FA8FC688984F6291C44A85D9CEA2E7, mem on start (mb), free: 109, total: 245, max: 672
2015-07-21 12:23:25,722 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6FA8FC688984F6291C44A85D9CEA2E7, mem on close (mb), free: 108, total: 245, max: 672
2015-07-21 12:23:25,761 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT/_temporary
2015-07-21 12:23:25,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.999
2015-07-21 12:23:25,816 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:25,817 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:25,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-07-21 12:23:25,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:25,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:25,906 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2015-07-21 12:23:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:25,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/value/VALID/STRICT
2015-07-21 12:23:26,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local123741122_0002
2015-07-21 12:23:26,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:26,099 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:26,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:26,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:26,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A045D24DE0E947D286AC2D4ADD036BB7, ordinal: 0
2015-07-21 12:23:26,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:26,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:26,138 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A045D24DE0E947D286AC2D4ADD036BB7, mem on start (mb), free: 81, total: 310, max: 672
2015-07-21 12:23:26,141 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A045D24DE0E947D286AC2D4ADD036BB7, mem on close (mb), free: 81, total: 310, max: 672
2015-07-21 12:23:26,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:26,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:26,164 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1EFF7AB205C445FA5BDF484C169D90C, ordinal: 1
2015-07-21 12:23:26,165 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:26,165 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2015-07-21 12:23:26,165 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1EFF7AB205C445FA5BDF484C169D90C, mem on start (mb), free: 77, total: 310, max: 672
2015-07-21 12:23:26,181 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1EFF7AB205C445FA5BDF484C169D90C, mem on close (mb), free: 76, total: 310, max: 672
2015-07-21 12:23:26,207 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT/_temporary
2015-07-21 12:23:26,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.300
2015-07-21 12:23:26,282 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:26,283 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:26,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-07-21 12:23:26,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:26,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:26,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:26,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:26,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2015-07-21 12:23:26,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:26,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:26,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:26,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/value/STRICT/STRICT
2015-07-21 12:23:26,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local184993546_0003
2015-07-21 12:23:26,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:26,687 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:26,746 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:26,746 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:26,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D29899EDAB304ACA82EB50FFD14BE5C1, ordinal: 0
2015-07-21 12:23:26,757 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:26,757 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:26,757 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D29899EDAB304ACA82EB50FFD14BE5C1, mem on start (mb), free: 144, total: 410, max: 672
2015-07-21 12:23:26,760 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D29899EDAB304ACA82EB50FFD14BE5C1, mem on close (mb), free: 144, total: 410, max: 672
2015-07-21 12:23:26,773 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:26,774 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:26,783 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B4D56CCE7A984DBB9767DBDBFBF2723A, ordinal: 1
2015-07-21 12:23:26,784 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:26,784 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2015-07-21 12:23:26,784 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B4D56CCE7A984DBB9767DBDBFBF2723A, mem on start (mb), free: 139, total: 410, max: 672
2015-07-21 12:23:26,797 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:26,799 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:26,800 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B4D56CCE7A984DBB9767DBDBFBF2723A, mem on close (mb), free: 138, total: 410, max: 672
2015-07-21 12:23:26,803 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local184993546_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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:26,815 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local184993546_0003 state at FAILED
2015-07-21 12:23:26,816 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:26,817 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:26,817 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:26,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:26,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/value/STRICT/STRICT
2015-07-21 12:23:26,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:26,825 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT/_temporary
2015-07-21 12:23:26,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.408
2015-07-21 12:23:26,851 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:26,852 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:26,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-07-21 12:23:26,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:26,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:26,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:26,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:26,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2015-07-21 12:23:26,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:26,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:26,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:26,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/value/NONE/VALID
2015-07-21 12:23:27,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1857709884_0004
2015-07-21 12:23:27,132 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:27,136 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:27,198 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:27,198 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:27,204 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D23EE30A0A694921BED36CD07AD2547B, ordinal: 0
2015-07-21 12:23:27,205 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:27,205 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:27,205 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D23EE30A0A694921BED36CD07AD2547B, mem on start (mb), free: 83, total: 511, max: 672
2015-07-21 12:23:27,208 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D23EE30A0A694921BED36CD07AD2547B, mem on close (mb), free: 83, total: 511, max: 672
2015-07-21 12:23:27,225 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:27,225 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:27,234 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CE6C98E63CA840DCAEE38E45D16B71A9, ordinal: 1
2015-07-21 12:23:27,235 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:27,235 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2015-07-21 12:23:27,235 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CE6C98E63CA840DCAEE38E45D16B71A9, mem on start (mb), free: 78, total: 511, max: 672
2015-07-21 12:23:27,252 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CE6C98E63CA840DCAEE38E45D16B71A9, mem on close (mb), free: 76, total: 511, max: 672
2015-07-21 12:23:27,308 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID/_temporary
2015-07-21 12:23:27,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.370
2015-07-21 12:23:27,367 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:27,368 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:27,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2015-07-21 12:23:27,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:27,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:27,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:27,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:27,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2015-07-21 12:23:27,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:27,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:27,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:27,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/VALID/VALID
2015-07-21 12:23:27,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local3224158_0005
2015-07-21 12:23:27,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:27,610 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:27,637 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:27,637 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:27,645 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA643614931247CC8ACDA4ED2AD9FF38, ordinal: 0
2015-07-21 12:23:27,646 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:27,646 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:27,646 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA643614931247CC8ACDA4ED2AD9FF38, mem on start (mb), free: 135, total: 612, max: 672
2015-07-21 12:23:27,649 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA643614931247CC8ACDA4ED2AD9FF38, mem on close (mb), free: 135, total: 612, max: 672
2015-07-21 12:23:27,664 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:27,665 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:27,673 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE75FF3A15E14741861EF850C4975BDE, ordinal: 1
2015-07-21 12:23:27,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:27,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2015-07-21 12:23:27,674 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE75FF3A15E14741861EF850C4975BDE, mem on start (mb), free: 128, total: 612, max: 672
2015-07-21 12:23:27,689 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:27,690 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:27,693 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE75FF3A15E14741861EF850C4975BDE, mem on close (mb), free: 125, total: 612, max: 672
2015-07-21 12:23:27,696 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local3224158_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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:27,701 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local3224158_0005 state at FAILED
2015-07-21 12:23:27,702 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:27,702 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:27,703 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:27,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:27,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/value/VALID/VALID
2015-07-21 12:23:27,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:27,713 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID/_temporary
2015-07-21 12:23:27,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.272
2015-07-21 12:23:27,714 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT
2015-07-21 12:23:27,714 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT
2015-07-21 12:23:27,714 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT
2015-07-21 12:23:27,715 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID
2015-07-21 12:23:27,715 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID
2015-07-21 12:23:27,750 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:27,751 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:27,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-07-21 12:23:27,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:27,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:27,820 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:27,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:27,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2015-07-21 12:23:27,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:27,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:27,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:27,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/NONE/STRICT
2015-07-21 12:23:27,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local748931162_0006
2015-07-21 12:23:27,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:27,982 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:27,994 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:27,994 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:27,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B4D6AD493E6943F3B41FC7BFDE8B19EF, ordinal: 0
2015-07-21 12:23:28,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,000 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4D6AD493E6943F3B41FC7BFDE8B19EF, mem on start (mb), free: 197, total: 612, max: 672
2015-07-21 12:23:28,002 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4D6AD493E6943F3B41FC7BFDE8B19EF, mem on close (mb), free: 197, total: 612, max: 672
2015-07-21 12:23:28,012 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:28,012 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,019 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EB0659CD2E3F4C16B4BA4107B5D6E139, ordinal: 1
2015-07-21 12:23:28,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2015-07-21 12:23:28,020 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EB0659CD2E3F4C16B4BA4107B5D6E139, mem on start (mb), free: 189, total: 612, max: 672
2015-07-21 12:23:28,033 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EB0659CD2E3F4C16B4BA4107B5D6E139, mem on close (mb), free: 187, total: 612, max: 672
2015-07-21 12:23:28,062 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT/_temporary
2015-07-21 12:23:28,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.242
2015-07-21 12:23:28,110 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:28,110 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:28,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-07-21 12:23:28,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:28,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:28,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:28,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2015-07-21 12:23:28,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:28,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:28,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:28,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/group/VALID/STRICT
2015-07-21 12:23:28,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local41736451_0007
2015-07-21 12:23:28,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:28,307 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:28,328 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:28,328 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6CA0030D6D74001A1216609B069C3DA, ordinal: 0
2015-07-21 12:23:28,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,335 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6CA0030D6D74001A1216609B069C3DA, mem on start (mb), free: 202, total: 612, max: 672
2015-07-21 12:23:28,337 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6CA0030D6D74001A1216609B069C3DA, mem on close (mb), free: 202, total: 612, max: 672
2015-07-21 12:23:28,350 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:28,350 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,356 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E058773834C9444ABBCDF56F4EFE2848, ordinal: 1
2015-07-21 12:23:28,356 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,357 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2015-07-21 12:23:28,357 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E058773834C9444ABBCDF56F4EFE2848, mem on start (mb), free: 195, total: 612, max: 672
2015-07-21 12:23:28,368 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E058773834C9444ABBCDF56F4EFE2848, mem on close (mb), free: 193, total: 612, max: 672
2015-07-21 12:23:28,388 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT/_temporary
2015-07-21 12:23:28,389 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.223
2015-07-21 12:23:28,437 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:28,438 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:28,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-07-21 12:23:28,471 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:28,471 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:28,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:28,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2015-07-21 12:23:28,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:28,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:28,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:28,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/group/STRICT/STRICT
2015-07-21 12:23:28,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local213212065_0008
2015-07-21 12:23:28,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:28,621 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:28,639 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:28,639 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,644 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5161CA066524F43AF38AFF3D4D0C28A, ordinal: 0
2015-07-21 12:23:28,645 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,645 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,645 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5161CA066524F43AF38AFF3D4D0C28A, mem on start (mb), free: 194, total: 605, max: 672
2015-07-21 12:23:28,647 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5161CA066524F43AF38AFF3D4D0C28A, mem on close (mb), free: 194, total: 605, max: 672
2015-07-21 12:23:28,658 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:28,658 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,663 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1583ED2D4154E4C82D490FF2D0D89A3, ordinal: 1
2015-07-21 12:23:28,664 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,664 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2015-07-21 12:23:28,664 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1583ED2D4154E4C82D490FF2D0D89A3, mem on start (mb), free: 187, total: 605, max: 672
2015-07-21 12:23:28,678 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:28,678 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:28,679 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1583ED2D4154E4C82D490FF2D0D89A3, mem on close (mb), free: 184, total: 605, max: 672
2015-07-21 12:23:28,682 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local213212065_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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:28,693 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local213212065_0008 state at FAILED
2015-07-21 12:23:28,693 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:28,693 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:28,693 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:28,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:28,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/group/STRICT/STRICT
2015-07-21 12:23:28,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:28,701 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT/_temporary
2015-07-21 12:23:28,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.211
2015-07-21 12:23:28,718 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:28,719 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:28,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-07-21 12:23:28,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:28,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:28,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:28,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2015-07-21 12:23:28,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:28,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:28,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:28,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/group/NONE/VALID
2015-07-21 12:23:28,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local230939222_0009
2015-07-21 12:23:28,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:28,938 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:28,961 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:28,961 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,968 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE002FB78896436C8C3D1C85F716B2E0, ordinal: 0
2015-07-21 12:23:28,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:28,970 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,970 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE002FB78896436C8C3D1C85F716B2E0, mem on start (mb), free: 201, total: 611, max: 672
2015-07-21 12:23:28,974 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE002FB78896436C8C3D1C85F716B2E0, mem on close (mb), free: 201, total: 611, max: 672
2015-07-21 12:23:28,992 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:28,992 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:28,998 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CDA43851C44B4127B6B657266574D995, ordinal: 1
2015-07-21 12:23:28,998 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:28,999 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2015-07-21 12:23:28,999 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CDA43851C44B4127B6B657266574D995, mem on start (mb), free: 194, total: 611, max: 672
2015-07-21 12:23:29,014 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CDA43851C44B4127B6B657266574D995, mem on close (mb), free: 192, total: 611, max: 672
2015-07-21 12:23:29,044 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID/_temporary
2015-07-21 12:23:29,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.261
2015-07-21 12:23:29,105 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:29,107 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:29,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-07-21 12:23:29,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:29,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:29,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:29,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2015-07-21 12:23:29,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:29,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:29,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:29,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/VALID/VALID
2015-07-21 12:23:29,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1973472152_0010
2015-07-21 12:23:29,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:29,333 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:29,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:29,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,363 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A13043342D624F07A17C2F4DF7B342A2, ordinal: 0
2015-07-21 12:23:29,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,364 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A13043342D624F07A17C2F4DF7B342A2, mem on start (mb), free: 201, total: 612, max: 672
2015-07-21 12:23:29,367 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A13043342D624F07A17C2F4DF7B342A2, mem on close (mb), free: 201, total: 612, max: 672
2015-07-21 12:23:29,382 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:29,382 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,387 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DA5A3AD7E6C34EB48839C6C79708518E, ordinal: 1
2015-07-21 12:23:29,388 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,388 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2015-07-21 12:23:29,388 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DA5A3AD7E6C34EB48839C6C79708518E, mem on start (mb), free: 195, total: 612, max: 672
2015-07-21 12:23:29,402 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,403 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,404 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DA5A3AD7E6C34EB48839C6C79708518E, mem on close (mb), free: 193, total: 612, max: 672
2015-07-21 12:23:29,407 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1973472152_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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,413 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1973472152_0010 state at FAILED
2015-07-21 12:23:29,414 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:29,414 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:29,415 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:29,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:29,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/group/VALID/VALID
2015-07-21 12:23:29,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:29,434 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID/_temporary
2015-07-21 12:23:29,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.269
2015-07-21 12:23:29,435 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT
2015-07-21 12:23:29,436 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT
2015-07-21 12:23:29,436 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT
2015-07-21 12:23:29,436 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID
2015-07-21 12:23:29,436 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID
2015-07-21 12:23:29,468 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:29,469 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:29,521 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-07-21 12:23:29,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:29,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:29,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:29,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2015-07-21 12:23:29,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:29,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:29,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:29,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsFail/fail
2015-07-21 12:23:29,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local703330455_0011
2015-07-21 12:23:29,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:29,680 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:29,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:29,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,702 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F0654583688A4063A852324AEB2DC0AE, ordinal: 0
2015-07-21 12:23:29,702 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,702 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,703 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0654583688A4063A852324AEB2DC0AE, mem on start (mb), free: 201, total: 612, max: 672
2015-07-21 12:23:29,704 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0654583688A4063A852324AEB2DC0AE, mem on close (mb), free: 201, total: 612, max: 672
2015-07-21 12:23:29,714 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:29,714 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,720 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C774AF630B794ECBB46E3A23766ED344, ordinal: 1
2015-07-21 12:23:29,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2015-07-21 12:23:29,721 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C774AF630B794ECBB46E3A23766ED344, mem on start (mb), free: 195, total: 612, max: 672
2015-07-21 12:23:29,733 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,733 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,734 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C774AF630B794ECBB46E3A23766ED344, mem on close (mb), free: 193, total: 612, max: 672
2015-07-21 12:23:29,736 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local703330455_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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:29,744 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local703330455_0011 state at FAILED
2015-07-21 12:23:29,744 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:29,744 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:29,744 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:29,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:29,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...tGroupAssertionsFail/fail
2015-07-21 12:23:29,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:29,748 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail/_temporary
2015-07-21 12:23:29,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.208
2015-07-21 12:23:29,749 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail
2015-07-21 12:23:29,765 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:29,766 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:29,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-07-21 12:23:29,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:29,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:29,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:29,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2015-07-21 12:23:29,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:29,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:29,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:29,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsPass/pass
2015-07-21 12:23:29,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1982697901_0012
2015-07-21 12:23:29,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:29,942 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:29,960 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:29,960 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9408EFDBDF84A82BD704EDB30642DA3, ordinal: 0
2015-07-21 12:23:29,965 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:29,965 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,965 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9408EFDBDF84A82BD704EDB30642DA3, mem on start (mb), free: 200, total: 612, max: 672
2015-07-21 12:23:29,968 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9408EFDBDF84A82BD704EDB30642DA3, mem on close (mb), free: 200, total: 612, max: 672
2015-07-21 12:23:29,982 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:29,982 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:29,989 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C0FD449203854CA88FE3F785865C8DD4, ordinal: 1
2015-07-21 12:23:29,990 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:29,991 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2015-07-21 12:23:29,991 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0FD449203854CA88FE3F785865C8DD4, mem on start (mb), free: 195, total: 612, max: 672
2015-07-21 12:23:30,004 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0FD449203854CA88FE3F785865C8DD4, mem on close (mb), free: 193, total: 612, max: 672
2015-07-21 12:23:30,029 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass/_temporary
2015-07-21 12:23:30,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.215
2015-07-21 12:23:30,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass
2015-07-21 12:23:30,089 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:30,090 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:30,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-07-21 12:23:30,121 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:30,121 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:30,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:30,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsFail/value/fail
2015-07-21 12:23:30,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1117479125_0013
2015-07-21 12:23:30,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:30,269 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:30,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:30,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:30,292 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E5ED3FAB3AC54D8AA3FFB77C37487BAF, ordinal: 0
2015-07-21 12:23:30,293 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:30,293 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:30,293 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5ED3FAB3AC54D8AA3FFB77C37487BAF, mem on start (mb), free: 200, total: 612, max: 672
2015-07-21 12:23:30,295 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5ED3FAB3AC54D8AA3FFB77C37487BAF, mem on close (mb), free: 200, total: 612, max: 672
2015-07-21 12:23:30,305 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:30,305 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:30,311 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FEE1035C30904559AC7E3243F63A7F40, ordinal: 1
2015-07-21 12:23:30,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:30,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2015-07-21 12:23:30,312 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FEE1035C30904559AC7E3243F63A7F40, mem on start (mb), free: 194, total: 612, max: 672
2015-07-21 12:23:30,328 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:30,329 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:30,329 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FEE1035C30904559AC7E3243F63A7F40, mem on close (mb), free: 192, total: 612, max: 672
2015-07-21 12:23:30,332 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1117479125_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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
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.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
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-21 12:23:30,343 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1117479125_0013 state at FAILED
2015-07-21 12:23:30,343 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 12:23:30,343 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 12:23:30,343 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 12:23:30,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 12:23:30,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...AssertionsFail/value/fail
2015-07-21 12:23:30,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 12:23:30,350 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail/_temporary
2015-07-21 12:23:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.215
2015-07-21 12:23:30,351 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail
2015-07-21 12:23:30,369 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:23:30,370 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:23:30,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-07-21 12:23:30,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:23:30,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:23:30,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:23:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2015-07-21 12:23:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-07-21 12:23:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-07-21 12:23:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-07-21 12:23:30,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsPass/value/pass
2015-07-21 12:23:30,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1022802917_0014
2015-07-21 12:23:30,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 12:23:30,546 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 12:23:30,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:23:30,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:23:30,568 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C83108A9A7E84A4BA977A037587F2BDB, ordinal: 0
2015-07-21 12:23:30,569 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:23:30,569 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:30,569 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C83108A9A7E84A4BA977A037587F2BDB, mem on start (mb), free: 199, total: 612, max: 672
2015-07-21 12:23:30,571 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C83108A9A7E84A4BA977A037587F2BDB, mem on close (mb), free: 199, total: 612, max: 672
2015-07-21 12:23:30,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 12:23:30,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 12:23:30,589 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B6B196B347A249E9B8FC7DCC82E58A9F, ordinal: 1
2015-07-21 12:23:30,590 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-07-21 12:23:30,590 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2015-07-21 12:23:30,590 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6B196B347A249E9B8FC7DCC82E58A9F, mem on start (mb), free: 194, total: 612, max: 672
2015-07-21 12:23:30,601 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6B196B347A249E9B8FC7DCC82E58A9F, mem on close (mb), free: 192, total: 612, max: 672
2015-07-21 12:23:30,628 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass/_temporary
2015-07-21 12:23:30,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.208
2015-07-21 12:23:30,655 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass