2016-01-14 22:12:37,175 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 22:12:37,191 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.flow.FlowStrategiesPlatformTest, with platform: hadoop
2016-01-14 22:12:37,215 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 22:12:37,454 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 22:12:37,552 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:12:37,555 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 22:12:37,673 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: E2CDB298C0D44DBD8FCC7A2B2C5DED0B
2016-01-14 22:12:37,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.108
2016-01-14 22:12:37,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:12:37,828 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 22:12:37,941 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink is marked for delete
2016-01-14 22:12:37,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 22:12:37,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink is marked for delete
2016-01-14 22:12:37,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 22:12:38,000 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 22:12:38,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:12:38,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:38,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesReplace/replace"]
2016-01-14 22:12:38,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:12:38,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:12:38,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:12:38,007 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...StrategiesReplace/replace
2016-01-14 22:12:38,040 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 22:12:38,092 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 22:12:38,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0001
2016-01-14 22:12:38,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:12:38,384 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 22:12:38,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:12:38,399 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:12:38,411 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE4FDCDF42F3431EBEBD1D0E18B9B31F, ordinal: 0
2016-01-14 22:12:38,456 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:38,457 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesReplace/replace"]
2016-01-14 22:12:38,459 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4FDCDF42F3431EBEBD1D0E18B9B31F, mem on start (mb), free: 186, total: 223, max: 672
2016-01-14 22:12:38,470 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4FDCDF42F3431EBEBD1D0E18B9B31F, mem on close (mb), free: 185, total: 223, max: 672
2016-01-14 22:12:38,491 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesReplace/replace/_temporary
2016-01-14 22:12:38,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.488
2016-01-14 22:12:38,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink is marked for delete
2016-01-14 22:12:38,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 22:12:38,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink is marked for delete
2016-01-14 22:12:38,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 22:12:38,551 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/testSkipStrategiesReplace/replace
2016-01-14 22:12:38,581 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:12:38,582 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 22:12:38,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 22:12:38,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:12:38,650 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 22:12:38,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink does not exist
2016-01-14 22:12:38,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] at least one sink does not exist
2016-01-14 22:12:38,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:12:38,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:38,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesKeep/keep"]
2016-01-14 22:12:38,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:12:38,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:12:38,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:12:38,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSkipStrategiesKeep/keep
2016-01-14 22:12:38,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0002
2016-01-14 22:12:38,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:12:38,784 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 22:12:38,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:12:38,792 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:12:38,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5CB672086D74CFD82479E120094F907, ordinal: 0
2016-01-14 22:12:38,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:38,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesKeep/keep"]
2016-01-14 22:12:38,809 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5CB672086D74CFD82479E120094F907, mem on start (mb), free: 170, total: 223, max: 672
2016-01-14 22:12:38,812 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5CB672086D74CFD82479E120094F907, mem on close (mb), free: 170, total: 223, max: 672
2016-01-14 22:12:38,833 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testSkipStrategiesKeep/keep/_temporary
2016-01-14 22:12:38,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.161
2016-01-14 22:12:38,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Thu Jan 14 22:12:38 UTC 2016
2016-01-14 22:12:38,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source modification date at: Thu Jan 14 21:03:36 UTC 2016
2016-01-14 22:12:38,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink oldest modified date: Thu Jan 14 22:12:38 UTC 2016
2016-01-14 22:12:38,890 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/testSkipStrategiesKeep/keep
2016-01-14 22:12:38,923 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:12:38,925 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 22:12:39,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2016-01-14 22:12:39,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:12:39,043 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 22:12:39,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 22:12:39,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:39,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testFlowStepStrategy/simple"]
2016-01-14 22:12:39,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 22:12:39,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 22:12:39,092 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 22:12:39,092 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stFlowStepStrategy/simple
2016-01-14 22:12:39,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0003
2016-01-14 22:12:39,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 22:12:39,156 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 22:12:39,307 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:12:39,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:12:39,324 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A187AE76945C4522A21BD1582C17168C, ordinal: 0
2016-01-14 22:12:39,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:12:39,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'ip']]
2016-01-14 22:12:39,334 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A187AE76945C4522A21BD1582C17168C, mem on start (mb), free: 113, total: 223, max: 672
2016-01-14 22:12:39,340 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A187AE76945C4522A21BD1582C17168C, mem on close (mb), free: 113, total: 223, max: 672
2016-01-14 22:12:39,370 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 22:12:39,370 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 22:12:39,382 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C9BAE5441FB84278966275421160231B, ordinal: 1
2016-01-14 22:12:39,386 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'ip']]
2016-01-14 22:12:39,386 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testFlowStepStrategy/simple"]
2016-01-14 22:12:39,386 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9BAE5441FB84278966275421160231B, mem on start (mb), free: 111, total: 223, max: 672
2016-01-14 22:12:39,401 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C9BAE5441FB84278966275421160231B, mem on close (mb), free: 110, total: 223, max: 672
2016-01-14 22:12:39,421 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/flowstrategiesplatform/testFlowStepStrategy/simple/_temporary
2016-01-14 22:12:39,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.332
2016-01-14 22:12:39,437 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/flowstrategiesplatform/testFlowStepStrategy/simple