2015-08-12 18:50:27,802 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 18:50:27,847 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-mr1
2015-08-12 18:50:27,895 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-08-12 18:50:29,147 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-12 18:50:29,888 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 18:50:35,750 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 18:50:36,012 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 18:50:36,219 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 18:50:36,410 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 18:50:53,644 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-08-12 18:50:53,825 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:53,827 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:53,970 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 6A22CD7D5F17484283A960F58D23A1B4
2015-08-12 18:50:54,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.113
2015-08-12 18:50:54,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:54,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:54,333 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2015-08-12 18:50:54,334 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2015-08-12 18:50:54,336 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 18:50:54,336 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2015-08-12 18:50:54,389 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:54,390 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:54,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2015-08-12 18:50:54,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:54,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:54,500 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2015-08-12 18:50:54,505 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] parallel execution of flows is enabled: false
2015-08-12 18:50:54,506 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] executing total flows: 1
2015-08-12 18:50:54,506 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] allocating management threads: 1
2015-08-12 18:50:54,508 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-08-12 18:50:54,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-08-12 18:50:54,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:54,551 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2015-08-12 18:50:54,553 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-08-12 18:50:54,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping all jobs
2015-08-12 18:50:54,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-08-12 18:50:54,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopped all jobs
2015-08-12 18:50:54,560 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2015-08-12 18:50:54,560 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2015-08-12 18:50:54,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] completed in: 16660:01:50:54.558
2015-08-12 18:50:54,562 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-08-12 18:50:54,563 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2015-08-12 18:50:54,595 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:54,597 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:54,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 18:50:54,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:54,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:54,683 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2015-08-12 18:50:54,685 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:50:54,686 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] executing total flows: 1
2015-08-12 18:50:54,688 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] allocating management threads: 1
2015-08-12 18:50:54,690 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-08-12 18:50:54,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-08-12 18:50:54,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:54,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting
2015-08-12 18:50:54,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:50:54,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2015-08-12 18:50:54,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:50:54,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executing total steps: 1
2015-08-12 18:50:54,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] allocating management threads: 1
2015-08-12 18:50:54,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-12 18:50:54,783 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2015-08-12 18:50:54,784 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-08-12 18:50:54,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping all jobs
2015-08-12 18:50:54,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-12 18:50:54,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopped all jobs
2015-08-12 18:50:54,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutting down job executor
2015-08-12 18:50:55,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] submitted hadoop job: job_1439430648135_0001
2015-08-12 18:50:55,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0001/
2015-08-12 18:50:55,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutdown complete
2015-08-12 18:50:55,845 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2015-08-12 18:50:55,846 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2015-08-12 18:50:55,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] completed in: 00:00.076
2015-08-12 18:50:55,881 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-08-12 18:50:55,881 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2015-08-12 18:50:55,923 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:55,923 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:56,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.102
2015-08-12 18:50:56,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:56,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:56,091 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2015-08-12 18:50:56,095 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:50:56,096 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] executing total flows: 1
2015-08-12 18:50:56,097 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] allocating management threads: 1
2015-08-12 18:50:56,101 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-08-12 18:50:56,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-08-12 18:50:56,105 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:56,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting
2015-08-12 18:50:56,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:50:56,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2015-08-12 18:50:56,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:50:56,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executing total steps: 1
2015-08-12 18:50:56,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] allocating management threads: 1
2015-08-12 18:50:56,123 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-12 18:50:56,241 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2015-08-12 18:50:56,243 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-08-12 18:50:56,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping all jobs
2015-08-12 18:50:56,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-12 18:50:56,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopped all jobs
2015-08-12 18:50:56,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutting down job executor
2015-08-12 18:50:57,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] submitted hadoop job: job_1439430648135_0002
2015-08-12 18:50:57,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0002/
2015-08-12 18:50:57,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutdown complete
2015-08-12 18:50:57,317 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2015-08-12 18:50:57,318 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2015-08-12 18:50:57,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] completed in: 00:00.128
2015-08-12 18:50:57,336 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-08-12 18:50:57,350 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2015-08-12 18:50:57,444 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:57,445 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:57,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.158
2015-08-12 18:50:57,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:57,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:57,681 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2015-08-12 18:50:57,692 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:50:57,693 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] executing total flows: 1
2015-08-12 18:50:57,693 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] allocating management threads: 1
2015-08-12 18:50:57,701 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-08-12 18:50:57,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-08-12 18:50:57,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:57,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting
2015-08-12 18:50:57,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:50:57,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2015-08-12 18:50:57,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:50:57,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executing total steps: 1
2015-08-12 18:50:57,737 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] allocating management threads: 1
2015-08-12 18:50:57,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-12 18:50:57,879 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2015-08-12 18:50:57,891 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-08-12 18:50:57,891 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping all jobs
2015-08-12 18:50:57,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-12 18:50:57,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopped all jobs
2015-08-12 18:50:57,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutting down job executor
2015-08-12 18:50:58,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] submitted hadoop job: job_1439430648135_0003
2015-08-12 18:50:58,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0003/
2015-08-12 18:50:58,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutdown complete
2015-08-12 18:50:58,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] completed in: 00:00.155
2015-08-12 18:50:58,456 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-08-12 18:50:58,456 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2015-08-12 18:50:58,457 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2015-08-12 18:50:58,460 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2015-08-12 18:50:58,533 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:58,543 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:58,696 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.138
2015-08-12 18:50:58,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:58,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:58,720 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2015-08-12 18:50:58,727 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:50:58,727 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] executing total flows: 1
2015-08-12 18:50:58,728 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] allocating management threads: 1
2015-08-12 18:50:58,735 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-08-12 18:50:58,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-08-12 18:50:58,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting
2015-08-12 18:50:58,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:50:58,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2015-08-12 18:50:58,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:50:58,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executing total steps: 1
2015-08-12 18:50:58,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] allocating management threads: 1
2015-08-12 18:50:58,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-12 18:50:58,970 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2015-08-12 18:50:58,982 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-08-12 18:50:58,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping all jobs
2015-08-12 18:50:59,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-12 18:50:59,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopped all jobs
2015-08-12 18:50:59,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutting down job executor
2015-08-12 18:50:59,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] submitted hadoop job: job_1439430648135_0004
2015-08-12 18:50:59,550 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0004/
2015-08-12 18:50:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutdown complete
2015-08-12 18:50:59,558 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2015-08-12 18:50:59,558 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2015-08-12 18:50:59,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] completed in: 00:00.206
2015-08-12 18:50:59,559 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-08-12 18:50:59,565 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2015-08-12 18:50:59,641 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:50:59,641 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:50:59,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.109
2015-08-12 18:50:59,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:50:59,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:50:59,833 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2015-08-12 18:50:59,855 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:50:59,855 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] executing total flows: 1
2015-08-12 18:50:59,855 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] allocating management threads: 1
2015-08-12 18:50:59,864 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-08-12 18:50:59,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-08-12 18:50:59,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:50:59,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting
2015-08-12 18:50:59,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:50:59,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2015-08-12 18:50:59,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:50:59,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executing total steps: 1
2015-08-12 18:50:59,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] allocating management threads: 1
2015-08-12 18:50:59,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:00,124 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2015-08-12 18:51:00,139 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-08-12 18:51:00,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping all jobs
2015-08-12 18:51:00,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:00,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopped all jobs
2015-08-12 18:51:00,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] shutting down job executor
2015-08-12 18:51:00,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] submitted hadoop job: job_1439430648135_0005
2015-08-12 18:51:00,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0005/
2015-08-12 18:51:00,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] completed in: 00:00.261
2015-08-12 18:51:00,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] shutdown complete
2015-08-12 18:51:00,535 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2015-08-12 18:51:00,535 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2015-08-12 18:51:00,536 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-08-12 18:51:00,537 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2015-08-12 18:51:00,599 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:00,606 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:00,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2015-08-12 18:51:00,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:00,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:00,763 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2015-08-12 18:51:00,769 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:51:00,770 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] executing total flows: 1
2015-08-12 18:51:00,771 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] allocating management threads: 1
2015-08-12 18:51:00,780 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-08-12 18:51:00,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-08-12 18:51:00,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:00,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting
2015-08-12 18:51:00,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:00,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2015-08-12 18:51:00,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:51:00,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executing total steps: 1
2015-08-12 18:51:00,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] allocating management threads: 1
2015-08-12 18:51:00,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-12 18:51:01,113 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2015-08-12 18:51:01,123 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-08-12 18:51:01,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping all jobs
2015-08-12 18:51:01,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-12 18:51:01,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopped all jobs
2015-08-12 18:51:01,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutting down job executor
2015-08-12 18:51:01,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] submitted hadoop job: job_1439430648135_0006
2015-08-12 18:51:01,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0006/
2015-08-12 18:51:01,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] completed in: 00:00.290
2015-08-12 18:51:01,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutdown complete
2015-08-12 18:51:01,486 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2015-08-12 18:51:01,487 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2015-08-12 18:51:01,489 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-08-12 18:51:01,492 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2015-08-12 18:51:01,581 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:01,582 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:01,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.165
2015-08-12 18:51:01,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:01,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:01,831 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2015-08-12 18:51:01,834 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:51:01,835 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] executing total flows: 1
2015-08-12 18:51:01,836 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] allocating management threads: 1
2015-08-12 18:51:01,844 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-08-12 18:51:01,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-08-12 18:51:01,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:01,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting
2015-08-12 18:51:01,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:01,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2015-08-12 18:51:01,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:51:01,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executing total steps: 1
2015-08-12 18:51:01,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] allocating management threads: 1
2015-08-12 18:51:01,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:02,231 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2015-08-12 18:51:02,235 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-08-12 18:51:02,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping all jobs
2015-08-12 18:51:02,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:02,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopped all jobs
2015-08-12 18:51:02,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutting down job executor
2015-08-12 18:51:02,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] submitted hadoop job: job_1439430648135_0007
2015-08-12 18:51:02,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0007/
2015-08-12 18:51:02,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutdown complete
2015-08-12 18:51:02,703 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2015-08-12 18:51:02,703 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2015-08-12 18:51:02,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] completed in: 00:00.373
2015-08-12 18:51:02,711 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-08-12 18:51:02,712 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2015-08-12 18:51:02,843 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:02,849 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:02,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-08-12 18:51:02,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:02,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:02,950 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2015-08-12 18:51:02,962 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:51:02,963 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] executing total flows: 1
2015-08-12 18:51:02,964 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] allocating management threads: 1
2015-08-12 18:51:02,972 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-08-12 18:51:02,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-08-12 18:51:02,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:02,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting
2015-08-12 18:51:02,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:02,999 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2015-08-12 18:51:03,000 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:51:03,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executing total steps: 1
2015-08-12 18:51:03,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] allocating management threads: 1
2015-08-12 18:51:03,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-12 18:51:03,400 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2015-08-12 18:51:03,415 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-08-12 18:51:03,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping all jobs
2015-08-12 18:51:03,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-12 18:51:03,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopped all jobs
2015-08-12 18:51:03,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutting down job executor
2015-08-12 18:51:03,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] submitted hadoop job: job_1439430648135_0008
2015-08-12 18:51:03,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0008/
2015-08-12 18:51:03,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] completed in: 00:00.419
2015-08-12 18:51:03,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutdown complete
2015-08-12 18:51:03,693 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2015-08-12 18:51:03,693 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2015-08-12 18:51:03,693 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-08-12 18:51:03,694 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2015-08-12 18:51:03,810 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:03,811 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:04,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.158
2015-08-12 18:51:04,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:04,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:04,052 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2015-08-12 18:51:04,055 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] parallel execution of flows is enabled: false
2015-08-12 18:51:04,056 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] executing total flows: 1
2015-08-12 18:51:04,065 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] allocating management threads: 1
2015-08-12 18:51:04,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-08-12 18:51:04,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-08-12 18:51:04,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:04,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting
2015-08-12 18:51:04,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:04,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2015-08-12 18:51:04,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] parallel execution of steps is enabled: true
2015-08-12 18:51:04,106 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executing total steps: 1
2015-08-12 18:51:04,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] allocating management threads: 1
2015-08-12 18:51:04,121 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:04,553 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2015-08-12 18:51:04,561 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-08-12 18:51:04,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping all jobs
2015-08-12 18:51:04,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-12 18:51:04,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopped all jobs
2015-08-12 18:51:04,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutting down job executor
2015-08-12 18:51:04,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] submitted hadoop job: job_1439430648135_0009
2015-08-12 18:51:04,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0009/
2015-08-12 18:51:04,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] completed in: 00:00.462
2015-08-12 18:51:04,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutdown complete
2015-08-12 18:51:04,967 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2015-08-12 18:51:04,968 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2015-08-12 18:51:04,967 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-08-12 18:51:04,976 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2015-08-12 18:51:04,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2015-08-12 18:51:04,982 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2015-08-12 18:51:04,985 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2015-08-12 18:51:04,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2015-08-12 18:51:04,990 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2015-08-12 18:51:04,992 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2015-08-12 18:51:04,994 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2015-08-12 18:51:05,001 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2015-08-12 18:51:05,007 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2015-08-12 18:51:05,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2015-08-12 18:51:05,016 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2015-08-12 18:51:05,161 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:05,162 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:05,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.144
2015-08-12 18:51:05,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:05,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:05,564 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:05,565 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:05,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2015-08-12 18:51:05,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:05,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:05,874 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:05,875 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:06,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.140
2015-08-12 18:51:06,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:06,041 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:06,194 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:06,194 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:06,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.120
2015-08-12 18:51:06,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:51:06,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:06,530 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:51:06,530 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:51:06,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.229
2015-08-12 18:51:06,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 18:51:06,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:51:07,096 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2015-08-12 18:51:07,099 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] parallel execution of flows is enabled: true
2015-08-12 18:51:07,099 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] executing total flows: 5
2015-08-12 18:51:07,099 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] allocating management threads: 5
2015-08-12 18:51:07,108 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2015-08-12 18:51:07,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] at least one sink is marked for delete
2015-08-12 18:51:07,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:07,117 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2015-08-12 18:51:07,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] at least one sink is marked for delete
2015-08-12 18:51:07,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:51:07,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting
2015-08-12 18:51:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2015-08-12 18:51:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] parallel execution of steps is enabled: true
2015-08-12 18:51:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executing total steps: 1
2015-08-12 18:51:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] allocating management threads: 1
2015-08-12 18:51:07,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting
2015-08-12 18:51:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 18:51:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2015-08-12 18:51:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] parallel execution of steps is enabled: true
2015-08-12 18:51:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executing total steps: 1
2015-08-12 18:51:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] allocating management threads: 1
2015-08-12 18:51:07,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2015-08-12 18:51:07,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2015-08-12 18:51:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] submitted hadoop job: job_1439430648135_0010
2015-08-12 18:51:08,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0010/
2015-08-12 18:51:08,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] submitted hadoop job: job_1439430648135_0011
2015-08-12 18:51:08,215 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0011/
2015-08-12 18:51:53,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0002_01_000005 is : 143
2015-08-12 18:51:53,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0002_01_000004 is : 143
2015-08-12 18:52:47,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0004_01_000003 is : 143
2015-08-12 18:52:47,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0004_01_000002 is : 143
2015-08-12 18:52:49,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0003_01_000005 is : 143
2015-08-12 18:52:49,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0003_01_000004 is : 143
2015-08-12 18:52:49,857 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0004_01_000005 is : 143
2015-08-12 18:52:49,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0004_01_000004 is : 143
2015-08-12 18:53:42,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0005_01_000005 is : 143
2015-08-12 18:53:42,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0006_01_000002 is : 143
2015-08-12 18:53:43,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0006_01_000004 is : 143
2015-08-12 18:53:43,578 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0006_01_000005 is : 143
2015-08-12 18:54:31,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0007_01_000005 is : 143
2015-08-12 18:54:36,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0008_01_000004 is : 143
2015-08-12 18:54:37,012 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0008_01_000002 is : 143
2015-08-12 18:54:37,064 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0008_01_000003 is : 143
2015-08-12 18:55:28,444 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0009_01_000002 is : 143
2015-08-12 18:55:30,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0010_01_000003 is : 143
2015-08-12 18:55:30,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0010_01_000002 is : 143
2015-08-12 18:55:31,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0010_01_000005 is : 143
2015-08-12 18:55:31,987 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0010_01_000004 is : 143
2015-08-12 18:55:33,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2/_temporary
2015-08-12 18:55:33,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] completed in: 04:26.148, using cpu time: 00:04.440
2015-08-12 18:55:33,330 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2015-08-12 18:55:33,331 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2015-08-12 18:55:33,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] at least one sink is marked for delete
2015-08-12 18:55:33,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:55:33,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting
2015-08-12 18:55:33,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2015-08-12 18:55:33,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2015-08-12 18:55:33,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] parallel execution of steps is enabled: true
2015-08-12 18:55:33,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executing total steps: 1
2015-08-12 18:55:33,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] allocating management threads: 1
2015-08-12 18:55:33,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2015-08-12 18:55:33,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] submitted hadoop job: job_1439430648135_0012
2015-08-12 18:55:33,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0012/
2015-08-12 18:56:25,891 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1/_temporary
2015-08-12 18:56:25,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] completed in: 05:18.685, using cpu time: 00:04.660
2015-08-12 18:56:25,899 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2015-08-12 18:56:25,900 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2015-08-12 18:56:25,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] at least one sink is marked for delete
2015-08-12 18:56:25,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:56:25,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting
2015-08-12 18:56:25,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2015-08-12 18:56:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2015-08-12 18:56:25,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] parallel execution of steps is enabled: true
2015-08-12 18:56:25,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executing total steps: 1
2015-08-12 18:56:25,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] allocating management threads: 1
2015-08-12 18:56:25,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2015-08-12 18:56:27,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] submitted hadoop job: job_1439430648135_0013
2015-08-12 18:56:27,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0013/
2015-08-12 18:56:34,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0012_01_000003 is : 143
2015-08-12 18:56:34,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0012_01_000004 is : 143
2015-08-12 18:56:36,021 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2/_temporary
2015-08-12 18:56:36,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] completed in: 01:02.685, using cpu time: 00:05.640
2015-08-12 18:56:36,024 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2015-08-12 18:57:02,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0013_01_000003 is : 143
2015-08-12 18:57:07,092 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1/_temporary
2015-08-12 18:57:07,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] completed in: 00:41.160, using cpu time: 00:05.530
2015-08-12 18:57:07,097 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2015-08-12 18:57:07,097 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-08-12 18:57:07,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] at least one sink is marked for delete
2015-08-12 18:57:07,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-08-12 18:57:07,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-08-12 18:57:07,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2015-08-12 18:57:07,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2015-08-12 18:57:07,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third"]
2015-08-12 18:57:07,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2015-08-12 18:57:07,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2015-08-12 18:57:07,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2015-08-12 18:57:07,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2015-08-12 18:57:07,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1439430648135_0014
2015-08-12 18:57:07,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://node1.bidemo.com:46301/proxy/application_1439430648135_0014/
2015-08-12 18:57:49,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000002 is : 143
2015-08-12 18:57:54,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000003 is : 143
2015-08-12 18:58:03,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000008 is : 143
2015-08-12 18:58:06,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000006 is : 143
2015-08-12 18:58:07,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000007 is : 143
2015-08-12 18:58:08,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000011 is : 143
2015-08-12 18:58:08,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000009 is : 143
2015-08-12 18:58:08,981 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000004 is : 143
2015-08-12 18:58:14,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439430648135_0014_01_000012 is : 143
2015-08-12 18:58:15,413 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third/_temporary
2015-08-12 18:58:15,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 01:08.310, using cpu time: 00:20.620
2015-08-12 18:58:15,416 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-08-12 18:58:15,460 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/third
2015-08-12 18:58:15,477 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second2
2015-08-12 18:58:15,513 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first1
2015-08-12 18:58:15,542 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first2
2015-08-12 18:58:15,572 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second1