2015-08-13 21:39:20,800 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 21:39:20,854 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 21:39:20,854 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.operation.assertion.AppliedAssertionsPlatformTest
2015-08-13 21:39:20,894 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 21:39:21,178 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 21:39:21,292 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:21,294 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:21,307 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: B01AAF2F796C4693A29C3DE8CF65FDE7
2015-08-13 21:39:21,550 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 21:39:21,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:21,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:21,555 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT"]
2015-08-13 21:39:21,556 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:21,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/NONE/STRICT
2015-08-13 21:39:21,608 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 21:39:21,654 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 21:39:21,862 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0001
2015-08-13 21:39:21,863 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:21,943 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:22,119 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:22,120 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:22,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:22,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:24,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:24,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:24,957 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:24,957 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT"]
2015-08-13 21:39:27,938 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/STRICT/_temporary
2015-08-13 21:39:27,994 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:27,995 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:28,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:28,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:28,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT"]
2015-08-13 21:39:28,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:28,036 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:28,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:28,038 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/value/VALID/STRICT
2015-08-13 21:39:28,140 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0002
2015-08-13 21:39:28,141 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:28,147 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:28,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:28,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:28,306 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:28,306 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:31,155 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:31,155 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:31,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:31,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT"]
2015-08-13 21:39:34,164 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/STRICT/_temporary
2015-08-13 21:39:34,226 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:34,227 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:34,265 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:34,266 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:34,266 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT"]
2015-08-13 21:39:34,267 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:34,267 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:34,267 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:34,268 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/value/STRICT/STRICT
2015-08-13 21:39:34,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0003
2015-08-13 21:39:34,359 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:34,366 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:34,504 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:34,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:34,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:34,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:37,372 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:37,373 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:37,386 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:37,387 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT"]
2015-08-13 21:39:37,396 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:37,399 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:37,404 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0003
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:37,407 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0003 state at FAILED
2015-08-13 21:39:37,408 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:39:37,409 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:39:37,409 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:39:37,410 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:39:37,410 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/value/STRICT/STRICT
2015-08-13 21:39:37,411 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:39:37,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/STRICT/STRICT/_temporary
2015-08-13 21:39:37,430 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:37,431 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:37,461 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:37,461 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:37,462 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID"]
2015-08-13 21:39:37,462 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:37,463 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:37,463 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:37,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/value/NONE/VALID
2015-08-13 21:39:37,524 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0004
2015-08-13 21:39:37,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:37,532 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:37,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:37,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:37,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:37,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:40,542 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:40,542 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:40,553 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:40,554 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID"]
2015-08-13 21:39:43,547 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/NONE/VALID/_temporary
2015-08-13 21:39:43,594 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:43,595 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:43,628 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:43,629 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:43,629 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID"]
2015-08-13 21:39:43,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:43,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:43,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:43,631 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/value/VALID/VALID
2015-08-13 21:39:43,688 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0005
2015-08-13 21:39:43,689 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:43,694 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:43,829 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:43,829 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:43,842 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:43,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:46,702 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:46,702 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:46,714 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:46,715 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID"]
2015-08-13 21:39:46,722 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:46,723 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:46,726 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0005
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:39:46,736 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0005 state at FAILED
2015-08-13 21:39:46,736 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:39:46,736 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:39:46,736 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:39:46,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:39:46,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/value/VALID/VALID
2015-08-13 21:39:46,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:39:46,738 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/VALID/VALID/_temporary
2015-08-13 21:39:46,738 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/NONE/STRICT
2015-08-13 21:39:46,738 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/NONE/VALID
2015-08-13 21:39:46,739 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/VALID/STRICT
2015-08-13 21:39:46,739 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/VALID/VALID
2015-08-13 21:39:46,739 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/STRICT/STRICT
2015-08-13 21:39:46,760 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:46,760 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:46,788 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:46,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:46,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT"]
2015-08-13 21:39:46,790 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:46,790 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:46,790 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:46,792 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/NONE/STRICT
2015-08-13 21:39:46,845 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0006
2015-08-13 21:39:46,846 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:46,851 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:47,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:47,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:47,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:47,214 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:49,857 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:49,858 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:49,868 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:49,869 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT"]
2015-08-13 21:39:52,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/STRICT/_temporary
2015-08-13 21:39:52,888 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:52,889 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:52,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:52,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:52,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT"]
2015-08-13 21:39:52,917 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:52,917 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:52,917 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:52,919 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...atform/group/VALID/STRICT
2015-08-13 21:39:52,967 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0007
2015-08-13 21:39:52,967 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:52,972 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:53,112 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:53,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:53,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:53,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:55,978 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:39:55,979 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:39:55,988 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:39:55,988 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT"]
2015-08-13 21:39:58,983 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/STRICT/_temporary
2015-08-13 21:39:59,010 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:39:59,010 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:39:59,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:39:59,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:59,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT"]
2015-08-13 21:39:59,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:39:59,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:39:59,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:39:59,042 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/group/STRICT/STRICT
2015-08-13 21:39:59,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0008
2015-08-13 21:39:59,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:39:59,104 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:39:59,240 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:39:59,240 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:39:59,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:39:59,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:02,110 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:02,110 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:02,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:02,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT"]
2015-08-13 21:40:02,128 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:02,129 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:02,131 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0008
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:02,135 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0008 state at FAILED
2015-08-13 21:40:02,136 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:40:02,136 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:40:02,136 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:40:02,136 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:40:02,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/group/STRICT/STRICT
2015-08-13 21:40:02,138 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:40:02,139 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/STRICT/STRICT/_temporary
2015-08-13 21:40:02,153 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:02,154 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:02,179 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID"]
2015-08-13 21:40:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:02,181 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:02,181 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:02,181 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/group/NONE/VALID
2015-08-13 21:40:02,223 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0009
2015-08-13 21:40:02,224 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:02,229 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:02,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:02,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:02,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:02,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:05,236 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:05,236 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:05,245 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:05,245 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID"]
2015-08-13 21:40:08,244 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/NONE/VALID/_temporary
2015-08-13 21:40:08,271 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:08,271 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:08,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:08,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:08,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID"]
2015-08-13 21:40:08,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:08,297 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:08,298 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:08,298 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...latform/group/VALID/VALID
2015-08-13 21:40:08,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0010
2015-08-13 21:40:08,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:08,351 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:08,496 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:08,496 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:08,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:08,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:11,357 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:11,357 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:11,368 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:11,368 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID"]
2015-08-13 21:40:11,374 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:11,375 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:11,377 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:11,382 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0010 state at FAILED
2015-08-13 21:40:11,382 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:40:11,382 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:40:11,382 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:40:11,382 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:40:11,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...latform/group/VALID/VALID
2015-08-13 21:40:11,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:40:11,383 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/group/VALID/VALID/_temporary
2015-08-13 21:40:11,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/group/VALID/VALID
2015-08-13 21:40:11,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/group/NONE/STRICT
2015-08-13 21:40:11,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/group/STRICT/STRICT
2015-08-13 21:40:11,385 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/group/NONE/VALID
2015-08-13 21:40:11,385 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/group/VALID/STRICT
2015-08-13 21:40:11,398 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:11,399 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:11,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:11,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:11,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/fail"]
2015-08-13 21:40:11,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:11,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:11,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:11,425 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/fail
2015-08-13 21:40:11,463 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0011
2015-08-13 21:40:11,463 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:11,468 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:11,803 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:11,803 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:11,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:11,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:14,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:14,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:14,483 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:14,484 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/fail"]
2015-08-13 21:40:14,489 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:14,490 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:14,492 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:14,500 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0011 state at FAILED
2015-08-13 21:40:14,500 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:40:14,500 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:40:14,500 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:40:14,500 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:40:14,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...edassertionsplatform/fail
2015-08-13 21:40:14,501 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:40:14,502 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/fail/_temporary
2015-08-13 21:40:14,502 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/fail
2015-08-13 21:40:14,515 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:14,515 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:14,537 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/pass"]
2015-08-13 21:40:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:14,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edassertionsplatform/pass
2015-08-13 21:40:14,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0012
2015-08-13 21:40:14,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:14,579 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:14,729 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:14,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:14,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:14,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:17,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:17,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:17,594 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:17,594 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/pass"]
2015-08-13 21:40:20,586 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/pass/_temporary
2015-08-13 21:40:20,597 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/pass
2015-08-13 21:40:20,610 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:20,611 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:20,632 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:20,632 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:20,633 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/fail"]
2015-08-13 21:40:20,633 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:20,633 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:20,633 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:20,634 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/fail
2015-08-13 21:40:20,669 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0013
2015-08-13 21:40:20,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:20,674 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:20,812 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:20,812 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:20,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:20,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:23,680 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:23,680 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:23,689 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:23,690 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/fail"]
2015-08-13 21:40:23,696 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:23,697 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:23,699 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0013
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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 21:40:23,708 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0013 state at FAILED
2015-08-13 21:40:23,708 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 21:40:23,709 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 21:40:23,709 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 21:40:23,709 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 21:40:23,709 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...rtionsplatform/value/fail
2015-08-13 21:40:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 21:40:23,710 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/fail/_temporary
2015-08-13 21:40:23,710 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/fail
2015-08-13 21:40:23,726 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 21:40:23,727 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 21:40:23,750 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 21:40:23,751 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:23,751 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/pass"]
2015-08-13 21:40:23,752 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 21:40:23,752 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 21:40:23,753 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 21:40:23,754 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...rtionsplatform/value/pass
2015-08-13 21:40:23,795 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0014
2015-08-13 21:40:23,795 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 21:40:23,800 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-08-13 21:40:23,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 21:40:23,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 21:40:23,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-08-13 21:40:23,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:26,806 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 21:40:26,806 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 21:40:26,815 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2015-08-13 21:40:26,815 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/pass"]
2015-08-13 21:40:29,810 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/value/pass/_temporary
2015-08-13 21:40:29,822 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/value/pass