2015-08-12 19:22:00,742 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 19:22:00,845 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.operation.assertion.AppliedAssertionsPlatformTest, with platform: hadoop2-mr1
2015-08-12 19:22:00,944 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 19:22:01,808 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-12 19:22:02,084 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-08-12 19:22:02,258 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:02,275 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:02,549 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 17E718DC0C8349169EF9D56B04FD77F2
2015-08-12 19:22:02,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.143
2015-08-12 19:22:02,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:02,779 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-08-12 19:22:03,016 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 19:22:03,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:03,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:03,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2015-08-12 19:22:03,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:03,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:03,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:03,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/NONE/STRICT
2015-08-12 19:22:03,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1252362772_0001
2015-08-12 19:22:03,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:03,949 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:04,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:04,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:04,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC093171BDE74490B7BCACB262F0BA58, ordinal: 0
2015-08-12 19:22:04,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:04,259 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:04,264 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC093171BDE74490B7BCACB262F0BA58, mem on start (mb), free: 113, total: 249, max: 672
2015-08-12 19:22:04,296 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC093171BDE74490B7BCACB262F0BA58, mem on close (mb), free: 112, total: 249, max: 672
2015-08-12 19:22:04,564 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:04,566 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:04,592 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB8CDCB4BE144BCEA6AE5BBA0DD7866C, ordinal: 1
2015-08-12 19:22:04,600 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:04,601 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2015-08-12 19:22:04,603 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB8CDCB4BE144BCEA6AE5BBA0DD7866C, mem on start (mb), free: 95, total: 249, max: 672
2015-08-12 19:22:04,633 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB8CDCB4BE144BCEA6AE5BBA0DD7866C, mem on close (mb), free: 93, total: 249, max: 672
2015-08-12 19:22:04,696 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT/_temporary
2015-08-12 19:22:04,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:01.675
2015-08-12 19:22:04,833 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:04,840 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:04,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2015-08-12 19:22:04,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:04,968 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-08-12 19:22:05,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:05,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:05,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2015-08-12 19:22:05,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:05,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:05,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:05,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/value/VALID/STRICT
2015-08-12 19:22:05,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1563526771_0002
2015-08-12 19:22:05,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:05,264 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:05,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:05,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:05,318 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D745D312A2F54DB5BDF57713C70DDACA, ordinal: 0
2015-08-12 19:22:05,319 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:05,320 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:05,320 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D745D312A2F54DB5BDF57713C70DDACA, mem on start (mb), free: 155, total: 413, max: 672
2015-08-12 19:22:05,323 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D745D312A2F54DB5BDF57713C70DDACA, mem on close (mb), free: 155, total: 413, max: 672
2015-08-12 19:22:05,348 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:05,348 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:05,366 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F4BE25249F5B4BABACD20A38571B3476, ordinal: 1
2015-08-12 19:22:05,367 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:05,367 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2015-08-12 19:22:05,368 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4BE25249F5B4BABACD20A38571B3476, mem on start (mb), free: 151, total: 413, max: 672
2015-08-12 19:22:05,389 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4BE25249F5B4BABACD20A38571B3476, mem on close (mb), free: 149, total: 413, max: 672
2015-08-12 19:22:05,437 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT/_temporary
2015-08-12 19:22:05,440 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.421
2015-08-12 19:22:05,542 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:05,545 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:05,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2015-08-12 19:22:05,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:05,647 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-08-12 19:22:05,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:05,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:05,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2015-08-12 19:22:05,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:05,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:05,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:05,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/value/STRICT/STRICT
2015-08-12 19:22:06,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1124894342_0003
2015-08-12 19:22:06,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:06,161 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:06,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:06,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:06,226 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF86BDCECDC94D4C9ABAB9DE3C43F475, ordinal: 0
2015-08-12 19:22:06,229 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:06,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:06,232 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF86BDCECDC94D4C9ABAB9DE3C43F475, mem on start (mb), free: 88, total: 514, max: 672
2015-08-12 19:22:06,241 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF86BDCECDC94D4C9ABAB9DE3C43F475, mem on close (mb), free: 88, total: 514, max: 672
2015-08-12 19:22:06,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:06,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:06,301 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AEB5BED69D3A4654916D9E6F890B9E33, ordinal: 1
2015-08-12 19:22:06,303 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:06,304 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2015-08-12 19:22:06,304 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AEB5BED69D3A4654916D9E6F890B9E33, mem on start (mb), free: 84, total: 514, max: 672
2015-08-12 19:22:06,325 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-08-12 19:22:06,348 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-08-12 19:22:06,356 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AEB5BED69D3A4654916D9E6F890B9E33, mem on close (mb), free: 83, total: 514, max: 672
2015-08-12 19:22:06,361 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1124894342_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-08-12 19:22:06,363 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1124894342_0003 state at FAILED
2015-08-12 19:22:06,363 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:06,365 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:06,365 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:06,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:06,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/value/STRICT/STRICT
2015-08-12 19:22:06,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:06,415 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT/_temporary
2015-08-12 19:22:06,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.709
2015-08-12 19:22:06,707 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:06,710 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:06,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2015-08-12 19:22:06,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:06,796 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-08-12 19:22:06,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:06,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:06,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2015-08-12 19:22:06,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:06,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:06,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:06,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/value/NONE/VALID
2015-08-12 19:22:07,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1170610734_0004
2015-08-12 19:22:07,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:07,131 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:07,178 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:07,179 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:07,195 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2B08F6168AD4F3DB6CCFAFFAA45ABC3, ordinal: 0
2015-08-12 19:22:07,197 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:07,198 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:07,199 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B08F6168AD4F3DB6CCFAFFAA45ABC3, mem on start (mb), free: 155, total: 615, max: 672
2015-08-12 19:22:07,203 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B08F6168AD4F3DB6CCFAFFAA45ABC3, mem on close (mb), free: 155, total: 615, max: 672
2015-08-12 19:22:07,244 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:07,245 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:07,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BBAC54765AD44E70A529DA4BD350CE17, ordinal: 1
2015-08-12 19:22:07,267 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:07,268 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2015-08-12 19:22:07,269 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BBAC54765AD44E70A529DA4BD350CE17, mem on start (mb), free: 150, total: 615, max: 672
2015-08-12 19:22:07,287 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BBAC54765AD44E70A529DA4BD350CE17, mem on close (mb), free: 149, total: 615, max: 672
2015-08-12 19:22:07,340 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID/_temporary
2015-08-12 19:22:07,342 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.495
2015-08-12 19:22:07,499 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:07,500 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:07,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2015-08-12 19:22:07,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:07,596 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-08-12 19:22:07,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:07,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:07,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2015-08-12 19:22:07,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:07,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:07,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:07,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/VALID/VALID
2015-08-12 19:22:07,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1147371567_0005
2015-08-12 19:22:07,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:07,838 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:07,873 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:07,873 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:07,889 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AA6D30F3B61E48D8A55F2AD3481738C7, ordinal: 0
2015-08-12 19:22:07,890 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:07,891 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:07,892 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA6D30F3B61E48D8A55F2AD3481738C7, mem on start (mb), free: 233, total: 747, max: 747
2015-08-12 19:22:07,896 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA6D30F3B61E48D8A55F2AD3481738C7, mem on close (mb), free: 233, total: 747, max: 747
2015-08-12 19:22:07,926 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:07,927 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:07,940 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DD75FFFB200E4FAAB90D9FA5D58B570B, ordinal: 1
2015-08-12 19:22:07,943 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:07,944 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2015-08-12 19:22:07,945 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DD75FFFB200E4FAAB90D9FA5D58B570B, mem on start (mb), free: 226, total: 747, max: 747
2015-08-12 19:22:07,956 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-08-12 19:22:07,957 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-08-12 19:22:07,958 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DD75FFFB200E4FAAB90D9FA5D58B570B, mem on close (mb), free: 225, total: 747, max: 747
2015-08-12 19:22:07,961 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1147371567_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-08-12 19:22:07,968 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1147371567_0005 state at FAILED
2015-08-12 19:22:07,969 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:07,970 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:07,970 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:07,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:07,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/value/VALID/VALID
2015-08-12 19:22:07,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:07,993 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID/_temporary
2015-08-12 19:22:07,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.349
2015-08-12 19:22:07,994 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT
2015-08-12 19:22:07,994 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT
2015-08-12 19:22:07,994 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID
2015-08-12 19:22:07,995 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT
2015-08-12 19:22:07,995 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID
2015-08-12 19:22:08,047 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:08,048 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:08,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2015-08-12 19:22:08,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:08,128 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-08-12 19:22:08,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:08,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2015-08-12 19:22:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:08,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/NONE/STRICT
2015-08-12 19:22:08,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local875140670_0006
2015-08-12 19:22:08,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:08,311 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:08,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:08,343 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:08,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F048D5D6D9D048D0BEA20112735347F2, ordinal: 0
2015-08-12 19:22:08,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:08,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:08,356 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F048D5D6D9D048D0BEA20112735347F2, mem on start (mb), free: 234, total: 747, max: 747
2015-08-12 19:22:08,364 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F048D5D6D9D048D0BEA20112735347F2, mem on close (mb), free: 234, total: 747, max: 747
2015-08-12 19:22:08,397 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:08,397 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:08,408 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DF42A51D3FAD4BB58EB7D4A310AB62F5, ordinal: 1
2015-08-12 19:22:08,410 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:08,413 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2015-08-12 19:22:08,414 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF42A51D3FAD4BB58EB7D4A310AB62F5, mem on start (mb), free: 227, total: 747, max: 747
2015-08-12 19:22:08,422 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF42A51D3FAD4BB58EB7D4A310AB62F5, mem on close (mb), free: 226, total: 747, max: 747
2015-08-12 19:22:08,453 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT/_temporary
2015-08-12 19:22:08,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.300
2015-08-12 19:22:08,539 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:08,541 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:08,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2015-08-12 19:22:08,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:08,617 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-08-12 19:22:08,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:08,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:08,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2015-08-12 19:22:08,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:08,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:08,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/group/VALID/STRICT
2015-08-12 19:22:08,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1089119611_0007
2015-08-12 19:22:08,830 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:08,850 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:08,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:08,888 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:08,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EC7EDAE4702C49DC8035BBA237AB5DBD, ordinal: 0
2015-08-12 19:22:08,896 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:08,896 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:08,897 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC7EDAE4702C49DC8035BBA237AB5DBD, mem on start (mb), free: 233, total: 746, max: 746
2015-08-12 19:22:08,900 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC7EDAE4702C49DC8035BBA237AB5DBD, mem on close (mb), free: 233, total: 746, max: 746
2015-08-12 19:22:08,934 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:08,934 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:08,944 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F595804D24E24A45A49857702734EB5B, ordinal: 1
2015-08-12 19:22:08,945 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:08,946 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2015-08-12 19:22:08,947 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F595804D24E24A45A49857702734EB5B, mem on start (mb), free: 227, total: 746, max: 746
2015-08-12 19:22:08,956 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F595804D24E24A45A49857702734EB5B, mem on close (mb), free: 226, total: 746, max: 746
2015-08-12 19:22:08,990 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT/_temporary
2015-08-12 19:22:08,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.351
2015-08-12 19:22:09,059 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:09,061 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:09,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2015-08-12 19:22:09,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:09,126 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-08-12 19:22:09,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:09,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:09,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2015-08-12 19:22:09,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:09,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:09,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:09,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/group/STRICT/STRICT
2015-08-12 19:22:09,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local73051207_0008
2015-08-12 19:22:09,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:09,444 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:09,470 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:09,471 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:09,482 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B48726088195499CB3B8764932E4B855, ordinal: 0
2015-08-12 19:22:09,483 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:09,483 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:09,484 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B48726088195499CB3B8764932E4B855, mem on start (mb), free: 232, total: 747, max: 747
2015-08-12 19:22:09,487 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B48726088195499CB3B8764932E4B855, mem on close (mb), free: 232, total: 747, max: 747
2015-08-12 19:22:09,507 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:09,507 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:09,517 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B6C14302F86E4EF7BEF3B3D8932511DA, ordinal: 1
2015-08-12 19:22:09,519 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:09,520 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2015-08-12 19:22:09,521 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6C14302F86E4EF7BEF3B3D8932511DA, mem on start (mb), free: 225, total: 747, max: 747
2015-08-12 19:22:09,531 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-08-12 19:22:09,536 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-08-12 19:22:09,542 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B6C14302F86E4EF7BEF3B3D8932511DA, mem on close (mb), free: 224, total: 747, max: 747
2015-08-12 19:22:09,544 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local73051207_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-08-12 19:22:09,548 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local73051207_0008 state at FAILED
2015-08-12 19:22:09,548 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:09,549 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:09,549 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:09,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:09,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/group/STRICT/STRICT
2015-08-12 19:22:09,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:09,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2015-08-12 19:22:09,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2015-08-12 19:22:09,570 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT/_temporary
2015-08-12 19:22:09,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.412
2015-08-12 19:22:09,639 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:09,640 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:09,686 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-08-12 19:22:09,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:09,689 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-08-12 19:22:09,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:09,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:09,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2015-08-12 19:22:09,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:09,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:09,723 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:09,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/group/NONE/VALID
2015-08-12 19:22:09,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local7167899_0009
2015-08-12 19:22:09,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:09,888 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:09,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:09,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:09,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFA5476216234035A8AA22DD9F41E856, ordinal: 0
2015-08-12 19:22:09,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:09,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:09,965 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFA5476216234035A8AA22DD9F41E856, mem on start (mb), free: 232, total: 747, max: 747
2015-08-12 19:22:09,973 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFA5476216234035A8AA22DD9F41E856, mem on close (mb), free: 232, total: 747, max: 747
2015-08-12 19:22:10,043 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:10,043 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:10,053 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BA95C72DB5314131B44DEF6091BD245A, ordinal: 1
2015-08-12 19:22:10,055 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:10,055 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2015-08-12 19:22:10,056 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA95C72DB5314131B44DEF6091BD245A, mem on start (mb), free: 226, total: 747, max: 747
2015-08-12 19:22:10,066 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BA95C72DB5314131B44DEF6091BD245A, mem on close (mb), free: 225, total: 747, max: 747
2015-08-12 19:22:10,095 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID/_temporary
2015-08-12 19:22:10,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.375
2015-08-12 19:22:10,250 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:10,251 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:10,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2015-08-12 19:22:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:10,353 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-08-12 19:22:10,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:10,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:10,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2015-08-12 19:22:10,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:10,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:10,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:10,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/VALID/VALID
2015-08-12 19:22:10,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local139670112_0010
2015-08-12 19:22:10,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:10,762 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:10,816 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:10,817 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:10,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACF4BCE37F6D475B8C173AAF760AD74E, ordinal: 0
2015-08-12 19:22:10,834 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:10,835 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:10,837 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACF4BCE37F6D475B8C173AAF760AD74E, mem on start (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:10,844 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACF4BCE37F6D475B8C173AAF760AD74E, mem on close (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:10,871 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:10,871 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:10,876 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FA4DF4B485D54929A802320700629E87, ordinal: 1
2015-08-12 19:22:10,878 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:10,878 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2015-08-12 19:22:10,886 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA4DF4B485D54929A802320700629E87, mem on start (mb), free: 226, total: 747, max: 747
2015-08-12 19:22:10,897 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-08-12 19:22:10,903 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-08-12 19:22:10,905 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA4DF4B485D54929A802320700629E87, mem on close (mb), free: 225, total: 747, max: 747
2015-08-12 19:22:10,909 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local139670112_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-08-12 19:22:10,919 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local139670112_0010 state at FAILED
2015-08-12 19:22:10,919 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:10,920 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:10,920 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:10,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:10,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/group/VALID/VALID
2015-08-12 19:22:10,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:10,941 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID/_temporary
2015-08-12 19:22:10,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.529
2015-08-12 19:22:10,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID
2015-08-12 19:22:10,944 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT
2015-08-12 19:22:10,944 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID
2015-08-12 19:22:10,945 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT
2015-08-12 19:22:10,945 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT
2015-08-12 19:22:11,032 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:11,033 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:11,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.098
2015-08-12 19:22:11,171 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:11,171 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-08-12 19:22:11,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:11,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:11,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2015-08-12 19:22:11,209 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:11,210 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:11,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:11,213 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsFail/fail
2015-08-12 19:22:11,370 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local2114585945_0011
2015-08-12 19:22:11,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:11,380 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:11,408 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:11,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:11,421 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7D0C4CBEA01420E800E5F2EEB680AFA, ordinal: 0
2015-08-12 19:22:11,424 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:11,424 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:11,424 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7D0C4CBEA01420E800E5F2EEB680AFA, mem on start (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:11,427 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7D0C4CBEA01420E800E5F2EEB680AFA, mem on close (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:11,444 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:11,444 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:11,449 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BD400EF1FA1A4A6EB2AA7CCADCB4100E, ordinal: 1
2015-08-12 19:22:11,450 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:11,451 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2015-08-12 19:22:11,451 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD400EF1FA1A4A6EB2AA7CCADCB4100E, mem on start (mb), free: 226, total: 747, max: 747
2015-08-12 19:22:11,459 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-08-12 19:22:11,460 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-08-12 19:22:11,461 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD400EF1FA1A4A6EB2AA7CCADCB4100E, mem on close (mb), free: 224, total: 747, max: 747
2015-08-12 19:22:11,463 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2114585945_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-08-12 19:22:11,465 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local2114585945_0011 state at FAILED
2015-08-12 19:22:11,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:11,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:11,469 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:11,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:11,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...tGroupAssertionsFail/fail
2015-08-12 19:22:11,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:11,490 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail/_temporary
2015-08-12 19:22:11,492 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.284
2015-08-12 19:22:11,492 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail
2015-08-12 19:22:11,532 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:11,533 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:11,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2015-08-12 19:22:11,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:11,598 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-08-12 19:22:11,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:11,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:11,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2015-08-12 19:22:11,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:11,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:11,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:11,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsPass/pass
2015-08-12 19:22:11,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local218033625_0012
2015-08-12 19:22:11,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:11,797 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:11,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:11,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:11,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F0400CC5D91E481DA65330DA2AF69866, ordinal: 0
2015-08-12 19:22:11,834 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:11,834 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:11,835 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0400CC5D91E481DA65330DA2AF69866, mem on start (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:11,839 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0400CC5D91E481DA65330DA2AF69866, mem on close (mb), free: 231, total: 747, max: 747
2015-08-12 19:22:11,863 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:11,863 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:11,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E42B0CF1006D4ABB9F6F43C899D5FD54, ordinal: 1
2015-08-12 19:22:11,875 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:11,881 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2015-08-12 19:22:11,884 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E42B0CF1006D4ABB9F6F43C899D5FD54, mem on start (mb), free: 225, total: 747, max: 747
2015-08-12 19:22:11,893 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E42B0CF1006D4ABB9F6F43C899D5FD54, mem on close (mb), free: 224, total: 747, max: 747
2015-08-12 19:22:11,920 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass/_temporary
2015-08-12 19:22:11,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.284
2015-08-12 19:22:11,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass
2015-08-12 19:22:11,995 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:11,998 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:12,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 19:22:12,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:12,062 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-08-12 19:22:12,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:12,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:12,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2015-08-12 19:22:12,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:12,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:12,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:12,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsFail/value/fail
2015-08-12 19:22:12,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local712554092_0013
2015-08-12 19:22:12,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:12,222 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:12,247 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:12,247 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:12,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B15D285E1B5541FCA1DDEF55E933D02A, ordinal: 0
2015-08-12 19:22:12,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:12,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:12,255 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B15D285E1B5541FCA1DDEF55E933D02A, mem on start (mb), free: 230, total: 747, max: 747
2015-08-12 19:22:12,259 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B15D285E1B5541FCA1DDEF55E933D02A, mem on close (mb), free: 230, total: 747, max: 747
2015-08-12 19:22:12,277 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:12,277 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:12,283 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BDC96CCD469E4DE5AD9ACA8E3797A812, ordinal: 1
2015-08-12 19:22:12,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:12,285 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2015-08-12 19:22:12,286 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDC96CCD469E4DE5AD9ACA8E3797A812, mem on start (mb), free: 224, total: 747, max: 747
2015-08-12 19:22:12,294 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-08-12 19:22:12,296 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-08-12 19:22:12,297 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDC96CCD469E4DE5AD9ACA8E3797A812, mem on close (mb), free: 222, total: 747, max: 747
2015-08-12 19:22:12,300 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local712554092_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-08-12 19:22:12,305 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local712554092_0013 state at FAILED
2015-08-12 19:22:12,306 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 19:22:12,306 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 19:22:12,306 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 19:22:12,314 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 19:22:12,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...AssertionsFail/value/fail
2015-08-12 19:22:12,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 19:22:12,325 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail/_temporary
2015-08-12 19:22:12,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.244
2015-08-12 19:22:12,329 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail
2015-08-12 19:22:12,358 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:12,359 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 19:22:12,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2015-08-12 19:22:12,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 19:22:12,414 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-08-12 19:22:12,440 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 19:22:12,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:12,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2015-08-12 19:22:12,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 19:22:12,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 19:22:12,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 19:22:12,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsPass/value/pass
2015-08-12 19:22:12,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local289014784_0014
2015-08-12 19:22:12,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 19:22:12,618 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 19:22:12,643 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:12,643 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:12,649 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1CAE75F452E475A9CE32422254B8187, ordinal: 0
2015-08-12 19:22:12,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 19:22:12,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:12,651 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1CAE75F452E475A9CE32422254B8187, mem on start (mb), free: 223, total: 740, max: 740
2015-08-12 19:22:12,655 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1CAE75F452E475A9CE32422254B8187, mem on close (mb), free: 223, total: 740, max: 740
2015-08-12 19:22:12,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 19:22:12,675 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 19:22:12,683 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CE01BBA051134CB4AE31EDE5B986BC99, ordinal: 1
2015-08-12 19:22:12,685 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-12 19:22:12,686 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2015-08-12 19:22:12,689 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CE01BBA051134CB4AE31EDE5B986BC99, mem on start (mb), free: 218, total: 740, max: 740
2015-08-12 19:22:12,702 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CE01BBA051134CB4AE31EDE5B986BC99, mem on close (mb), free: 217, total: 740, max: 740
2015-08-12 19:22:12,726 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass/_temporary
2015-08-12 19:22:12,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.285
2015-08-12 19:22:12,758 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass