Class cascading.cascade.RiffleCascadePlatformTest

7

tests

0

failures

0

ignored

26.334s

duration

100%

successful

Tests

Test Duration Result
testProcessFlowFlowListenerExceptionHandlingInComplete 0.004s passed
testProcessFlowFlowListenerExceptionHandlingInStart 0.005s passed
testProcessFlowFlowListenerExceptionHandlingInStop 0.012s passed
testProcessFlowWithChildCounters 0.351s passed
testProcessFlowWithCounters 0.006s passed
testSimpleRiffle 13.386s passed
testSimpleRiffleCascade 12.570s passed

Standard output

2016-01-14 20:04:46,518 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 20:04:46,533 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.RiffleCascadePlatformTest, with platform: hadoop
2016-01-14 20:04:46,557 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 20:04:46,790 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 20:04:46,844 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 40EF8911686D41599F333C838C1C79DA
2016-01-14 20:04:46,905 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowWithChildCounters/children/first
2016-01-14 20:04:46,920 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInStop/stopException/first
2016-01-14 20:04:46,984 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:04:46,986 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:04:47,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.107
2016-01-14 20:04:47,241 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:04:47,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:04:47,392 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:04:47,393 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:04:47,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 20:04:47,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:04:47,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:04:47,526 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:04:47,527 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:04:47,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-14 20:04:47,587 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:04:47,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:04:47,627 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:04:47,628 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:04:47,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-14 20:04:47,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:04:47,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:04:47,765 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 20:04:47,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-14 20:04:47,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 20:04:47,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-01-14 20:04:47,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  parallel execution of steps is enabled: false
2016-01-14 20:04:47,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  executing total steps: 1
2016-01-14 20:04:47,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  allocating management threads: 1
2016-01-14 20:04:47,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...pleRiffle/perpetual/first
2016-01-14 20:04:47,803 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 20:04:47,835 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 20:04:47,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_local_0001
2016-01-14 20:04:47,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://localhost:8080/
2016-01-14 20:04:48,058 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt
2016-01-14 20:04:48,070 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:04:48,070 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:04:48,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A26662340B0C4210BF5F10CCF4917C79, ordinal: 0
2016-01-14 20:04:48,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 20:04:48,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-01-14 20:04:48,120 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A26662340B0C4210BF5F10CCF4917C79, mem on start (mb), free: 177, total: 223, max: 672
2016-01-14 20:04:48,132 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A26662340B0C4210BF5F10CCF4917C79, mem on close (mb), free: 177, total: 223, max: 672
2016-01-14 20:04:51,041 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first/_temporary
2016-01-14 20:04:51,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  completed in: 00:03.273
2016-01-14 20:04:51,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2016-01-14 20:04:51,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-01-14 20:04:51,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-01-14 20:04:51,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  parallel execution of steps is enabled: false
2016-01-14 20:04:51,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  executing total steps: 1
2016-01-14 20:04:51,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  allocating management threads: 1
2016-01-14 20:04:51,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...leRiffle/perpetual/second
2016-01-14 20:04:51,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_local_0002
2016-01-14 20:04:51,118 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://localhost:8080/
2016-01-14 20:04:51,123 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first/part-00000
2016-01-14 20:04:51,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:04:51,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:04:51,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A61CF030B6484349819C2F386DF746B1, ordinal: 0
2016-01-14 20:04:51,141 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-01-14 20:04:51,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-01-14 20:04:51,142 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A61CF030B6484349819C2F386DF746B1, mem on start (mb), free: 170, total: 223, max: 672
2016-01-14 20:04:51,146 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A61CF030B6484349819C2F386DF746B1, mem on close (mb), free: 170, total: 223, max: 672
2016-01-14 20:04:54,133 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second/_temporary
2016-01-14 20:04:54,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  completed in: 00:03.087
2016-01-14 20:04:54,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting
2016-01-14 20:04:54,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-01-14 20:04:54,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-01-14 20:04:54,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  parallel execution of steps is enabled: false
2016-01-14 20:04:54,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  executing total steps: 1
2016-01-14 20:04:54,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  allocating management threads: 1
2016-01-14 20:04:54,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting step: (1/1) ...pleRiffle/perpetual/third
2016-01-14 20:04:54,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] submitted hadoop job: job_local_0003
2016-01-14 20:04:54,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] tracking url: http://localhost:8080/
2016-01-14 20:04:54,210 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second/part-00000
2016-01-14 20:04:54,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:04:54,219 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:04:54,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DBEA8EB79CFB4298A0B05DA23116B454, ordinal: 0
2016-01-14 20:04:54,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-01-14 20:04:54,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-01-14 20:04:54,234 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBEA8EB79CFB4298A0B05DA23116B454, mem on start (mb), free: 165, total: 223, max: 672
2016-01-14 20:04:54,237 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBEA8EB79CFB4298A0B05DA23116B454, mem on close (mb), free: 165, total: 223, max: 672
2016-01-14 20:04:57,215 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third/_temporary
2016-01-14 20:04:57,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  completed in: 00:03.078
2016-01-14 20:04:57,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting
2016-01-14 20:04:57,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-01-14 20:04:57,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth"]
2016-01-14 20:04:57,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  parallel execution of steps is enabled: false
2016-01-14 20:04:57,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  executing total steps: 1
2016-01-14 20:04:57,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  allocating management threads: 1
2016-01-14 20:04:57,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting step: (1/1) ...leRiffle/perpetual/fourth
2016-01-14 20:04:57,279 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] submitted hadoop job: job_local_0004
2016-01-14 20:04:57,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] tracking url: http://localhost:8080/
2016-01-14 20:04:57,284 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third/part-00000
2016-01-14 20:04:57,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:04:57,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:04:57,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB48A02CDB464637A4ADEF880573AD27, ordinal: 0
2016-01-14 20:04:57,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-01-14 20:04:57,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth"]
2016-01-14 20:04:57,306 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB48A02CDB464637A4ADEF880573AD27, mem on start (mb), free: 160, total: 223, max: 672
2016-01-14 20:04:57,309 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB48A02CDB464637A4ADEF880573AD27, mem on close (mb), free: 160, total: 223, max: 672
2016-01-14 20:05:00,289 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth/_temporary
2016-01-14 20:05:00,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  completed in: 00:03.072
2016-01-14 20:05:00,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth
2016-01-14 20:05:00,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first
2016-01-14 20:05:00,306 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second
2016-01-14 20:05:00,307 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third
2016-01-14 20:05:00,317 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:05:00,317 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:05:00,388 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 20:05:00,389 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:05:00,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:05:00,417 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:05:00,418 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:05:00,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 20:05:00,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:05:00,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:05:00,485 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:05:00,486 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:05:00,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 20:05:00,528 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:05:00,528 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:05:00,550 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:05:00,550 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:05:00,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 20:05:00,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:05:00,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:05:00,616 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting
2016-01-14 20:05:00,618 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third]  parallel execution of flows is enabled: false
2016-01-14 20:05:00,618 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third]  executing total flows: 4
2016-01-14 20:05:00,618 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third]  allocating management threads: 1
2016-01-14 20:05:00,619 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: first
2016-01-14 20:05:00,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-14 20:05:00,624 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 20:05:00,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-14 20:05:00,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 20:05:00,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-01-14 20:05:00,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  parallel execution of steps is enabled: false
2016-01-14 20:05:00,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  executing total steps: 1
2016-01-14 20:05:00,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  allocating management threads: 1
2016-01-14 20:05:00,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...de/perpetualcascade/first
2016-01-14 20:05:00,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_local_0005
2016-01-14 20:05:00,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://localhost:8080/
2016-01-14 20:05:00,673 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt
2016-01-14 20:05:00,678 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:05:00,678 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:05:00,688 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB54604E1B614EF39C9EAB1AAF842FDF, ordinal: 0
2016-01-14 20:05:00,689 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2016-01-14 20:05:00,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-01-14 20:05:00,690 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB54604E1B614EF39C9EAB1AAF842FDF, mem on start (mb), free: 199, total: 223, max: 672
2016-01-14 20:05:00,693 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB54604E1B614EF39C9EAB1AAF842FDF, mem on close (mb), free: 199, total: 223, max: 672
2016-01-14 20:05:03,681 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first/_temporary
2016-01-14 20:05:03,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first]  completed in: 00:03.054
2016-01-14 20:05:03,682 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: first
2016-01-14 20:05:03,683 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: second
2016-01-14 20:05:03,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2016-01-14 20:05:03,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 20:05:03,686 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2016-01-14 20:05:03,686 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-01-14 20:05:03,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-01-14 20:05:03,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  parallel execution of steps is enabled: false
2016-01-14 20:05:03,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  executing total steps: 1
2016-01-14 20:05:03,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  allocating management threads: 1
2016-01-14 20:05:03,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...e/perpetualcascade/second
2016-01-14 20:05:03,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_local_0006
2016-01-14 20:05:03,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://localhost:8080/
2016-01-14 20:05:03,733 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first/part-00000
2016-01-14 20:05:03,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:05:03,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:05:03,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1D46E7786BD445487B668DA5C0E7823, ordinal: 0
2016-01-14 20:05:03,753 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-01-14 20:05:03,753 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-01-14 20:05:03,754 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1D46E7786BD445487B668DA5C0E7823, mem on start (mb), free: 194, total: 223, max: 672
2016-01-14 20:05:03,757 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1D46E7786BD445487B668DA5C0E7823, mem on close (mb), free: 194, total: 223, max: 672
2016-01-14 20:05:06,737 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second/_temporary
2016-01-14 20:05:06,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second]  completed in: 00:03.051
2016-01-14 20:05:06,738 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: second
2016-01-14 20:05:06,739 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: third
2016-01-14 20:05:06,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] at least one sink is marked for delete
2016-01-14 20:05:06,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 20:05:06,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting
2016-01-14 20:05:06,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-01-14 20:05:06,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-01-14 20:05:06,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  parallel execution of steps is enabled: false
2016-01-14 20:05:06,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  executing total steps: 1
2016-01-14 20:05:06,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  allocating management threads: 1
2016-01-14 20:05:06,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting step: (1/1) ...de/perpetualcascade/third
2016-01-14 20:05:06,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] submitted hadoop job: job_local_0007
2016-01-14 20:05:06,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third] tracking url: http://localhost:8080/
2016-01-14 20:05:06,782 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second/part-00000
2016-01-14 20:05:06,786 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:05:06,786 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:05:06,794 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF3FE03CF60C4FB1A23001DEB60F392E, ordinal: 0
2016-01-14 20:05:06,794 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-01-14 20:05:06,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-01-14 20:05:06,795 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF3FE03CF60C4FB1A23001DEB60F392E, mem on start (mb), free: 188, total: 223, max: 672
2016-01-14 20:05:06,798 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF3FE03CF60C4FB1A23001DEB60F392E, mem on close (mb), free: 188, total: 223, max: 672
2016-01-14 20:05:09,796 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third/_temporary
2016-01-14 20:05:09,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [third]  completed in: 00:03.052
2016-01-14 20:05:09,797 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: third
2016-01-14 20:05:09,798 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: fourth
2016-01-14 20:05:09,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] at least one sink is marked for delete
2016-01-14 20:05:09,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 20:05:09,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting
2016-01-14 20:05:09,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-01-14 20:05:09,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth"]
2016-01-14 20:05:09,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  parallel execution of steps is enabled: false
2016-01-14 20:05:09,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  executing total steps: 1
2016-01-14 20:05:09,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  allocating management threads: 1
2016-01-14 20:05:09,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting step: (1/1) ...e/perpetualcascade/fourth
2016-01-14 20:05:09,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] submitted hadoop job: job_local_0008
2016-01-14 20:05:09,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] tracking url: http://localhost:8080/
2016-01-14 20:05:09,855 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third/part-00000
2016-01-14 20:05:09,860 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:05:09,860 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:05:09,871 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A94EDD9777F74374AE8B18404DFFF6E2, ordinal: 0
2016-01-14 20:05:09,872 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-01-14 20:05:09,872 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth"]
2016-01-14 20:05:09,873 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A94EDD9777F74374AE8B18404DFFF6E2, mem on start (mb), free: 183, total: 223, max: 672
2016-01-14 20:05:09,874 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A94EDD9777F74374AE8B18404DFFF6E2, mem on close (mb), free: 183, total: 223, max: 672
2016-01-14 20:05:12,866 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth/_temporary
2016-01-14 20:05:12,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth]  completed in: 00:03.065
2016-01-14 20:05:12,867 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: fourth
2016-01-14 20:05:12,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth
2016-01-14 20:05:12,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second
2016-01-14 20:05:12,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third
2016-01-14 20:05:12,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first
2016-01-14 20:05:12,883 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowWithCounters/counter/first
2016-01-14 20:05:12,888 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInComplete/completeException/first
2016-01-14 20:05:12,893 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInStart/startException/first