2015-08-14 05:49:02,227 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 05:49:02,290 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 05:49:02,291 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.operation.assertion.AppliedAssertionsPlatformTest
2015-08-14 05:49:02,337 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 05:49:02,989 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 05:49:03,156 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 05:49:03,300 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:03,303 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:03,317 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 604F573A9A7F4B85A68D2406E9EFD3A1
2015-08-14 05:49:03,593 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 05:49:03,594 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:03,595 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:03,595 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT"]
2015-08-14 05:49:03,596 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:03,596 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:03,596 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:03,599 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/NONE/STRICT
2015-08-14 05:49:04,321 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity451212956/.staging/job_local451212956_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:04,333 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity451212956/.staging/job_local451212956_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:04,523 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local451212956_0001/job_local451212956_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:04,530 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local451212956_0001/job_local451212956_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:04,541 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local451212956_0001
2015-08-14 05:49:04,541 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:04,664 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:04,860 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:04,860 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:04,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:04,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:05,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:05,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:05,138 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:05,138 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT"]
2015-08-14 05:49:05,222 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT/_temporary
2015-08-14 05:49:05,301 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:05,302 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:05,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:05,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:05,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT"]
2015-08-14 05:49:05,347 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:05,347 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:05,347 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:05,348 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/value/VALID/STRICT
2015-08-14 05:49:05,515 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity399886036/.staging/job_local399886036_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:05,516 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity399886036/.staging/job_local399886036_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:05,632 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local399886036_0002/job_local399886036_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:05,635 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local399886036_0002/job_local399886036_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:05,636 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local399886036_0002
2015-08-14 05:49:05,636 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:05,646 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:05,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:05,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:05,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:05,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:05,842 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:05,842 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:05,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:05,856 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT"]
2015-08-14 05:49:05,902 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT/_temporary
2015-08-14 05:49:05,990 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:05,990 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:06,031 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:06,032 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:06,032 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT"]
2015-08-14 05:49:06,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:06,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:06,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:06,034 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/value/STRICT/STRICT
2015-08-14 05:49:06,176 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1410395919/.staging/job_local1410395919_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:06,178 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1410395919/.staging/job_local1410395919_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:06,265 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1410395919_0003/job_local1410395919_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:06,268 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1410395919_0003/job_local1410395919_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:06,269 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1410395919_0003
2015-08-14 05:49:06,269 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:06,279 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:06,429 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:06,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:06,446 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:06,446 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:06,480 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:06,481 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:06,495 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:06,496 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT"]
2015-08-14 05:49:06,511 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:06,514 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:06,518 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1410395919_0003
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:06,525 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local1410395919_0003 state at FAILED
2015-08-14 05:49:06,525 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:06,526 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:06,526 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:06,537 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:06,538 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/value/STRICT/STRICT
2015-08-14 05:49:06,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:06,539 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT/_temporary
2015-08-14 05:49:06,571 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:06,572 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:06,606 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:06,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID"]
2015-08-14 05:49:06,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:06,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:06,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:06,608 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/value/NONE/VALID
2015-08-14 05:49:06,706 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1675696103/.staging/job_local1675696103_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:06,708 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1675696103/.staging/job_local1675696103_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:06,783 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1675696103_0004/job_local1675696103_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:06,785 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1675696103_0004/job_local1675696103_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:06,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1675696103_0004
2015-08-14 05:49:06,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:06,797 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:06,951 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:06,951 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:06,963 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:06,963 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:06,992 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:06,993 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:07,004 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:07,005 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID"]
2015-08-14 05:49:07,052 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID/_temporary
2015-08-14 05:49:07,114 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:07,115 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:07,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:07,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:07,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID"]
2015-08-14 05:49:07,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:07,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:07,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:07,151 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/VALID/VALID
2015-08-14 05:49:07,270 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2124122888/.staging/job_local2124122888_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:07,272 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2124122888/.staging/job_local2124122888_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:07,359 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2124122888_0005/job_local2124122888_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:07,362 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2124122888_0005/job_local2124122888_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:07,362 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2124122888_0005
2015-08-14 05:49:07,363 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:07,374 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:07,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:07,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:07,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:07,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:07,562 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:07,563 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:07,574 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:07,574 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID"]
2015-08-14 05:49:07,587 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:07,588 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:07,592 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2124122888_0005
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:07,599 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local2124122888_0005 state at FAILED
2015-08-14 05:49:07,599 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:07,599 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:07,599 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:07,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:07,608 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/value/VALID/VALID
2015-08-14 05:49:07,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:07,610 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID/_temporary
2015-08-14 05:49:07,610 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/STRICT/STRICT
2015-08-14 05:49:07,610 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/NONE/STRICT
2015-08-14 05:49:07,611 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/VALID/STRICT
2015-08-14 05:49:07,611 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/NONE/VALID
2015-08-14 05:49:07,611 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/VALID/VALID
2015-08-14 05:49:07,640 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:07,640 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:07,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:07,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:07,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT"]
2015-08-14 05:49:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:07,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:07,672 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/NONE/STRICT
2015-08-14 05:49:07,761 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity579942261/.staging/job_local579942261_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:07,762 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity579942261/.staging/job_local579942261_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:07,816 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local579942261_0006/job_local579942261_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:07,818 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local579942261_0006/job_local579942261_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:07,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local579942261_0006
2015-08-14 05:49:07,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:07,827 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:08,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:08,190 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:08,201 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:08,201 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:08,228 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:08,228 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:08,238 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:08,238 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT"]
2015-08-14 05:49:08,284 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT/_temporary
2015-08-14 05:49:08,346 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:08,347 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:08,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:08,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:08,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT"]
2015-08-14 05:49:08,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:08,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:08,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:08,381 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/group/VALID/STRICT
2015-08-14 05:49:08,469 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2051606889/.staging/job_local2051606889_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:08,470 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity2051606889/.staging/job_local2051606889_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:08,527 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2051606889_0007/job_local2051606889_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:08,528 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2051606889_0007/job_local2051606889_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:08,529 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2051606889_0007
2015-08-14 05:49:08,530 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:08,537 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:08,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:08,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:08,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:08,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:08,720 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:08,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:08,729 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:08,730 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT"]
2015-08-14 05:49:08,773 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT/_temporary
2015-08-14 05:49:08,838 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:08,839 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:08,873 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:08,873 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:08,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT"]
2015-08-14 05:49:08,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:08,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:08,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:08,875 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/group/STRICT/STRICT
2015-08-14 05:49:08,960 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1889296789/.staging/job_local1889296789_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:08,961 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1889296789/.staging/job_local1889296789_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,014 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1889296789_0008/job_local1889296789_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:09,016 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1889296789_0008/job_local1889296789_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,017 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1889296789_0008
2015-08-14 05:49:09,018 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:09,025 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:09,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:09,170 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:09,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:09,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:09,210 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:09,211 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:09,221 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:09,222 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT"]
2015-08-14 05:49:09,234 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:09,235 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:09,239 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1889296789_0008
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:09,243 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local1889296789_0008 state at FAILED
2015-08-14 05:49:09,243 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:09,243 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:09,243 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:09,250 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:09,251 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/group/STRICT/STRICT
2015-08-14 05:49:09,251 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:09,252 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT/_temporary
2015-08-14 05:49:09,276 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:09,276 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:09,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID"]
2015-08-14 05:49:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:09,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:09,307 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/group/NONE/VALID
2015-08-14 05:49:09,401 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1714560865/.staging/job_local1714560865_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:09,402 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity1714560865/.staging/job_local1714560865_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,478 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1714560865_0009/job_local1714560865_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:09,480 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1714560865_0009/job_local1714560865_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,481 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1714560865_0009
2015-08-14 05:49:09,481 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:09,489 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:09,639 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:09,639 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:09,648 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:09,649 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:09,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:09,674 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:09,683 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:09,683 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID"]
2015-08-14 05:49:09,722 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID/_temporary
2015-08-14 05:49:09,779 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:09,780 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:09,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:09,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:09,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID"]
2015-08-14 05:49:09,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:09,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:09,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:09,806 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/VALID/VALID
2015-08-14 05:49:09,892 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity670515837/.staging/job_local670515837_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:09,893 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity670515837/.staging/job_local670515837_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,948 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local670515837_0010/job_local670515837_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:09,950 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local670515837_0010/job_local670515837_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:09,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local670515837_0010
2015-08-14 05:49:09,951 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:09,958 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:10,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:10,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:10,285 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:10,285 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:10,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:10,313 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:10,323 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:10,323 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID"]
2015-08-14 05:49:10,335 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,337 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,343 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local670515837_0010
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,344 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local670515837_0010 state at FAILED
2015-08-14 05:49:10,345 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:10,345 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:10,345 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:10,351 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:10,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/group/VALID/VALID
2015-08-14 05:49:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:10,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] shutting down job executor
2015-08-14 05:49:10,353 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] shutdown complete
2015-08-14 05:49:10,353 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID/_temporary
2015-08-14 05:49:10,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/NONE/STRICT
2015-08-14 05:49:10,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/VALID/STRICT
2015-08-14 05:49:10,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/NONE/VALID
2015-08-14 05:49:10,355 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/VALID/VALID
2015-08-14 05:49:10,355 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/group/STRICT/STRICT
2015-08-14 05:49:10,380 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:10,381 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:10,406 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:10,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:10,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/fail"]
2015-08-14 05:49:10,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:10,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:10,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/fail
2015-08-14 05:49:10,495 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity522388635/.staging/job_local522388635_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:10,496 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity522388635/.staging/job_local522388635_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:10,548 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local522388635_0011/job_local522388635_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:10,549 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local522388635_0011/job_local522388635_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:10,550 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local522388635_0011
2015-08-14 05:49:10,550 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:10,557 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:10,706 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:10,706 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:10,718 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:10,718 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:10,742 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:10,742 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:10,751 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:10,751 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/fail"]
2015-08-14 05:49:10,761 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,762 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,765 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local522388635_0011
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:125)
at cascading.flow.stream.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:34)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:10,774 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local522388635_0011 state at FAILED
2015-08-14 05:49:10,774 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:10,774 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:10,774 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:10,781 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:10,781 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...edassertionsplatform/fail
2015-08-14 05:49:10,782 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:10,782 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/fail/_temporary
2015-08-14 05:49:10,783 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/fail
2015-08-14 05:49:10,804 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:10,805 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:10,826 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:10,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:10,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/pass"]
2015-08-14 05:49:10,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:10,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:10,828 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:10,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/pass
2015-08-14 05:49:10,912 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity521729951/.staging/job_local521729951_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:10,914 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity521729951/.staging/job_local521729951_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:10,979 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local521729951_0012/job_local521729951_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:10,981 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local521729951_0012/job_local521729951_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:10,982 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local521729951_0012
2015-08-14 05:49:10,982 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:10,989 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:11,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:11,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:11,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,168 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:11,168 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,177 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,178 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/pass"]
2015-08-14 05:49:11,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/pass/_temporary
2015-08-14 05:49:11,255 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/pass
2015-08-14 05:49:11,276 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:11,277 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:11,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:11,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:11,298 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/fail"]
2015-08-14 05:49:11,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:11,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:11,300 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:11,301 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/fail
2015-08-14 05:49:11,380 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity428168199/.staging/job_local428168199_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:11,381 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity428168199/.staging/job_local428168199_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:11,430 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local428168199_0013/job_local428168199_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:11,432 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local428168199_0013/job_local428168199_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:11,433 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local428168199_0013
2015-08-14 05:49:11,434 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:11,440 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:11,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:11,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:11,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:11,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,631 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,631 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/fail"]
2015-08-14 05:49:11,641 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:11,642 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:11,645 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local428168199_0013
java.lang.Exception: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:70)
at cascading.flow.stream.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:34)
at cascading.flow.stream.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:67)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:151)
at cascading.flow.stream.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:39)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 05:49:11,648 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local428168199_0013 state at FAILED
2015-08-14 05:49:11,648 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-14 05:49:11,648 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-14 05:49:11,648 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-14 05:49:11,654 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-14 05:49:11,656 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...rtionsplatform/value/fail
2015-08-14 05:49:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-14 05:49:11,657 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] shutting down job executor
2015-08-14 05:49:11,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] shutdown complete
2015-08-14 05:49:11,658 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/fail/_temporary
2015-08-14 05:49:11,659 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/fail
2015-08-14 05:49:11,679 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:49:11,680 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 05:49:11,699 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 05:49:11,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:11,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/pass"]
2015-08-14 05:49:11,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 05:49:11,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 05:49:11,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 05:49:11,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/pass
2015-08-14 05:49:11,782 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity502058892/.staging/job_local502058892_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:11,783 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/staging/teamcity502058892/.staging/job_local502058892_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:11,836 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local502058892_0014/job_local502058892_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 05:49:11,837 WARN conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local502058892_0014/job_local502058892_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 05:49:11,838 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local502058892_0014
2015-08-14 05:49:11,838 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 05:49:11,844 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt
2015-08-14 05:49:11,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 05:49:11,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,904 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/apache.10.txt"]
2015-08-14 05:49:11,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,931 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 05:49:11,931 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 05:49:11,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-14 05:49:11,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/pass"]
2015-08-14 05:49:11,983 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/appliedassertionsplatform/value/pass/_temporary
2015-08-14 05:49:12,020 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/appliedassertionsplatform/value/pass