2016-01-14 20:14:16,928 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 20:14:16,944 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.operation.assertion.AppliedAssertionsPlatformTest, with platform: hadoop
2016-01-14 20:14:16,974 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 20:14:17,202 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 20:14:17,303 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:17,304 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:17,418 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4F817BC894C049FBB5A86FB3A1A63BF8
2016-01-14 20:14:17,617 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.157
2016-01-14 20:14:17,622 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:17,623 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:17,851 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 20:14:17,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:17,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:17,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-14 20:14:17,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:17,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:17,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:17,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/NONE/STRICT
2016-01-14 20:14:17,912 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 20:14:17,945 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 20:14:18,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0001
2016-01-14 20:14:18,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:18,227 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:18,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:18,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:18,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DFEF2BDF13B54A5481744AB6F2B86382, ordinal: 0
2016-01-14 20:14:18,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:18,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:18,418 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFEF2BDF13B54A5481744AB6F2B86382, mem on start (mb), free: 87, total: 223, max: 672
2016-01-14 20:14:18,434 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFEF2BDF13B54A5481744AB6F2B86382, mem on close (mb), free: 87, total: 223, max: 672
2016-01-14 20:14:21,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:21,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:21,236 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E5D7CAAD1F614F6C9889A1042BB7FC98, ordinal: 1
2016-01-14 20:14:21,240 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:21,240 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-14 20:14:21,241 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5D7CAAD1F614F6C9889A1042BB7FC98, mem on start (mb), free: 85, total: 223, max: 672
2016-01-14 20:14:21,254 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5D7CAAD1F614F6C9889A1042BB7FC98, mem on close (mb), free: 84, total: 223, max: 672
2016-01-14 20:14:24,217 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT/_temporary
2016-01-14 20:14:24,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.361
2016-01-14 20:14:24,257 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:24,257 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:24,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-01-14 20:14:24,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:24,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:24,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:24,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:24,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-14 20:14:24,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:24,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:24,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:24,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/value/VALID/STRICT
2016-01-14 20:14:24,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0002
2016-01-14 20:14:24,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:24,493 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:24,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:24,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:24,603 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B8939EB11453440D8FD2AF8DC8178047, ordinal: 0
2016-01-14 20:14:24,604 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:24,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:24,605 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8939EB11453440D8FD2AF8DC8178047, mem on start (mb), free: 69, total: 318, max: 672
2016-01-14 20:14:24,608 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8939EB11453440D8FD2AF8DC8178047, mem on close (mb), free: 69, total: 318, max: 672
2016-01-14 20:14:27,498 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:27,498 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:27,514 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DBEA778F909E49D0A7D7F95967C4FD78, ordinal: 1
2016-01-14 20:14:27,516 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:27,516 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-14 20:14:27,516 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBEA778F909E49D0A7D7F95967C4FD78, mem on start (mb), free: 67, total: 318, max: 672
2016-01-14 20:14:27,524 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBEA778F909E49D0A7D7F95967C4FD78, mem on close (mb), free: 67, total: 318, max: 672
2016-01-14 20:14:30,505 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT/_temporary
2016-01-14 20:14:30,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.122
2016-01-14 20:14:30,541 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:30,541 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:30,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-01-14 20:14:30,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:30,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:30,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:30,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:30,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-14 20:14:30,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:30,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:30,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:30,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/value/STRICT/STRICT
2016-01-14 20:14:30,753 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0003
2016-01-14 20:14:30,755 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:30,759 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:30,859 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:30,859 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:30,869 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E9A48BC5730E498CBFCBF93FDD7751AA, ordinal: 0
2016-01-14 20:14:30,870 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:30,871 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:30,871 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9A48BC5730E498CBFCBF93FDD7751AA, mem on start (mb), free: 112, total: 414, max: 672
2016-01-14 20:14:30,875 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9A48BC5730E498CBFCBF93FDD7751AA, mem on close (mb), free: 111, total: 414, max: 672
2016-01-14 20:14:33,765 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:33,766 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:33,776 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FEB51F855716487B97A234F9EB1E6495, ordinal: 1
2016-01-14 20:14:33,777 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:33,777 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-14 20:14:33,777 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FEB51F855716487B97A234F9EB1E6495, mem on start (mb), free: 110, total: 414, max: 672
2016-01-14 20:14:33,784 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:33,786 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:33,790 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:33,795 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0003 state at FAILED
2016-01-14 20:14:33,795 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:14:33,797 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:14:33,797 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:14:33,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:14:33,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/value/STRICT/STRICT
2016-01-14 20:14:33,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:14:33,798 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT/_temporary
2016-01-14 20:14:33,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.139
2016-01-14 20:14:33,812 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:33,812 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:33,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 20:14:33,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:33,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:33,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:33,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:33,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-14 20:14:33,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:33,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:33,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:33,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/value/NONE/VALID
2016-01-14 20:14:33,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0004
2016-01-14 20:14:33,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:33,944 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:34,040 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:34,041 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:34,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C20F84C14CFF4E9EAAD1B2A49D49A43C, ordinal: 0
2016-01-14 20:14:34,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:34,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:34,051 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C20F84C14CFF4E9EAAD1B2A49D49A43C, mem on start (mb), free: 96, total: 509, max: 672
2016-01-14 20:14:34,055 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C20F84C14CFF4E9EAAD1B2A49D49A43C, mem on close (mb), free: 96, total: 509, max: 672
2016-01-14 20:14:36,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:36,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:36,957 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F79C69BA8DFE40EE99226D7F321D443F, ordinal: 1
2016-01-14 20:14:36,958 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:36,958 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-14 20:14:36,959 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F79C69BA8DFE40EE99226D7F321D443F, mem on start (mb), free: 95, total: 509, max: 672
2016-01-14 20:14:36,964 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F79C69BA8DFE40EE99226D7F321D443F, mem on close (mb), free: 95, total: 509, max: 672
2016-01-14 20:14:39,954 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID/_temporary
2016-01-14 20:14:39,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.059
2016-01-14 20:14:39,974 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:39,975 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:40,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-01-14 20:14:40,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:40,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:40,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:40,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:40,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-14 20:14:40,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:40,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:40,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:40,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/VALID/VALID
2016-01-14 20:14:40,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0005
2016-01-14 20:14:40,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:40,118 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:40,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:40,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:40,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CCBD70D99B904D44AB065B6B1F30AE94, ordinal: 0
2016-01-14 20:14:40,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:40,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:40,225 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CCBD70D99B904D44AB065B6B1F30AE94, mem on start (mb), free: 47, total: 572, max: 672
2016-01-14 20:14:40,229 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CCBD70D99B904D44AB065B6B1F30AE94, mem on close (mb), free: 46, total: 572, max: 672
2016-01-14 20:14:43,122 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:43,122 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:43,133 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EB54D071BFDC4F79832EF9C32A08CD8D, ordinal: 1
2016-01-14 20:14:43,134 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:43,134 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-14 20:14:43,135 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EB54D071BFDC4F79832EF9C32A08CD8D, mem on start (mb), free: 45, total: 572, max: 672
2016-01-14 20:14:43,140 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:43,141 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runValueAssertions(AppliedAssertionsPlatformTest.java:158)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:43,149 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:43,151 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0005 state at FAILED
2016-01-14 20:14:43,157 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:14:43,157 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:14:43,157 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:14:43,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:14:43,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/value/VALID/VALID
2016-01-14 20:14:43,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:14:43,159 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID/_temporary
2016-01-14 20:14:43,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.097
2016-01-14 20:14:43,160 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID
2016-01-14 20:14:43,160 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID
2016-01-14 20:14:43,160 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT
2016-01-14 20:14:43,161 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT
2016-01-14 20:14:43,162 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT
2016-01-14 20:14:43,178 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:43,178 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:43,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-14 20:14:43,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:43,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:43,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:43,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:43,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-14 20:14:43,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:43,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:43,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:43,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/NONE/STRICT
2016-01-14 20:14:43,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0006
2016-01-14 20:14:43,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:43,299 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:43,538 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:43,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:43,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9DA827C1976491CAC0F084FE4D7C2C9, ordinal: 0
2016-01-14 20:14:43,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:43,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:43,550 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9DA827C1976491CAC0F084FE4D7C2C9, mem on start (mb), free: 140, total: 247, max: 672
2016-01-14 20:14:43,553 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9DA827C1976491CAC0F084FE4D7C2C9, mem on close (mb), free: 140, total: 247, max: 672
2016-01-14 20:14:46,303 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:46,304 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:46,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A9E22845197E4E6B8BF522A6413808D5, ordinal: 1
2016-01-14 20:14:46,313 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:46,313 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-14 20:14:46,313 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A9E22845197E4E6B8BF522A6413808D5, mem on start (mb), free: 139, total: 247, max: 672
2016-01-14 20:14:46,320 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A9E22845197E4E6B8BF522A6413808D5, mem on close (mb), free: 139, total: 247, max: 672
2016-01-14 20:14:49,310 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT/_temporary
2016-01-14 20:14:49,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.052
2016-01-14 20:14:49,340 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:49,341 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:49,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-01-14 20:14:49,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:49,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:49,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:49,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-14 20:14:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:49,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:49,437 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:49,437 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/group/VALID/STRICT
2016-01-14 20:14:49,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0007
2016-01-14 20:14:49,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:49,512 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:49,618 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:49,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:49,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3F2CE78992F4E16AEEEC3E6D8ADE511, ordinal: 0
2016-01-14 20:14:49,630 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:49,631 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:49,631 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3F2CE78992F4E16AEEEC3E6D8ADE511, mem on start (mb), free: 123, total: 343, max: 672
2016-01-14 20:14:49,635 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3F2CE78992F4E16AEEEC3E6D8ADE511, mem on close (mb), free: 123, total: 343, max: 672
2016-01-14 20:14:52,515 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:52,516 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:52,525 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DBFCF551AD544348A61CA9BAA7000510, ordinal: 1
2016-01-14 20:14:52,526 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:52,526 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-14 20:14:52,527 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBFCF551AD544348A61CA9BAA7000510, mem on start (mb), free: 122, total: 343, max: 672
2016-01-14 20:14:52,531 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBFCF551AD544348A61CA9BAA7000510, mem on close (mb), free: 122, total: 343, max: 672
2016-01-14 20:14:55,526 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT/_temporary
2016-01-14 20:14:55,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.090
2016-01-14 20:14:55,546 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:55,546 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:55,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 20:14:55,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:55,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:55,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:55,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:55,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-14 20:14:55,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:55,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:55,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:55,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/group/STRICT/STRICT
2016-01-14 20:14:55,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0008
2016-01-14 20:14:55,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:55,694 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:55,804 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:55,805 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:55,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE257AC22B52450983C742272B410243, ordinal: 0
2016-01-14 20:14:55,814 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:55,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:55,815 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE257AC22B52450983C742272B410243, mem on start (mb), free: 106, total: 438, max: 672
2016-01-14 20:14:55,819 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE257AC22B52450983C742272B410243, mem on close (mb), free: 106, total: 438, max: 672
2016-01-14 20:14:58,697 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:14:58,697 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:14:58,704 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AD4F65056126461EAC1E3225488413AD, ordinal: 1
2016-01-14 20:14:58,705 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:58,706 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-14 20:14:58,706 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AD4F65056126461EAC1E3225488413AD, mem on start (mb), free: 105, total: 438, max: 672
2016-01-14 20:14:58,711 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:58,714 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:58,719 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:14:58,726 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0008 state at FAILED
2016-01-14 20:14:58,726 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:14:58,726 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:14:58,726 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:14:58,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:14:58,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/group/STRICT/STRICT
2016-01-14 20:14:58,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:14:58,728 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT/_temporary
2016-01-14 20:14:58,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.094
2016-01-14 20:14:58,738 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:14:58,738 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:14:58,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 20:14:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:14:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:14:58,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:14:58,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:58,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-14 20:14:58,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:14:58,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:14:58,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:14:58,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/group/NONE/VALID
2016-01-14 20:14:58,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0009
2016-01-14 20:14:58,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:14:58,836 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:14:58,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:14:58,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:14:58,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B39BC1C96954489EB97ABCC846247C01, ordinal: 0
2016-01-14 20:14:58,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:14:58,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:14:58,939 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B39BC1C96954489EB97ABCC846247C01, mem on start (mb), free: 92, total: 534, max: 672
2016-01-14 20:14:58,943 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B39BC1C96954489EB97ABCC846247C01, mem on close (mb), free: 92, total: 534, max: 672
2016-01-14 20:15:01,840 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:01,841 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:01,850 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F8B8BB5A3BB54B53914701A311D24EC7, ordinal: 1
2016-01-14 20:15:01,850 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:01,851 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-14 20:15:01,851 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8B8BB5A3BB54B53914701A311D24EC7, mem on start (mb), free: 91, total: 534, max: 672
2016-01-14 20:15:01,857 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8B8BB5A3BB54B53914701A311D24EC7, mem on close (mb), free: 91, total: 534, max: 672
2016-01-14 20:15:04,847 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID/_temporary
2016-01-14 20:15:04,848 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.052
2016-01-14 20:15:04,876 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:15:04,877 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:15:04,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 20:15:04,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:15:04,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:15:04,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:15:04,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:04,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-14 20:15:04,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:15:04,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:15:04,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:15:04,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/VALID/VALID
2016-01-14 20:15:04,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0010
2016-01-14 20:15:04,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:15:04,987 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:15:05,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:15:05,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:15:05,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFC919B63EFE4D258F380FFA577458CE, ordinal: 0
2016-01-14 20:15:05,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:05,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:05,090 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFC919B63EFE4D258F380FFA577458CE, mem on start (mb), free: 70, total: 572, max: 672
2016-01-14 20:15:05,094 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFC919B63EFE4D258F380FFA577458CE, mem on close (mb), free: 70, total: 572, max: 672
2016-01-14 20:15:07,991 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:07,991 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:07,998 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DB0013751508458F81B679EECFDC12EF, ordinal: 1
2016-01-14 20:15:07,999 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:07,999 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-14 20:15:07,999 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB0013751508458F81B679EECFDC12EF, mem on start (mb), free: 69, total: 572, max: 672
2016-01-14 20:15:08,004 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:08,005 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.runGroupAssertions(AppliedAssertionsPlatformTest.java:283)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:08,008 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:08,010 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0010 state at FAILED
2016-01-14 20:15:08,010 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:15:08,010 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:15:08,011 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:15:08,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:15:08,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/group/VALID/VALID
2016-01-14 20:15:08,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:15:08,012 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID/_temporary
2016-01-14 20:15:08,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.064
2016-01-14 20:15:08,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT
2016-01-14 20:15:08,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT
2016-01-14 20:15:08,014 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID
2016-01-14 20:15:08,014 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID
2016-01-14 20:15:08,014 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT
2016-01-14 20:15:08,028 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:15:08,028 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:15:08,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 20:15:08,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:15:08,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:15:08,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:15:08,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:08,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-14 20:15:08,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:15:08,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:15:08,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:15:08,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsFail/fail
2016-01-14 20:15:08,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0011
2016-01-14 20:15:08,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:15:08,114 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:15:08,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:15:08,161 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:15:08,168 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADFA9F94A7574176B0E11737D8BE8426, ordinal: 0
2016-01-14 20:15:08,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:08,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:08,170 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADFA9F94A7574176B0E11737D8BE8426, mem on start (mb), free: 40, total: 628, max: 672
2016-01-14 20:15:08,173 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADFA9F94A7574176B0E11737D8BE8426, mem on close (mb), free: 40, total: 628, max: 672
2016-01-14 20:15:11,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:11,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:11,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A897760CA79B4452B86CB0BC061DC553, ordinal: 1
2016-01-14 20:15:11,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:11,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-14 20:15:11,126 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A897760CA79B4452B86CB0BC061DC553, mem on start (mb), free: 38, total: 628, max: 672
2016-01-14 20:15:11,131 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:11,132 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testGroupAssertionsFail(AppliedAssertionsPlatformTest.java:236)] group size: 7, is not equal to: 0, in group ['method']: ['POST']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertGroupBase.doAssert(AssertGroupBase.java:172)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:11,138 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.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:127)
at cascading.flow.stream.element.GroupAssertionEveryStage.completeGroup(GroupAssertionEveryStage.java:36)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:11,139 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0011 state at FAILED
2016-01-14 20:15:11,141 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:15:11,141 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:15:11,141 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:15:11,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:15:11,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...tGroupAssertionsFail/fail
2016-01-14 20:15:11,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:15:11,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail/_temporary
2016-01-14 20:15:11,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.062
2016-01-14 20:15:11,143 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail
2016-01-14 20:15:11,155 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:15:11,155 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:15:11,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 20:15:11,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:15:11,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:15:11,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:15:11,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:11,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-14 20:15:11,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:15:11,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:15:11,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:15:11,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsPass/pass
2016-01-14 20:15:11,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0012
2016-01-14 20:15:11,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:15:11,260 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:15:11,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:15:11,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:15:11,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B97BB7E42E2D4994A0A2FC392EAA1665, ordinal: 0
2016-01-14 20:15:11,296 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:11,297 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:11,297 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B97BB7E42E2D4994A0A2FC392EAA1665, mem on start (mb), free: 41, total: 629, max: 672
2016-01-14 20:15:11,300 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B97BB7E42E2D4994A0A2FC392EAA1665, mem on close (mb), free: 41, total: 629, max: 672
2016-01-14 20:15:14,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:14,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:14,271 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AC2AE05070984216944ECBF8705476AC, ordinal: 1
2016-01-14 20:15:14,271 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:14,271 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-14 20:15:14,272 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AC2AE05070984216944ECBF8705476AC, mem on start (mb), free: 39, total: 629, max: 672
2016-01-14 20:15:14,275 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AC2AE05070984216944ECBF8705476AC, mem on close (mb), free: 38, total: 629, max: 672
2016-01-14 20:15:17,269 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass/_temporary
2016-01-14 20:15:17,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.053
2016-01-14 20:15:17,277 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass
2016-01-14 20:15:17,289 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:15:17,290 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:15:17,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 20:15:17,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:15:17,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:15:17,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:15:17,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:17,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-14 20:15:17,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:15:17,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:15:17,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:15:17,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsFail/value/fail
2016-01-14 20:15:17,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0013
2016-01-14 20:15:17,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:15:17,380 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:15:17,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:15:17,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:15:17,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF91E1C19F424DFDAA65113F487DB16A, ordinal: 0
2016-01-14 20:15:17,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:17,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:17,410 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF91E1C19F424DFDAA65113F487DB16A, mem on start (mb), free: 151, total: 739, max: 739
2016-01-14 20:15:17,413 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF91E1C19F424DFDAA65113F487DB16A, mem on close (mb), free: 151, total: 739, max: 739
2016-01-14 20:15:20,384 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:20,384 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:20,390 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CBFF0B2523BA42FFA8CA8A24AB85ED0A, ordinal: 1
2016-01-14 20:15:20,391 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:20,391 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-14 20:15:20,392 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CBFF0B2523BA42FFA8CA8A24AB85ED0A, mem on start (mb), free: 149, total: 739, max: 739
2016-01-14 20:15:20,396 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:20,397 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.operation.AssertionException: [cascading.operation.assertion.AppliedAssertionsPlatformTest.testValueAssertionsFail(AppliedAssertionsPlatformTest.java:111)] argument tuple: ['7'] was not equal to values: ['0']
at cascading.operation.assertion.BaseAssertion.throwFail(BaseAssertion.java:107)
at cascading.operation.assertion.BaseAssertion.fail(BaseAssertion.java:86)
at cascading.operation.assertion.AssertEquals.doAssert(AssertEquals.java:77)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:20,400 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.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:71)
at cascading.flow.stream.element.ValueAssertionEachStage.receive(ValueAssertionEachStage.java:35)
at cascading.flow.stream.duct.CloseReducingDuct.completeGroup(CloseReducingDuct.java:47)
at cascading.flow.stream.element.AggregatorEveryStage$1.collect(AggregatorEveryStage.java:69)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.operation.aggregator.Count.complete(Count.java:82)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:153)
at cascading.flow.stream.element.AggregatorEveryStage.completeGroup(AggregatorEveryStage.java:41)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:51)
at cascading.flow.stream.duct.OpenReducingDuct.receive(OpenReducingDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:141)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2016-01-14 20:15:20,404 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0013 state at FAILED
2016-01-14 20:15:20,404 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 20:15:20,404 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 20:15:20,404 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 20:15:20,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 20:15:20,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...AssertionsFail/value/fail
2016-01-14 20:15:20,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 20:15:20,406 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail/_temporary
2016-01-14 20:15:20,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.056
2016-01-14 20:15:20,407 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail
2016-01-14 20:15:20,416 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:15:20,416 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:15:20,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 20:15:20,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 20:15:20,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:15:20,483 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 20:15:20,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:20,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-14 20:15:20,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 20:15:20,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 20:15:20,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 20:15:20,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsPass/value/pass
2016-01-14 20:15:20,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0014
2016-01-14 20:15:20,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 20:15:20,514 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt
2016-01-14 20:15:20,602 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:15:20,603 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:15:20,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1ADC5E84189475BAA2746083FC52440, ordinal: 0
2016-01-14 20:15:20,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2016-01-14 20:15:20,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:20,610 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1ADC5E84189475BAA2746083FC52440, mem on start (mb), free: 38, total: 739, max: 739
2016-01-14 20:15:20,613 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1ADC5E84189475BAA2746083FC52440, mem on close (mb), free: 38, total: 739, max: 739
2016-01-14 20:15:23,518 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 20:15:23,518 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 20:15:23,524 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AABD301D950349C19359D78F4CAE6899, ordinal: 1
2016-01-14 20:15:23,525 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 20:15:23,525 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-14 20:15:23,526 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AABD301D950349C19359D78F4CAE6899, mem on start (mb), free: 37, total: 739, max: 739
2016-01-14 20:15:23,534 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AABD301D950349C19359D78F4CAE6899, mem on close (mb), free: 36, total: 739, max: 739
2016-01-14 20:15:26,524 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass/_temporary
2016-01-14 20:15:26,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.040
2016-01-14 20:15:26,532 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass