2016-01-14 17:17:00,398 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:17:00,414 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.operation.assertion.AppliedAssertionsPlatformTest, with platform: hadoop
2016-01-14 17:17:00,443 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 17:17:00,667 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 17:17:00,766 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:00,768 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 17:17:00,863 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: BAFE28B0C12C46BC911547218DD696D9
2016-01-14 17:17:01,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.146
2016-01-14 17:17:01,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:01,057 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 17:17:01,274 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:17:01,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:01,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:01,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-14 17:17:01,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:01,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:01,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:01,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/NONE/STRICT
2016-01-14 17:17:01,322 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 17:17:01,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0001
2016-01-14 17:17:01,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:01,637 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:01,767 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:01,768 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:01,783 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BABBAB9280CC45AAB47F0FA46F805CDA, ordinal: 0
2016-01-14 17:17:01,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:01,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:01,831 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BABBAB9280CC45AAB47F0FA46F805CDA, mem on start (mb), free: 87, total: 223, max: 672
2016-01-14 17:17:01,845 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BABBAB9280CC45AAB47F0FA46F805CDA, mem on close (mb), free: 87, total: 223, max: 672
2016-01-14 17:17:04,630 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:04,630 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:04,649 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB04C2F47C6E468C811698E1D954E4B9, ordinal: 1
2016-01-14 17:17:04,654 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:04,654 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT"]
2016-01-14 17:17:04,655 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB04C2F47C6E468C811698E1D954E4B9, mem on start (mb), free: 85, total: 223, max: 672
2016-01-14 17:17:04,674 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB04C2F47C6E468C811698E1D954E4B9, mem on close (mb), free: 84, total: 223, max: 672
2016-01-14 17:17:07,630 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT/_temporary
2016-01-14 17:17:07,633 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.354
2016-01-14 17:17:07,681 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:07,682 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 17:17:07,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2016-01-14 17:17:07,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:07,799 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 17:17:07,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:07,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:07,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-14 17:17:07,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:07,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/value/VALID/STRICT
2016-01-14 17:17:07,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0002
2016-01-14 17:17:07,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:07,934 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:08,035 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:08,035 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:08,047 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F333C4E4430D4F309E3BE15E91D81AAC, ordinal: 0
2016-01-14 17:17:08,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:08,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:08,048 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F333C4E4430D4F309E3BE15E91D81AAC, mem on start (mb), free: 68, total: 318, max: 672
2016-01-14 17:17:08,052 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F333C4E4430D4F309E3BE15E91D81AAC, mem on close (mb), free: 68, total: 318, max: 672
2016-01-14 17:17:10,938 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:10,939 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:10,950 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D980416E16584F6DAC4630016D242B4D, ordinal: 1
2016-01-14 17:17:10,951 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:10,951 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT"]
2016-01-14 17:17:10,951 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D980416E16584F6DAC4630016D242B4D, mem on start (mb), free: 67, total: 318, max: 672
2016-01-14 17:17:10,957 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D980416E16584F6DAC4630016D242B4D, mem on close (mb), free: 67, total: 318, max: 672
2016-01-14 17:17:13,948 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT/_temporary
2016-01-14 17:17:13,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.114
2016-01-14 17:17:13,981 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:13,981 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 17:17:14,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.087
2016-01-14 17:17:14,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:14,074 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 17:17:14,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:14,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:14,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-14 17:17:14,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:14,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:14,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:14,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/value/STRICT/STRICT
2016-01-14 17:17:14,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0003
2016-01-14 17:17:14,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:14,184 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:14,284 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:14,284 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:14,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BD303B1894A344DFAC3941D1F4025503, ordinal: 0
2016-01-14 17:17:14,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:14,296 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:14,296 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD303B1894A344DFAC3941D1F4025503, mem on start (mb), free: 110, total: 414, max: 672
2016-01-14 17:17:14,300 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD303B1894A344DFAC3941D1F4025503, mem on close (mb), free: 110, total: 414, max: 672
2016-01-14 17:17:17,188 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:17,188 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:17,198 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AEAB5066CB4C4850A6218433BB9AAF12, ordinal: 1
2016-01-14 17:17:17,199 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:17,199 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT"]
2016-01-14 17:17:17,199 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AEAB5066CB4C4850A6218433BB9AAF12, mem on start (mb), free: 109, total: 414, max: 672
2016-01-14 17:17:17,205 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 17:17:17,210 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 17:17:17,215 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 17:17:17,219 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0003 state at FAILED
2016-01-14 17:17:17,219 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:17:17,221 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:17:17,221 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:17:17,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:17:17,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/value/STRICT/STRICT
2016-01-14 17:17:17,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:17:17,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2016-01-14 17:17:17,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2016-01-14 17:17:17,222 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT/_temporary
2016-01-14 17:17:17,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.123
2016-01-14 17:17:17,235 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:17,236 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 17:17:17,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-01-14 17:17:17,310 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:17,311 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 17:17:17,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:17,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:17,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-14 17:17:17,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:17,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:17,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:17,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/value/NONE/VALID
2016-01-14 17:17:17,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0004
2016-01-14 17:17:17,389 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:17,398 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:17,497 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:17,498 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:17,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CEEE6C30CD5A4229827B51E46C7CF805, ordinal: 0
2016-01-14 17:17:17,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:17,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:17,508 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEEE6C30CD5A4229827B51E46C7CF805, mem on start (mb), free: 95, total: 509, max: 672
2016-01-14 17:17:17,511 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEEE6C30CD5A4229827B51E46C7CF805, mem on close (mb), free: 95, total: 509, max: 672
2016-01-14 17:17:20,402 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:20,403 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:20,413 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C7225863EB5D46738707F9411BAA1541, ordinal: 1
2016-01-14 17:17:20,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:20,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID"]
2016-01-14 17:17:20,415 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7225863EB5D46738707F9411BAA1541, mem on start (mb), free: 94, total: 509, max: 672
2016-01-14 17:17:20,423 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7225863EB5D46738707F9411BAA1541, mem on close (mb), free: 93, total: 509, max: 672
2016-01-14 17:17:23,410 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID/_temporary
2016-01-14 17:17:23,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.070
2016-01-14 17:17:23,433 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:23,434 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 17:17:23,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-01-14 17:17:23,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:23,503 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 17:17:23,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:23,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:23,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-14 17:17:23,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:23,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:23,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:23,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/value/VALID/VALID
2016-01-14 17:17:23,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0005
2016-01-14 17:17:23,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:23,576 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:23,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:23,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:23,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D597FDFD162743D9A4B6FB90C8D63E5E, ordinal: 0
2016-01-14 17:17:23,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:23,684 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:23,684 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D597FDFD162743D9A4B6FB90C8D63E5E, mem on start (mb), free: 46, total: 572, max: 672
2016-01-14 17:17:23,688 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D597FDFD162743D9A4B6FB90C8D63E5E, mem on close (mb), free: 45, total: 572, max: 672
2016-01-14 17:17:26,580 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:26,581 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:26,590 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C839BFB1CD0C4775ACF692CDAB5F85FE, ordinal: 1
2016-01-14 17:17:26,591 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:26,592 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID"]
2016-01-14 17:17:26,593 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C839BFB1CD0C4775ACF692CDAB5F85FE, mem on start (mb), free: 44, total: 572, max: 672
2016-01-14 17:17:26,598 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 17:17:26,606 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 17:17:26,617 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 17:17:26,618 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0005 state at FAILED
2016-01-14 17:17:26,626 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:17:26,627 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:17:26,627 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:17:26,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:17:26,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/value/VALID/VALID
2016-01-14 17:17:26,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:17:26,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID/_temporary
2016-01-14 17:17:26,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.101
2016-01-14 17:17:26,630 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/STRICT
2016-01-14 17:17:26,630 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/VALID/VALID
2016-01-14 17:17:26,630 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/VALID
2016-01-14 17:17:26,631 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/NONE/STRICT
2016-01-14 17:17:26,631 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsRemoval/value/STRICT/STRICT
2016-01-14 17:17:26,649 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:26,650 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 17:17:26,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-01-14 17:17:26,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:26,712 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 17:17:26,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:26,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:26,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-14 17:17:26,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:26,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:26,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:26,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/NONE/STRICT
2016-01-14 17:17:26,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0006
2016-01-14 17:17:26,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:26,772 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:27,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:27,017 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:27,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D228458329984B368D45B250596F3980, ordinal: 0
2016-01-14 17:17:27,030 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:27,030 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:27,030 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D228458329984B368D45B250596F3980, mem on start (mb), free: 140, total: 247, max: 672
2016-01-14 17:17:27,035 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D228458329984B368D45B250596F3980, mem on close (mb), free: 140, total: 247, max: 672
2016-01-14 17:17:29,776 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:29,776 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:29,784 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D8C52B24257E4EC586F8D1A71D35B786, ordinal: 1
2016-01-14 17:17:29,785 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:29,785 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT"]
2016-01-14 17:17:29,786 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D8C52B24257E4EC586F8D1A71D35B786, mem on start (mb), free: 139, total: 247, max: 672
2016-01-14 17:17:29,792 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D8C52B24257E4EC586F8D1A71D35B786, mem on close (mb), free: 139, total: 247, max: 672
2016-01-14 17:17:32,784 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT/_temporary
2016-01-14 17:17:32,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.055
2016-01-14 17:17:32,805 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:32,806 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 17:17:32,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 17:17:32,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:32,851 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 17:17:32,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:32,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:32,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-14 17:17:32,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:32,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:32,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:32,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...emoval/group/VALID/STRICT
2016-01-14 17:17:32,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0007
2016-01-14 17:17:32,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:32,949 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:33,060 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:33,061 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:33,070 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1A7802030A14753A7C8F6469EDA83F6, ordinal: 0
2016-01-14 17:17:33,072 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:33,072 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:33,072 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1A7802030A14753A7C8F6469EDA83F6, mem on start (mb), free: 123, total: 343, max: 672
2016-01-14 17:17:33,076 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1A7802030A14753A7C8F6469EDA83F6, mem on close (mb), free: 123, total: 343, max: 672
2016-01-14 17:17:35,953 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:35,953 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:35,962 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E083F9E5045E47D7ABFFD66DA3B30302, ordinal: 1
2016-01-14 17:17:35,963 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:35,963 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT"]
2016-01-14 17:17:35,963 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E083F9E5045E47D7ABFFD66DA3B30302, mem on start (mb), free: 122, total: 343, max: 672
2016-01-14 17:17:35,969 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E083F9E5045E47D7ABFFD66DA3B30302, mem on close (mb), free: 122, total: 343, max: 672
2016-01-14 17:17:38,959 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT/_temporary
2016-01-14 17:17:38,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.091
2016-01-14 17:17:38,980 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:38,980 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 17:17:39,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 17:17:39,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:39,038 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 17:17:39,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:39,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:39,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-14 17:17:39,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:39,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:39,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:39,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...moval/group/STRICT/STRICT
2016-01-14 17:17:39,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0008
2016-01-14 17:17:39,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:39,120 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:39,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:39,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:39,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF86CDE4386248BEA53005C57EFB818F, ordinal: 0
2016-01-14 17:17:39,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:39,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:39,254 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF86CDE4386248BEA53005C57EFB818F, mem on start (mb), free: 107, total: 438, max: 672
2016-01-14 17:17:39,257 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF86CDE4386248BEA53005C57EFB818F, mem on close (mb), free: 107, total: 438, max: 672
2016-01-14 17:17:42,123 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:42,123 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:42,131 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A262672A54224A76B026354DD6D35550, ordinal: 1
2016-01-14 17:17:42,132 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:42,133 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT"]
2016-01-14 17:17:42,133 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A262672A54224A76B026354DD6D35550, mem on start (mb), free: 106, total: 438, max: 672
2016-01-14 17:17:42,138 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 17:17:42,139 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 17:17:42,142 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 17:17:42,144 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0008 state at FAILED
2016-01-14 17:17:42,144 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:17:42,144 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:17:42,144 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:17:42,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:17:42,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...moval/group/STRICT/STRICT
2016-01-14 17:17:42,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:17:42,146 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT/_temporary
2016-01-14 17:17:42,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.079
2016-01-14 17:17:42,157 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:42,157 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 17:17:42,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 17:17:42,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:42,200 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 17:17:42,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:42,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:42,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-14 17:17:42,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:42,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:42,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:42,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sRemoval/group/NONE/VALID
2016-01-14 17:17:42,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0009
2016-01-14 17:17:42,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:42,261 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:42,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:42,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:42,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B0C18FA719BF4AE9A08772C526F19F4E, ordinal: 0
2016-01-14 17:17:42,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:42,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:42,371 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0C18FA719BF4AE9A08772C526F19F4E, mem on start (mb), free: 91, total: 534, max: 672
2016-01-14 17:17:42,375 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0C18FA719BF4AE9A08772C526F19F4E, mem on close (mb), free: 91, total: 534, max: 672
2016-01-14 17:17:45,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:45,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:45,274 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9B0E897D9CD4776843EFF12AB5B7F1A, ordinal: 1
2016-01-14 17:17:45,275 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:45,275 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID"]
2016-01-14 17:17:45,275 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9B0E897D9CD4776843EFF12AB5B7F1A, mem on start (mb), free: 91, total: 534, max: 672
2016-01-14 17:17:45,282 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9B0E897D9CD4776843EFF12AB5B7F1A, mem on close (mb), free: 90, total: 534, max: 672
2016-01-14 17:17:48,270 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID/_temporary
2016-01-14 17:17:48,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.052
2016-01-14 17:17:48,293 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:48,294 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 17:17:48,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 17:17:48,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:48,336 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 17:17:48,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:48,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-14 17:17:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:48,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:48,354 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Removal/group/VALID/VALID
2016-01-14 17:17:48,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0010
2016-01-14 17:17:48,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:48,388 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:48,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:48,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:48,493 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E05E1C79E3CA4B38B1BFA5F6522AE066, ordinal: 0
2016-01-14 17:17:48,494 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:48,494 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:48,494 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E05E1C79E3CA4B38B1BFA5F6522AE066, mem on start (mb), free: 69, total: 572, max: 672
2016-01-14 17:17:48,500 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E05E1C79E3CA4B38B1BFA5F6522AE066, mem on close (mb), free: 69, total: 572, max: 672
2016-01-14 17:17:51,392 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:51,392 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:51,400 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D97C01E0E64F4B56A9AF896265B78CAA, ordinal: 1
2016-01-14 17:17:51,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:51,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID"]
2016-01-14 17:17:51,401 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D97C01E0E64F4B56A9AF896265B78CAA, mem on start (mb), free: 69, total: 572, max: 672
2016-01-14 17:17:51,407 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 17:17:51,410 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 17:17:51,413 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 17:17:51,422 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0010 state at FAILED
2016-01-14 17:17:51,423 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:17:51,423 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:17:51,423 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:17:51,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:17:51,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Removal/group/VALID/VALID
2016-01-14 17:17:51,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:17:51,424 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID/_temporary
2016-01-14 17:17:51,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.072
2016-01-14 17:17:51,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/VALID
2016-01-14 17:17:51,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/STRICT
2016-01-14 17:17:51,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/STRICT/STRICT
2016-01-14 17:17:51,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/NONE/STRICT
2016-01-14 17:17:51,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsRemoval/group/VALID/VALID
2016-01-14 17:17:51,440 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:51,440 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 17:17:51,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 17:17:51,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:51,478 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 17:17:51,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:51,500 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:51,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-14 17:17:51,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:51,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:51,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:51,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsFail/fail
2016-01-14 17:17:51,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0011
2016-01-14 17:17:51,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:51,547 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:51,603 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:51,604 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:51,614 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AEF853AD6D6C4950B0397EF6018F614D, ordinal: 0
2016-01-14 17:17:51,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:51,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:51,616 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEF853AD6D6C4950B0397EF6018F614D, mem on start (mb), free: 40, total: 628, max: 672
2016-01-14 17:17:51,619 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEF853AD6D6C4950B0397EF6018F614D, mem on close (mb), free: 40, total: 628, max: 672
2016-01-14 17:17:54,551 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:54,551 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:54,557 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A5129E969E9240C3BA5ADCDD1771DAA7, ordinal: 1
2016-01-14 17:17:54,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:54,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail"]
2016-01-14 17:17:54,558 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A5129E969E9240C3BA5ADCDD1771DAA7, mem on start (mb), free: 38, total: 628, max: 672
2016-01-14 17:17:54,563 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 17:17:54,566 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 17:17:54,571 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 17:17:54,577 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0011 state at FAILED
2016-01-14 17:17:54,578 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:17:54,578 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:17:54,578 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:17:54,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:17:54,579 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...tGroupAssertionsFail/fail
2016-01-14 17:17:54,579 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:17:54,579 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail/_temporary
2016-01-14 17:17:54,580 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.080
2016-01-14 17:17:54,580 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsFail/fail
2016-01-14 17:17:54,592 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:17:54,593 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 17:17:54,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-14 17:17:54,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:17:54,646 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 17:17:54,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:17:54,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:54,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-14 17:17:54,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:17:54,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:17:54,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:17:54,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tGroupAssertionsPass/pass
2016-01-14 17:17:54,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0012
2016-01-14 17:17:54,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:17:54,711 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:17:54,740 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:17:54,740 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:17:54,745 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C68A0A6EFEB54583886D1773BF0F781F, ordinal: 0
2016-01-14 17:17:54,746 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:17:54,746 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:54,746 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C68A0A6EFEB54583886D1773BF0F781F, mem on start (mb), free: 41, total: 629, max: 672
2016-01-14 17:17:54,749 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C68A0A6EFEB54583886D1773BF0F781F, mem on close (mb), free: 41, total: 629, max: 672
2016-01-14 17:17:57,715 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:17:57,715 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:17:57,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DB9E80AE8CCD4612B375147274226DB0, ordinal: 1
2016-01-14 17:17:57,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:17:57,721 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass"]
2016-01-14 17:17:57,722 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB9E80AE8CCD4612B375147274226DB0, mem on start (mb), free: 39, total: 629, max: 672
2016-01-14 17:17:57,725 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DB9E80AE8CCD4612B375147274226DB0, mem on close (mb), free: 39, total: 629, max: 672
2016-01-14 17:18:00,715 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass/_temporary
2016-01-14 17:18:00,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.054
2016-01-14 17:18:00,724 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testGroupAssertionsPass/pass
2016-01-14 17:18:00,731 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:18:00,732 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 17:18:00,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 17:18:00,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:18:00,772 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 17:18:00,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:18:00,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:18:00,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-14 17:18:00,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:18:00,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:18:00,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:18:00,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsFail/value/fail
2016-01-14 17:18:00,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0013
2016-01-14 17:18:00,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:18:00,819 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:18:00,846 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:18:00,846 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:18:00,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1D23425D2284AC8BCA2686ED9C23BE6, ordinal: 0
2016-01-14 17:18:00,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:18:00,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:18:00,853 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1D23425D2284AC8BCA2686ED9C23BE6, mem on start (mb), free: 151, total: 739, max: 739
2016-01-14 17:18:00,855 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1D23425D2284AC8BCA2686ED9C23BE6, mem on close (mb), free: 151, total: 739, max: 739
2016-01-14 17:18:03,823 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:18:03,823 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:18:03,828 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B758E51FF4CF491A8EF0E7217C4A3D1F, ordinal: 1
2016-01-14 17:18:03,829 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:18:03,829 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail"]
2016-01-14 17:18:03,829 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B758E51FF4CF491A8EF0E7217C4A3D1F, mem on start (mb), free: 149, total: 739, max: 739
2016-01-14 17:18:03,832 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 17:18:03,834 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 17:18:03,838 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 17:18:03,849 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local_0013 state at FAILED
2016-01-14 17:18:03,849 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2016-01-14 17:18:03,849 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2016-01-14 17:18:03,849 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2016-01-14 17:18:03,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2016-01-14 17:18:03,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...AssertionsFail/value/fail
2016-01-14 17:18:03,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2016-01-14 17:18:03,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2016-01-14 17:18:03,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2016-01-14 17:18:03,851 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail/_temporary
2016-01-14 17:18:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.063
2016-01-14 17:18:03,851 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsFail/value/fail
2016-01-14 17:18:03,859 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:18:03,860 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 17:18:03,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 17:18:03,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:18:03,905 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 17:18:03,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 17:18:03,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:18:03,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-14 17:18:03,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 17:18:03,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 17:18:03,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 17:18:03,920 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...AssertionsPass/value/pass
2016-01-14 17:18:03,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0014
2016-01-14 17:18:03,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 17:18:03,945 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 17:18:04,037 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:18:04,038 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:18:04,045 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A7E45B4C137748228644B7BDD42D7483, ordinal: 0
2016-01-14 17:18:04,045 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 17:18:04,045 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:18:04,046 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7E45B4C137748228644B7BDD42D7483, mem on start (mb), free: 38, total: 739, max: 739
2016-01-14 17:18:04,050 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7E45B4C137748228644B7BDD42D7483, mem on close (mb), free: 38, total: 739, max: 739
2016-01-14 17:18:06,948 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 17:18:06,949 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 17:18:06,955 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D035683DC14B427E9330BB5C832AF3AC, ordinal: 1
2016-01-14 17:18:06,955 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'method']]
2016-01-14 17:18:06,956 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass"]
2016-01-14 17:18:06,956 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D035683DC14B427E9330BB5C832AF3AC, mem on start (mb), free: 36, total: 739, max: 739
2016-01-14 17:18:06,961 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D035683DC14B427E9330BB5C832AF3AC, mem on close (mb), free: 36, total: 739, max: 739
2016-01-14 17:18:09,952 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass/_temporary
2016-01-14 17:18:09,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.034
2016-01-14 17:18:09,960 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/appliedassertionsplatform/testValueAssertionsPass/value/pass