2016-05-17 22:39:29,741 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:39:29,757 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.RiffleCascadePlatformTest, with platform: hadoop
2016-05-17 22:39:29,781 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 22:39:30,018 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:39:30,076 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: B651410C0C184368AF7E4A34A2DD19D1
2016-05-17 22:39:30,129 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowWithChildCounters/children/first
2016-05-17 22:39:30,144 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInStop/stopException/first
2016-05-17 22:39:30,217 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:30,220 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:30,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.107
2016-05-17 22:39:30,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:30,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:30,615 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:30,617 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:30,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-17 22:39:30,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:30,704 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:30,760 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:30,762 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:30,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-17 22:39:30,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:30,813 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:30,849 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:30,850 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:30,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-17 22:39:30,912 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:30,912 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:31,006 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:39:31,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:39:31,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:39:31,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-05-17 22:39:31,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] parallel execution of steps is enabled: false
2016-05-17 22:39:31,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executing total steps: 1
2016-05-17 22:39:31,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] allocating management threads: 1
2016-05-17 22:39:31,010 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...pleRiffle/perpetual/first
2016-05-17 22:39:31,053 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 22:39:31,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_local_0001
2016-05-17 22:39:31,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://localhost:8080/
2016-05-17 22:39:31,371 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 22:39:31,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:31,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:31,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B8615F99AA2143A385E30804D591E6DF, ordinal: 0
2016-05-17 22:39:31,433 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:39:31,433 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-05-17 22:39:31,435 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8615F99AA2143A385E30804D591E6DF, mem on start (mb), free: 177, total: 223, max: 672
2016-05-17 22:39:31,447 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8615F99AA2143A385E30804D591E6DF, mem on close (mb), free: 176, total: 223, max: 672
2016-05-17 22:39:34,361 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first/_temporary
2016-05-17 22:39:34,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] completed in: 00:03.352
2016-05-17 22:39:34,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 22:39:34,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-05-17 22:39:34,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-05-17 22:39:34,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] parallel execution of steps is enabled: false
2016-05-17 22:39:34,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executing total steps: 1
2016-05-17 22:39:34,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] allocating management threads: 1
2016-05-17 22:39:34,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...leRiffle/perpetual/second
2016-05-17 22:39:34,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_local_0002
2016-05-17 22:39:34,451 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://localhost:8080/
2016-05-17 22:39:34,455 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first/part-00000
2016-05-17 22:39:34,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:34,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:34,472 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E78D8EB2CBAB4DDCA9865754D0E507BB, ordinal: 0
2016-05-17 22:39:34,473 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first"]
2016-05-17 22:39:34,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-05-17 22:39:34,474 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E78D8EB2CBAB4DDCA9865754D0E507BB, mem on start (mb), free: 171, total: 223, max: 672
2016-05-17 22:39:34,479 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E78D8EB2CBAB4DDCA9865754D0E507BB, mem on close (mb), free: 171, total: 223, max: 672
2016-05-17 22:39:37,466 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second/_temporary
2016-05-17 22:39:37,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] completed in: 00:03.102
2016-05-17 22:39:37,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting
2016-05-17 22:39:37,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-05-17 22:39:37,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-05-17 22:39:37,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] parallel execution of steps is enabled: false
2016-05-17 22:39:37,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executing total steps: 1
2016-05-17 22:39:37,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] allocating management threads: 1
2016-05-17 22:39:37,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting step: (1/1) ...pleRiffle/perpetual/third
2016-05-17 22:39:37,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] submitted hadoop job: job_local_0003
2016-05-17 22:39:37,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] tracking url: http://localhost:8080/
2016-05-17 22:39:37,571 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second/part-00000
2016-05-17 22:39:37,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:37,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:37,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E712DF795FBE44919F8F90823D2F3569, ordinal: 0
2016-05-17 22:39:37,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second"]
2016-05-17 22:39:37,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-05-17 22:39:37,591 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E712DF795FBE44919F8F90823D2F3569, mem on start (mb), free: 165, total: 223, max: 672
2016-05-17 22:39:37,594 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E712DF795FBE44919F8F90823D2F3569, mem on close (mb), free: 165, total: 223, max: 672
2016-05-17 22:39:40,580 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third/_temporary
2016-05-17 22:39:40,581 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] completed in: 00:03.111
2016-05-17 22:39:40,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting
2016-05-17 22:39:40,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-05-17 22:39:40,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth"]
2016-05-17 22:39:40,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] parallel execution of steps is enabled: false
2016-05-17 22:39:40,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executing total steps: 1
2016-05-17 22:39:40,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] allocating management threads: 1
2016-05-17 22:39:40,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting step: (1/1) ...leRiffle/perpetual/fourth
2016-05-17 22:39:40,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] submitted hadoop job: job_local_0004
2016-05-17 22:39:40,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] tracking url: http://localhost:8080/
2016-05-17 22:39:40,654 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third/part-00000
2016-05-17 22:39:40,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:40,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:40,680 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F41D3B325BDA4886886ACE0EDA61D3DC, ordinal: 0
2016-05-17 22:39:40,681 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third"]
2016-05-17 22:39:40,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth"]
2016-05-17 22:39:40,683 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41D3B325BDA4886886ACE0EDA61D3DC, mem on start (mb), free: 160, total: 223, max: 672
2016-05-17 22:39:40,687 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41D3B325BDA4886886ACE0EDA61D3DC, mem on close (mb), free: 160, total: 223, max: 672
2016-05-17 22:39:43,662 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth/_temporary
2016-05-17 22:39:43,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] completed in: 00:03.077
2016-05-17 22:39:43,683 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/fourth
2016-05-17 22:39:43,684 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/third
2016-05-17 22:39:43,684 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/first
2016-05-17 22:39:43,685 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffle/perpetual/second
2016-05-17 22:39:43,703 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:43,703 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:43,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-17 22:39:43,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:43,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:43,806 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:43,807 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:43,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 22:39:43,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:43,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:43,880 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:43,880 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:43,912 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 22:39:43,913 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:43,913 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:43,933 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:39:43,934 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:39:43,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:39:43,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:39:43,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:39:44,011 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting
2016-05-17 22:39:44,013 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] parallel execution of flows is enabled: false
2016-05-17 22:39:44,013 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] executing total flows: 4
2016-05-17 22:39:44,014 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] allocating management threads: 1
2016-05-17 22:39:44,015 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: first
2016-05-17 22:39:44,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 22:39:44,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:39:44,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:39:44,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:39:44,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-05-17 22:39:44,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] parallel execution of steps is enabled: false
2016-05-17 22:39:44,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executing total steps: 1
2016-05-17 22:39:44,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] allocating management threads: 1
2016-05-17 22:39:44,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...de/perpetualcascade/first
2016-05-17 22:39:44,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_local_0005
2016-05-17 22:39:44,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://localhost:8080/
2016-05-17 22:39:44,075 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 22:39:44,079 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:44,080 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:44,097 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF6F1A1EF5ED4860B1A7408A27868350, ordinal: 0
2016-05-17 22:39:44,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 22:39:44,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-05-17 22:39:44,098 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6F1A1EF5ED4860B1A7408A27868350, mem on start (mb), free: 199, total: 223, max: 672
2016-05-17 22:39:44,101 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6F1A1EF5ED4860B1A7408A27868350, mem on close (mb), free: 199, total: 223, max: 672
2016-05-17 22:39:47,085 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first/_temporary
2016-05-17 22:39:47,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first] completed in: 00:03.061
2016-05-17 22:39:47,086 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: first
2016-05-17 22:39:47,087 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: second
2016-05-17 22:39:47,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] at least one sink is marked for delete
2016-05-17 22:39:47,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:39:47,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 22:39:47,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-05-17 22:39:47,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-05-17 22:39:47,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] parallel execution of steps is enabled: false
2016-05-17 22:39:47,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executing total steps: 1
2016-05-17 22:39:47,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] allocating management threads: 1
2016-05-17 22:39:47,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...e/perpetualcascade/second
2016-05-17 22:39:47,125 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_local_0006
2016-05-17 22:39:47,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://localhost:8080/
2016-05-17 22:39:47,130 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first/part-00000
2016-05-17 22:39:47,134 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:47,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:47,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D57BB7110507404891BA24EF4E11504B, ordinal: 0
2016-05-17 22:39:47,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first"]
2016-05-17 22:39:47,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-05-17 22:39:47,145 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D57BB7110507404891BA24EF4E11504B, mem on start (mb), free: 194, total: 223, max: 672
2016-05-17 22:39:47,149 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D57BB7110507404891BA24EF4E11504B, mem on close (mb), free: 194, total: 223, max: 672
2016-05-17 22:39:50,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second/_temporary
2016-05-17 22:39:50,144 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second] completed in: 00:03.052
2016-05-17 22:39:50,144 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: second
2016-05-17 22:39:50,145 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: third
2016-05-17 22:39:50,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] at least one sink is marked for delete
2016-05-17 22:39:50,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:39:50,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting
2016-05-17 22:39:50,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-05-17 22:39:50,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-05-17 22:39:50,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] parallel execution of steps is enabled: false
2016-05-17 22:39:50,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executing total steps: 1
2016-05-17 22:39:50,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] allocating management threads: 1
2016-05-17 22:39:50,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting step: (1/1) ...de/perpetualcascade/third
2016-05-17 22:39:50,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] submitted hadoop job: job_local_0007
2016-05-17 22:39:50,184 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] tracking url: http://localhost:8080/
2016-05-17 22:39:50,189 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second/part-00000
2016-05-17 22:39:50,193 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:50,194 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:50,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D753FF748FC04C9FA105BF03504ED317, ordinal: 0
2016-05-17 22:39:50,203 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second"]
2016-05-17 22:39:50,203 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-05-17 22:39:50,203 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D753FF748FC04C9FA105BF03504ED317, mem on start (mb), free: 188, total: 223, max: 672
2016-05-17 22:39:50,206 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D753FF748FC04C9FA105BF03504ED317, mem on close (mb), free: 188, total: 223, max: 672
2016-05-17 22:39:53,198 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third/_temporary
2016-05-17 22:39:53,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [third] completed in: 00:03.050
2016-05-17 22:39:53,199 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: third
2016-05-17 22:39:53,200 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] starting flow: fourth
2016-05-17 22:39:53,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] at least one sink is marked for delete
2016-05-17 22:39:53,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:39:53,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting
2016-05-17 22:39:53,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-05-17 22:39:53,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth"]
2016-05-17 22:39:53,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] parallel execution of steps is enabled: false
2016-05-17 22:39:53,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executing total steps: 1
2016-05-17 22:39:53,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] allocating management threads: 1
2016-05-17 22:39:53,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting step: (1/1) ...e/perpetualcascade/fourth
2016-05-17 22:39:53,245 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] submitted hadoop job: job_local_0008
2016-05-17 22:39:53,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] tracking url: http://localhost:8080/
2016-05-17 22:39:53,251 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third/part-00000
2016-05-17 22:39:53,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:39:53,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:39:53,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF6A2DD54D52486186EC597156C6B39D, ordinal: 0
2016-05-17 22:39:53,271 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third"]
2016-05-17 22:39:53,272 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth"]
2016-05-17 22:39:53,272 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF6A2DD54D52486186EC597156C6B39D, mem on start (mb), free: 183, total: 223, max: 672
2016-05-17 22:39:53,275 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF6A2DD54D52486186EC597156C6B39D, mem on close (mb), free: 183, total: 223, max: 672
2016-05-17 22:39:56,254 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth/_temporary
2016-05-17 22:39:56,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] completed in: 00:03.049
2016-05-17 22:39:56,255 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+first+third] completed flow: fourth
2016-05-17 22:39:56,266 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/first
2016-05-17 22:39:56,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/third
2016-05-17 22:39:56,268 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/fourth
2016-05-17 22:39:56,269 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testSimpleRiffleCascade/perpetualcascade/second
2016-05-17 22:39:56,280 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowWithCounters/counter/first
2016-05-17 22:39:56,288 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInComplete/completeException/first
2016-05-17 22:39:56,296 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/rifflecascadeplatform/testProcessFlowFlowListenerExceptionHandlingInStart/startException/first