Class cascading.UnmodifiablePipesPlatformTest

1

tests

0

failures

0

ignored

2.033s

duration

100%

successful

Tests

Test Duration Result
testUnmodifiable 2.033s passed

Standard output

2016-01-14 23:26:02,455 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 23:26:02,471 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.UnmodifiablePipesPlatformTest, with platform: hadoop
2016-01-14 23:26:02,494 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 23:26:02,748 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 23:26:02,880 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:26:02,882 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 23:26:02,999 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: B658C569E74D435EB13F36DB91405C78
2016-01-14 23:26:03,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.207
2016-01-14 23:26:03,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 23:26:03,255 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 23:26:03,480 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 23:26:03,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:26:03,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[['lhs', 'rhs']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:26:03,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/unmodifiablepipesplatform/testUnmodifiable/simple"]
2016-01-14 23:26:03,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 23:26:03,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2016-01-14 23:26:03,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 23:26:03,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 23:26:03,530 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 23:26:03,582 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 23:26:03,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1793653561_0001
2016-01-14 23:26:03,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:26:03,936 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lhs.txt
2016-01-14 23:26:04,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:26:04,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:26:04,088 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F61A2B6894184F678A066B5ADFC57AC4, ordinal: 0
2016-01-14 23:26:04,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['lhs', 'rhs']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:26:04,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'lhs']]
2016-01-14 23:26:04,127 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F61A2B6894184F678A066B5ADFC57AC4, mem on start (mb), free: 81, total: 223, max: 672
2016-01-14 23:26:04,141 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F61A2B6894184F678A066B5ADFC57AC4, mem on close (mb), free: 80, total: 223, max: 672
2016-01-14 23:26:04,177 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:26:04,178 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:26:04,193 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E27E3DBCA26B45F4A49EBB7280118E2E, ordinal: 1
2016-01-14 23:26:04,198 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'lhs']]
2016-01-14 23:26:04,198 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[['lhs', 'rhs']]"][9231277652/test/]
2016-01-14 23:26:04,198 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E27E3DBCA26B45F4A49EBB7280118E2E, mem on start (mb), free: 78, total: 223, max: 672
2016-01-14 23:26:04,217 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E27E3DBCA26B45F4A49EBB7280118E2E, mem on close (mb), free: 77, total: 223, max: 672
2016-01-14 23:26:04,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...m/testUnmodifiable/simple
2016-01-14 23:26:04,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1339781467_0002
2016-01-14 23:26:04,325 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:26:04,330 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/9231277652_test_F8A99EE7BA754172A9FAAF0946875D2B/part-00000
2016-01-14 23:26:04,437 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:26:04,437 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:26:04,447 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC6FC83E96DC413E95BAB06CC347C541, ordinal: 0
2016-01-14 23:26:04,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[['lhs', 'rhs']]"][9231277652/test/]
2016-01-14 23:26:04,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'lhs']]
2016-01-14 23:26:04,448 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC6FC83E96DC413E95BAB06CC347C541, mem on start (mb), free: 66, total: 318, max: 672
2016-01-14 23:26:04,451 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC6FC83E96DC413E95BAB06CC347C541, mem on close (mb), free: 66, total: 318, max: 672
2016-01-14 23:26:04,461 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:26:04,462 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:26:04,473 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A4DBC5AF7F744A0F9FF60C8469FFD662, ordinal: 1
2016-01-14 23:26:04,474 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'lhs']]
2016-01-14 23:26:04,475 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/unmodifiablepipesplatform/testUnmodifiable/simple"]
2016-01-14 23:26:04,475 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DBC5AF7F744A0F9FF60C8469FFD662, mem on start (mb), free: 65, total: 318, max: 672
2016-01-14 23:26:04,482 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DBC5AF7F744A0F9FF60C8469FFD662, mem on close (mb), free: 65, total: 318, max: 672
2016-01-14 23:26:04,494 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/unmodifiablepipesplatform/testUnmodifiable/simple/_temporary
2016-01-14 23:26:04,495 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:01.010
2016-01-14 23:26:04,524 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/unmodifiablepipesplatform/testUnmodifiable/simple