Class cascading.operation.assertion.AppliedAssertionsPlatformTest

6

tests

0

failures

0

ignored

7.266s

duration

100%

successful

Tests

Test Duration Result
testGroupAssertionsFail 0.305s passed
testGroupAssertionsPass 0.307s passed
testGroupAssertionsRemoval 1.647s passed
testValueAssertionsFail 0.249s passed
testValueAssertionsPass 0.305s passed
testValueAssertionsRemoval 4.453s passed

Standard output

2016-01-15 04:50:56,159 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 04:50:56,179 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.operation.assertion.AppliedAssertionsPlatformTest, with platform: hadoop2-mr1
2016-01-15 04:50:56,207 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-15 04:50:56,901 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-15 04:50:57,034 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-15 04:50:57,149 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:50:57,151 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:50:57,224 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 9A723096012D4B1BB7BCDF7C3F8BFC2D
2016-01-15 04:50:57,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2016-01-15 04:50:57,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:50:57,413 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'
2016-01-15 04:50:57,565 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 04:50:57,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:50:57,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:57,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-15 04:50:57,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:50:57,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:50:57,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:50:57,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/NONE/STRICT
2016-01-15 04:50:58,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local715317854_0001
2016-01-15 04:50:58,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:50:58,390 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:50:58,529 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:50:58,529 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:50:58,542 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A2A73ABCFFD74727A88E28A4A0A919C1, ordinal: 0
2016-01-15 04:50:58,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:58,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:58,585 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2A73ABCFFD74727A88E28A4A0A919C1, mem on start (mb), free: 117, total: 281, max: 672
2016-01-15 04:50:58,596 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2A73ABCFFD74727A88E28A4A0A919C1, mem on close (mb), free: 117, total: 281, max: 672
2016-01-15 04:50:58,675 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:50:58,676 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:50:58,689 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C41950C5C1D841C2A18FE5006A4983DE, ordinal: 1
2016-01-15 04:50:58,693 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:58,694 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-15 04:50:58,694 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C41950C5C1D841C2A18FE5006A4983DE, mem on start (mb), free: 105, total: 281, max: 672
2016-01-15 04:50:58,714 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C41950C5C1D841C2A18FE5006A4983DE, mem on close (mb), free: 103, total: 281, max: 672
2016-01-15 04:50:58,756 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT/_temporary
2016-01-15 04:50:58,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:01.188
2016-01-15 04:50:58,839 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:50:58,840 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:50:58,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-01-15 04:50:58,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:50:58,940 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'
2016-01-15 04:50:58,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:50:58,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:58,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-15 04:50:58,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:50:58,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:50:58,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:50:58,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/value/VALID/STRICT
2016-01-15 04:50:59,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1804304603_0002
2016-01-15 04:50:59,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:50:59,190 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:50:59,217 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:50:59,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:50:59,229 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDB1D6F05F874C46BB4674C5735F6CEB, ordinal: 0
2016-01-15 04:50:59,229 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:59,230 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:59,230 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDB1D6F05F874C46BB4674C5735F6CEB, mem on start (mb), free: 57, total: 281, max: 672
2016-01-15 04:50:59,234 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDB1D6F05F874C46BB4674C5735F6CEB, mem on close (mb), free: 57, total: 281, max: 672
2016-01-15 04:50:59,251 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:50:59,251 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:50:59,265 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C504ADEC7796485B9004DAB280759513, ordinal: 1
2016-01-15 04:50:59,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:59,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-15 04:50:59,267 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C504ADEC7796485B9004DAB280759513, mem on start (mb), free: 54, total: 281, max: 672
2016-01-15 04:50:59,294 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C504ADEC7796485B9004DAB280759513, mem on close (mb), free: 288, total: 397, max: 672
2016-01-15 04:50:59,320 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT/_temporary
2016-01-15 04:50:59,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.351
2016-01-15 04:50:59,385 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:50:59,385 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:50:59,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-15 04:50:59,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:50:59,456 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'
2016-01-15 04:50:59,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:50:59,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:59,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-15 04:50:59,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:50:59,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:50:59,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:50:59,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/value/STRICT/STRICT
2016-01-15 04:50:59,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1125045622_0003
2016-01-15 04:50:59,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:50:59,741 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:50:59,807 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:50:59,807 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:50:59,821 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C44FE822CBBE482C958031CF97FAD817, ordinal: 0
2016-01-15 04:50:59,823 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:50:59,823 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:59,823 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44FE822CBBE482C958031CF97FAD817, mem on start (mb), free: 112, total: 397, max: 672
2016-01-15 04:50:59,827 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44FE822CBBE482C958031CF97FAD817, mem on close (mb), free: 112, total: 397, max: 672
2016-01-15 04:50:59,845 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:50:59,845 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:50:59,855 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A11118BA603243AC870FBFF5F85C9293, ordinal: 1
2016-01-15 04:50:59,856 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:50:59,856 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-15 04:50:59,856 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A11118BA603243AC870FBFF5F85C9293, mem on start (mb), free: 104, total: 397, max: 672
2016-01-15 04:50:59,867 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)
2016-01-15 04:50:59,870 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)
2016-01-15 04:50:59,875 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A11118BA603243AC870FBFF5F85C9293, mem on close (mb), free: 101, total: 397, max: 672
2016-01-15 04:50:59,877 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1125045622_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)
2016-01-15 04:50:59,878 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1125045622_0003 state at FAILED
2016-01-15 04:50:59,878 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:50:59,879 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:50:59,879 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:50:59,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:50:59,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/value/STRICT/STRICT
2016-01-15 04:50:59,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:50:59,889 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT/_temporary
2016-01-15 04:50:59,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.404
2016-01-15 04:50:59,924 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:50:59,925 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:50:59,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-01-15 04:50:59,994 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:50:59,994 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'
2016-01-15 04:51:00,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:00,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-15 04:51:00,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:00,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:00,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:00,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/value/NONE/VALID
2016-01-15 04:51:00,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local393966105_0004
2016-01-15 04:51:00,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:00,212 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:00,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:00,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,237 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CEF28CCF314E4231B9913379F56F7D1C, ordinal: 0
2016-01-15 04:51:00,239 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,239 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,239 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEF28CCF314E4231B9913379F56F7D1C, mem on start (mb), free: 169, total: 396, max: 672
2016-01-15 04:51:00,243 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEF28CCF314E4231B9913379F56F7D1C, mem on close (mb), free: 169, total: 396, max: 672
2016-01-15 04:51:00,258 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:00,258 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F4F2C208AA8B4A7FA23DA570EBB2B978, ordinal: 1
2016-01-15 04:51:00,267 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,267 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-15 04:51:00,267 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4F2C208AA8B4A7FA23DA570EBB2B978, mem on start (mb), free: 161, total: 396, max: 672
2016-01-15 04:51:00,277 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4F2C208AA8B4A7FA23DA570EBB2B978, mem on close (mb), free: 158, total: 396, max: 672
2016-01-15 04:51:00,296 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID/_temporary
2016-01-15 04:51:00,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.279
2016-01-15 04:51:00,343 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:00,343 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:00,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-15 04:51:00,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:00,402 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'
2016-01-15 04:51:00,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:00,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-15 04:51:00,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:00,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:00,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:00,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/VALID/VALID
2016-01-15 04:51:00,552 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1197335535_0005
2016-01-15 04:51:00,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:00,560 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:00,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:00,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A225A341393C4B0F9B8B9AD30F5DB1BF, ordinal: 0
2016-01-15 04:51:00,604 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,604 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,604 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A225A341393C4B0F9B8B9AD30F5DB1BF, mem on start (mb), free: 184, total: 395, max: 672
2016-01-15 04:51:00,607 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A225A341393C4B0F9B8B9AD30F5DB1BF, mem on close (mb), free: 184, total: 395, max: 672
2016-01-15 04:51:00,622 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:00,622 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,630 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E0C49A010E294E5F84223D7F06CD20D1, ordinal: 1
2016-01-15 04:51:00,631 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,631 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-15 04:51:00,632 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0C49A010E294E5F84223D7F06CD20D1, mem on start (mb), free: 177, total: 395, max: 672
2016-01-15 04:51:00,640 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)
2016-01-15 04:51:00,641 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)
2016-01-15 04:51:00,642 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E0C49A010E294E5F84223D7F06CD20D1, mem on close (mb), free: 174, total: 395, max: 672
2016-01-15 04:51:00,644 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1197335535_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)
2016-01-15 04:51:00,647 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1197335535_0005 state at FAILED
2016-01-15 04:51:00,647 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:51:00,647 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:51:00,647 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:51:00,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:51:00,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/value/VALID/VALID
2016-01-15 04:51:00,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:51:00,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2016-01-15 04:51:00,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2016-01-15 04:51:00,653 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID/_temporary
2016-01-15 04:51:00,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.229
2016-01-15 04:51:00,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT
2016-01-15 04:51:00,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID
2016-01-15 04:51:00,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT
2016-01-15 04:51:00,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT
2016-01-15 04:51:00,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID
2016-01-15 04:51:00,685 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:00,685 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:00,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-15 04:51:00,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:00,741 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'
2016-01-15 04:51:00,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:00,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-15 04:51:00,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:00,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:00,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:00,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/NONE/STRICT
2016-01-15 04:51:00,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1695231566_0006
2016-01-15 04:51:00,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:00,880 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:00,911 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:00,912 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,919 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5B729C7908B401AA4C9DE0A562C3F5A, ordinal: 0
2016-01-15 04:51:00,919 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:00,919 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,920 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B729C7908B401AA4C9DE0A562C3F5A, mem on start (mb), free: 178, total: 389, max: 672
2016-01-15 04:51:00,922 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B729C7908B401AA4C9DE0A562C3F5A, mem on close (mb), free: 178, total: 389, max: 672
2016-01-15 04:51:00,937 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:00,937 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:00,945 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EE6C9D01B1584167931DA4A55CC932BC, ordinal: 1
2016-01-15 04:51:00,945 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:00,946 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-15 04:51:00,946 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE6C9D01B1584167931DA4A55CC932BC, mem on start (mb), free: 170, total: 389, max: 672
2016-01-15 04:51:00,956 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE6C9D01B1584167931DA4A55CC932BC, mem on close (mb), free: 168, total: 389, max: 672
2016-01-15 04:51:00,986 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT/_temporary
2016-01-15 04:51:00,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.227
2016-01-15 04:51:01,039 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:01,039 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:01,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-15 04:51:01,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:01,098 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'
2016-01-15 04:51:01,115 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:01,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-15 04:51:01,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:01,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:01,118 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:01,118 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/group/VALID/STRICT
2016-01-15 04:51:01,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local506060002_0007
2016-01-15 04:51:01,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:01,241 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:01,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:01,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9C630CD30F64F71B6B7E25B6565A0A2, ordinal: 0
2016-01-15 04:51:01,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,276 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,276 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9C630CD30F64F71B6B7E25B6565A0A2, mem on start (mb), free: 182, total: 394, max: 672
2016-01-15 04:51:01,280 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9C630CD30F64F71B6B7E25B6565A0A2, mem on close (mb), free: 182, total: 394, max: 672
2016-01-15 04:51:01,302 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:01,302 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,309 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE25FA0705034BA190AFDC16183EFD1D, ordinal: 1
2016-01-15 04:51:01,310 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,311 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-15 04:51:01,311 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE25FA0705034BA190AFDC16183EFD1D, mem on start (mb), free: 176, total: 394, max: 672
2016-01-15 04:51:01,320 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE25FA0705034BA190AFDC16183EFD1D, mem on close (mb), free: 174, total: 394, max: 672
2016-01-15 04:51:01,349 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT/_temporary
2016-01-15 04:51:01,349 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.234
2016-01-15 04:51:01,395 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:01,395 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:01,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-15 04:51:01,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:01,455 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'
2016-01-15 04:51:01,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-15 04:51:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:01,475 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/group/STRICT/STRICT
2016-01-15 04:51:01,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1904576931_0008
2016-01-15 04:51:01,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:01,633 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:01,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:01,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,663 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B1E7D67B15DF4BE698091974E67C182F, ordinal: 0
2016-01-15 04:51:01,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,665 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1E7D67B15DF4BE698091974E67C182F, mem on start (mb), free: 171, total: 384, max: 672
2016-01-15 04:51:01,667 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1E7D67B15DF4BE698091974E67C182F, mem on close (mb), free: 171, total: 384, max: 672
2016-01-15 04:51:01,681 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:01,681 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,688 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EF43FA10FE654E3686CBA42EDB13143B, ordinal: 1
2016-01-15 04:51:01,690 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,690 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-15 04:51:01,690 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EF43FA10FE654E3686CBA42EDB13143B, mem on start (mb), free: 165, total: 384, max: 672
2016-01-15 04:51:01,700 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)
2016-01-15 04:51:01,700 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)
2016-01-15 04:51:01,701 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EF43FA10FE654E3686CBA42EDB13143B, mem on close (mb), free: 163, total: 384, max: 672
2016-01-15 04:51:01,703 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1904576931_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)
2016-01-15 04:51:01,704 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1904576931_0008 state at FAILED
2016-01-15 04:51:01,704 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:51:01,705 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:51:01,705 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:51:01,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:51:01,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/group/STRICT/STRICT
2016-01-15 04:51:01,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:51:01,712 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT/_temporary
2016-01-15 04:51:01,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.239
2016-01-15 04:51:01,733 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:01,734 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:01,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 04:51:01,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:01,777 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'
2016-01-15 04:51:01,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:01,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-15 04:51:01,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:01,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:01,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:01,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/group/NONE/VALID
2016-01-15 04:51:01,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1158030320_0009
2016-01-15 04:51:01,903 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:01,908 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:01,930 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:01,930 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B15F01865042458381A5407D79362868, ordinal: 0
2016-01-15 04:51:01,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:01,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,939 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B15F01865042458381A5407D79362868, mem on start (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:01,942 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B15F01865042458381A5407D79362868, mem on close (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:01,954 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:01,955 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:01,962 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BDC4F32F0D5F45069F601790F377D1CC, ordinal: 1
2016-01-15 04:51:01,962 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:01,963 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-15 04:51:01,963 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDC4F32F0D5F45069F601790F377D1CC, mem on start (mb), free: 175, total: 394, max: 672
2016-01-15 04:51:01,973 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BDC4F32F0D5F45069F601790F377D1CC, mem on close (mb), free: 173, total: 394, max: 672
2016-01-15 04:51:01,994 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID/_temporary
2016-01-15 04:51:01,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.201
2016-01-15 04:51:02,044 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:02,045 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:02,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-15 04:51:02,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:02,083 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'
2016-01-15 04:51:02,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:02,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-15 04:51:02,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:02,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:02,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:02,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/VALID/VALID
2016-01-15 04:51:02,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1323876066_0010
2016-01-15 04:51:02,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:02,218 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:02,239 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:02,239 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,246 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D6F0BAE1DE904AC886D5B1FDDFABE30D, ordinal: 0
2016-01-15 04:51:02,247 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,247 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,247 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6F0BAE1DE904AC886D5B1FDDFABE30D, mem on start (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:02,249 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6F0BAE1DE904AC886D5B1FDDFABE30D, mem on close (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:02,263 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:02,263 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,270 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F59D2FBE341343C98A72BB04BF86B8DA, ordinal: 1
2016-01-15 04:51:02,270 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,271 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-15 04:51:02,271 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F59D2FBE341343C98A72BB04BF86B8DA, mem on start (mb), free: 175, total: 394, max: 672
2016-01-15 04:51:02,280 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)
2016-01-15 04:51:02,286 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)
2016-01-15 04:51:02,290 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F59D2FBE341343C98A72BB04BF86B8DA, mem on close (mb), free: 173, total: 394, max: 672
2016-01-15 04:51:02,292 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1323876066_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)
2016-01-15 04:51:02,300 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1323876066_0010 state at FAILED
2016-01-15 04:51:02,300 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:51:02,301 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:51:02,301 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:51:02,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:51:02,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/group/VALID/VALID
2016-01-15 04:51:02,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:51:02,305 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID/_temporary
2016-01-15 04:51:02,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.206
2016-01-15 04:51:02,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID
2016-01-15 04:51:02,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID
2016-01-15 04:51:02,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT
2016-01-15 04:51:02,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT
2016-01-15 04:51:02,307 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT
2016-01-15 04:51:02,323 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:02,323 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:02,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-15 04:51:02,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:02,377 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'
2016-01-15 04:51:02,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:02,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-15 04:51:02,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:02,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:02,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:02,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsFail/fail
2016-01-15 04:51:02,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1337919189_0011
2016-01-15 04:51:02,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:02,515 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:02,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:02,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,543 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DD18E7087597449A95AF476DCBC069B5, ordinal: 0
2016-01-15 04:51:02,544 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,544 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,545 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD18E7087597449A95AF476DCBC069B5, mem on start (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:02,548 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD18E7087597449A95AF476DCBC069B5, mem on close (mb), free: 181, total: 394, max: 672
2016-01-15 04:51:02,566 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:02,566 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,573 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EB222BB734344F889A71EFC7490AA681, ordinal: 1
2016-01-15 04:51:02,574 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,574 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-15 04:51:02,574 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EB222BB734344F889A71EFC7490AA681, mem on start (mb), free: 175, total: 394, max: 672
2016-01-15 04:51:02,585 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)
2016-01-15 04:51:02,591 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)
2016-01-15 04:51:02,597 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EB222BB734344F889A71EFC7490AA681, mem on close (mb), free: 173, total: 394, max: 672
2016-01-15 04:51:02,598 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1337919189_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)
2016-01-15 04:51:02,603 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1337919189_0011 state at FAILED
2016-01-15 04:51:02,603 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:51:02,603 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:51:02,603 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:51:02,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:51:02,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...tGroupAssertionsFail/fail
2016-01-15 04:51:02,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:51:02,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail/_temporary
2016-01-15 04:51:02,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.217
2016-01-15 04:51:02,612 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsFail/fail
2016-01-15 04:51:02,630 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:02,630 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:02,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 04:51:02,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:02,672 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'
2016-01-15 04:51:02,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:02,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-15 04:51:02,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:02,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:02,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:02,686 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsPass/pass
2016-01-15 04:51:02,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local2002255994_0012
2016-01-15 04:51:02,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:02,814 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:02,833 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:02,833 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD0623046C904259AE9153FE1B8D3ED0, ordinal: 0
2016-01-15 04:51:02,841 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,841 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,841 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD0623046C904259AE9153FE1B8D3ED0, mem on start (mb), free: 180, total: 394, max: 672
2016-01-15 04:51:02,844 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD0623046C904259AE9153FE1B8D3ED0, mem on close (mb), free: 180, total: 394, max: 672
2016-01-15 04:51:02,856 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:02,856 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:02,861 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FE7B038FFDCC466F912557D60B626CA9, ordinal: 1
2016-01-15 04:51:02,862 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:02,862 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-15 04:51:02,862 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE7B038FFDCC466F912557D60B626CA9, mem on start (mb), free: 175, total: 394, max: 672
2016-01-15 04:51:02,871 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE7B038FFDCC466F912557D60B626CA9, mem on close (mb), free: 173, total: 394, max: 672
2016-01-15 04:51:02,895 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass/_temporary
2016-01-15 04:51:02,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.211
2016-01-15 04:51:02,919 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testGroupAssertionsPass/pass
2016-01-15 04:51:02,935 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:02,936 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:02,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 04:51:02,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:02,970 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'
2016-01-15 04:51:02,983 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:02,983 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:02,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-15 04:51:02,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:02,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:02,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:02,985 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsFail/value/fail
2016-01-15 04:51:03,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1310023267_0013
2016-01-15 04:51:03,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:03,096 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:03,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:03,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:03,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD23BB940DE94641ADD306594129FA84, ordinal: 0
2016-01-15 04:51:03,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:03,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:03,122 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD23BB940DE94641ADD306594129FA84, mem on start (mb), free: 179, total: 393, max: 672
2016-01-15 04:51:03,125 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD23BB940DE94641ADD306594129FA84, mem on close (mb), free: 179, total: 393, max: 672
2016-01-15 04:51:03,137 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:03,137 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:03,144 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FE4E005A5B23424C8CF34F054486D678, ordinal: 1
2016-01-15 04:51:03,144 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:03,144 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-15 04:51:03,145 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE4E005A5B23424C8CF34F054486D678, mem on start (mb), free: 173, total: 393, max: 672
2016-01-15 04:51:03,154 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)
2016-01-15 04:51:03,155 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)
2016-01-15 04:51:03,157 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FE4E005A5B23424C8CF34F054486D678, mem on close (mb), free: 171, total: 393, max: 672
2016-01-15 04:51:03,160 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1310023267_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)
2016-01-15 04:51:03,164 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1310023267_0013 state at FAILED
2016-01-15 04:51:03,164 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-15 04:51:03,164 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-15 04:51:03,164 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-15 04:51:03,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-15 04:51:03,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...AssertionsFail/value/fail
2016-01-15 04:51:03,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-15 04:51:03,169 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail/_temporary
2016-01-15 04:51:03,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.186
2016-01-15 04:51:03,169 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsFail/value/fail
2016-01-15 04:51:03,190 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:51:03,190 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 04:51:03,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 04:51:03,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:51:03,235 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'
2016-01-15 04:51:03,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 04:51:03,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:03,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-15 04:51:03,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 04:51:03,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 04:51:03,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 04:51:03,248 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsPass/value/pass
2016-01-15 04:51:03,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local149438651_0014
2016-01-15 04:51:03,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 04:51:03,360 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt
2016-01-15 04:51:03,378 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 04:51:03,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 04:51:03,384 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD5736551EC844DA9C420D18DDD7BE16, ordinal: 0
2016-01-15 04:51:03,385 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:51:03,385 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:03,386 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD5736551EC844DA9C420D18DDD7BE16, mem on start (mb), free: 179, total: 393, max: 672
2016-01-15 04:51:03,388 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD5736551EC844DA9C420D18DDD7BE16, mem on close (mb), free: 179, total: 393, max: 672
2016-01-15 04:51:03,401 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 04:51:03,401 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 04:51:03,407 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AA2BFE97AA124285AC68B3FB3EA8EDD7, ordinal: 1
2016-01-15 04:51:03,408 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-15 04:51:03,408 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-15 04:51:03,408 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA2BFE97AA124285AC68B3FB3EA8EDD7, mem on start (mb), free: 174, total: 393, max: 672
2016-01-15 04:51:03,418 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA2BFE97AA124285AC68B3FB3EA8EDD7, mem on close (mb), free: 172, total: 393, max: 672
2016-01-15 04:51:03,444 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass/_temporary
2016-01-15 04:51:03,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.198
2016-01-15 04:51:03,475 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/testValueAssertionsPass/value/pass