2016-05-17 22:24:52,465 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:24:52,487 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-tez
2016-05-17 22:24:52,512 INFO tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-05-17 22:24:53,209 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
2016-05-17 22:24:54,087 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 22:24:54,669 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:24:57,208 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(109)) - Using Tez AppJar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.6.2/7cfbec38ae59bd135b5606c0b42dce12b41c076c/tez-dag-0.6.2.jar
2016-05-17 22:24:57,423 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(121)) - Set TEZ-LIB-URI to: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:24:57,429 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(152)) - mkdir: hdfs://localhost:52258/apps_staging_dir
2016-05-17 22:24:57,840 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.
2016-05-17 22:24:57,924 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.
2016-05-17 22:24:57,970 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.
2016-05-17 22:24:58,019 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.
2016-05-17 22:24:58,024 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(186)) - Starting MiniTezCluster
2016-05-17 22:24:58,317 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:24:58,322 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:24:58,324 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:25:03,682 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(205)) - Setting yarn-site.xml via YARN-APP-CP at: /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/target/cascading.platform.tez.Hadoop2TezPlatform,/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/resources/test:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/main:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/resources/main:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.1.0/9f41bc3c02048b244161c34aab73acda810c2389/cascading-core-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-platform/3.1.0/38cd2eba8dbbc1efc3f097f196965a60c99cbf2f/cascading-platform-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/11d23daa35c4c17d09d6a8d13b7964dbabd56bf6/cascading-hadoop2-tez-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez-stats/3.1.0/2b8a4fba885da289dd195ea1f6840a76b16f77a6/cascading-hadoop2-tez-stats-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-io/3.1.0/32191afb3963b6ad8992408fd1432cd213fd8de6/cascading-hadoop2-io-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-core/2.5.2/a7168fb50e32ee16e926e28ba0459580c36b2548/hadoop-mapreduce-client-core-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.5.2/d4a60ca549b1f9064578a4ac0a2340624e2440bd/hadoop-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-minicluster/2.5.2/b7ec5d497be231060f492203a205e8cbdccb6b70/hadoop-minicluster-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.5/6b262da268f8ad9eff941b25503a9198f0a0ac93/slf4j-api-1.7.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-tests/0.6.2/e6c7cbbf7f067cea6a8f8c5bea595536e141dd70/tez-tests-0.6.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-api/0.6.2/7be44271b408cb2a59181fc1c3d45d0bb2e6bb93/tez-api-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.6.2/7cfbec38ae59bd135b5606c0b42dce12b41c076c/tez-dag-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-yarn-timeline-history/0.6.2/4765a7b7c177208970def6b9640c1366a61c264c/tez-yarn-timeline-history-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/junit/junit/4.12/2973d150c0dc1fefe998f834810d68f278ea58ec/junit-4.12.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/riffle/riffle/1.0.0/d991264d10c1e80f8588d2480e3f6e536e30fcb2/riffle-1.0.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.jgrapht/jgrapht-core/0.9.2/2597c1f9aa80fcfdd1f2e8ad0f0655bd768d95ca/jgrapht-core-0.9.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.1.0/ba7756e455a94ae4c9cf9a2debeb7085e46f05e5/cascading-core-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-expression/3.1.0/47daa0fd74a26bfe727c2e6c06f8b9c7e9cb91c3/cascading-expression-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-common/2.5.2/8bc52cc38b68820e9fc4831e3942802f6034404e/hadoop-yarn-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.protobuf/protobuf-java/2.5.0/a10732c76bfacdbd633a7eb0f7968b1059a65dfa/protobuf-java-2.5.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.avro/avro/1.7.4/416e7030879814f52845b97f04bb50ecd1cef372/avro-1.7.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-annotations/2.5.2/7bf4cdb8c35cf4dd761726c02b7677a169162f0a/hadoop-annotations-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.inject.extensions/guice-servlet/3.0/610cde0e8da5a8b7d8efb8f0b8987466ffebaaf9/guice-servlet-3.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/11.0.2/35a3c69e19d72743cac83778aecbee68680f63eb/guava-11.0.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-cli/commons-cli/1.2/2bf96b7aa8b611c177d329452af1dc933e14501c/commons-cli-1.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-math3/3.1.1/6719d757a98ff24a83d9d727bef9cec83f59b6e1/commons-math3-3.1.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/xmlenc/xmlenc/0.52/d82554efbe65906d83b3d97bd7509289e9db561a/xmlenc-0.52.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-httpclient/commons-httpclient/3.1/964cd74171f427720480efdec40a7c7f6e58426a/commons-httpclient-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-io/commons-io/2.4/b1b6ea3b7e4aa4f492509a4952029cd8e48019ad/commons-io-2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-net/commons-net/3.1/2298164a7c2484406f2aa5ac85b205d39019896f/commons-net-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-collections/commons-collections/3.2.1/761ea405b9b37ced573d2df0d1e3a4e0f9edc668/commons-collections-3.2.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.servlet/servlet-api/2.5/5959582d97d8b61f4d154ca9e495aafd16726e34/servlet-api-2.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty/6.1.26/2f546e289fddd5b1fab1d4199fbb6e9ef43ee4b0/jetty-6.1.26.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty-util/6.1.26/e5642fe0399814e1687d55a3862aa5a3417226a9/jetty-util-6.1.26.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-core/1.9/8341846f18187013bb9e27e46b7ee00a6395daf4/jersey-core-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-json/1.9/1aa73e1896bcc7013fed247157d7f676226eb432/jersey-json-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-server/1.9/3a6ea7cc5e15c824953f9f3ece2201b634d90d18/jersey-server-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/tomcat/jasper-compiler/5.5.23/6d35bd7fb8c4fbc1f5401fb3678aa976d2e4c241/jasper-compiler-5.5.23.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/tomcat/jasper-runtime/5.5.23/96ca5528a93ab47b001476b74320c644beb89dde/jasper-runtime-5.5.23.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.servlet.jsp/jsp-api/2.1/63f943103f250ef1f3a4d5e94d145a0f961f5316/jsp-api-2.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-el/commons-el/1.0/1df2c042b3f2de0124750241ac6c886dbfa2cc2c/commons-el-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.1.3/f6f66e966c70a83ffbdb6f17a0919eaf7c8aca7f/commons-logging-1.1.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/net.java.dev.jets3t/jets3t/0.9.0/792bc96ee7e57b89f472aa0cb5a31015b9f59c96/jets3t-0.9.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-lang/commons-lang/2.6/ce1edb914c94ebc388f086c6827e8bdeec71ac2/commons-lang-2.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-configuration/commons-configuration/1.6/32cadde23955d7681b0d94a2715846d20b425235/commons-configuration-1.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-core-asl/1.9.13/3c304d70f42f832e0a86d45bd437f692129299a4/jackson-core-asl-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-mapper-asl/1.9.13/1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7/jackson-mapper-asl-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-auth/2.5.2/e637ea131afd368853034649c48b36d032aead52/hadoop-auth-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.jcraft/jsch/0.1.42/a86104b0f2e0c0bab5b0df836065823a99b5e334/jsch-0.1.42.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.6/1b2502e29da1ebaade2357cd1de35a855fa3755/zookeeper-3.4.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-compress/1.4.1/b02e84a993d88568417536240e970c4b809126fd/commons-compress-1.4.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.5.2/9449a553c364a5b13be1789e1921915dde6e444b/hadoop-common-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.5.2/eb891cf7dd6533281c13be4f31b641561908d686/hadoop-hdfs-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.5.2/7c555a887341e8abd95cec5815bb8d920db74969/hadoop-hdfs-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-tests/2.5.2/d4146517ed4f66c8d05261f2a52f36149414f504/hadoop-yarn-server-tests-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.5.2/b0e0f83051d9930577ced46b9d67bade0df33fec/hadoop-mapreduce-client-jobclient-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.5.2/a4dc84d6dfab278f58d729073ae9d93ac1e7b2f9/hadoop-mapreduce-client-jobclient-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-app/2.5.2/345951a8ac3de5bbdf6cc81029e74e2c64e862af/hadoop-mapreduce-client-app-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-api/2.5.2/ed56ef51f79bec95a258681d38a61dbc1713724e/hadoop-yarn-api-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-hs/2.5.2/154271ac4333b0372097d1b46b48efd9bd50516c/hadoop-mapreduce-client-hs-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-library/0.6.2/51f93c866043ed03d16e9657c292858b752100ad/tez-runtime-library-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-mapreduce/0.6.2/dc9fc549fb8023221647d410b3e17b751a1b2c03/tez-mapreduce-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-examples/0.6.2/cd9c5d801f5ffee25bc6e2f0a271e32c5c95c65/tez-examples-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-client/2.5.2/f62818f180f489d18607474ddeb7f0072c00f87d/hadoop-yarn-client-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-common/2.5.2/4c643ab26741daf6d570bab6008b95c8b2562a8f/hadoop-mapreduce-client-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-collections4/4.0/da217367fd25e88df52ba79e47658d4cf928b0d1/commons-collections4-4.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-client/1.9/d3c4b2b5f89db32c96ceddcb863684821910a7bb/jersey-client-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-common/0.6.2/2b6e194f37e7a9931e8f2f732fd167c20395adb5/tez-common-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-internals/0.6.2/c03a09ad12e31ea93c2a2131fbf96f0993875e24/tez-runtime-internals-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-web-proxy/2.5.2/b0030cb1a2abb5eaeac9850ce0c598b141186328/hadoop-yarn-server-web-proxy-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jettison/jettison/1.3.4/3c08d8f699432e23023080cdc8b4073132473dc8/jettison-1.3.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.janino/janino/2.7.6/37fde5de7edd5d7ebe075f03f4c083df2ac73dd8/janino-2.7.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.2.2/aeb3021ca93dde265796d82015beecdcff95bf09/jaxb-api-2.2.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-jaxrs/1.9.13/534d72d2b9d6199dd531dfb27083dd4844082bba/jackson-jaxrs-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-xc/1.9.13/e3480072bc95c202476ffa1de99ff7ee9149f29c/jackson-xc-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.inject/guice/3.0/9d84f15fe35e2c716a02979fb62f50a29f38aefa/guice-3.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey.contribs/jersey-guice/1.9/5963c28c47df7e5d6ad34cec80c071c368777f7b/jersey-guice-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.3/4a85963a752c0a2f715c3924bfc686865e7e1bc6/paranamer-2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.0.4.1/f88b89a5a21a466aeb0ecf0c063605bd584b4947/snappy-java-1.0.4.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/servlet-api/2.5-20081211/22bff70037e1e6fa7e6413149489552ee2064702/servlet-api-2.5-20081211.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/2.2.3-1/56baae106392040a45a06d4a41099173425da1e6/jaxb-impl-2.2.3-1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/asm/asm/3.1/c157def142714c544bdea2e6144645702adf7097/asm-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.jamesmurty.utils/java-xmlbuilder/0.4/ac5962e48cdee3a0a6e1f8e00fcb594747ac5aaf/java-xmlbuilder-0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-digester/commons-digester/1.8/dc6a73fdbd1fa3f0944e8497c6c872fa21dca37e/commons-digester-1.8.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils-core/1.8.0/175dc721f87e4bc5cc0573f990e28c3cf9117508/commons-beanutils-core-1.8.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-kerberos-codec/2.0.0-M15/1c16e4e477183641c5f0dd5cdecd27ec331bacb5/apacheds-kerberos-codec-2.0.0-M15.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.tukaani/xz/1.0/ecff5cb8b1189514c9d1d8d68eb77ac372e000c9/xz-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-daemon/commons-daemon/1.0.13/750856a1fdb3ddf721ccf73c3518e4211cffc3a3/commons-daemon-1.0.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-common/2.5.2/f2203b3e8afeb600b899bfd944e1554adf55902/hadoop-yarn-server-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-nodemanager/2.5.2/36f02e92a13ccfd489a0e24df8ad5aa7f14ebee4/hadoop-yarn-server-nodemanager-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-resourcemanager/2.5.2/874925a5e8c6221bd11526b5b28762c6cfad1ea6/hadoop-yarn-server-resourcemanager-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-shuffle/2.5.2/1c2c8ada2300a9fca6967f1de0300e1b5d86a4a/hadoop-mapreduce-client-shuffle-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.janino/commons-compiler/2.7.6/b71e76d942b33dfa26e4e3047ff2a774d1f917b4/commons-compiler-2.7.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.xml.stream/stax-api/1.0-2/d6337b0de8b25e53e81b922352fbea9f9f57ba0b/stax-api-1.0-2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1/e6cb541461c2834bdea3eb920f1884d1eb508b50/activation-1.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.inject/javax.inject/1/6975da39a7040257bd51d21a231b76c915872d38/javax.inject-1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/aopalliance/aopalliance/1.0/235ba8b489512805ac13a8f9ea77a1ca5ebe3e8/aopalliance-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.sonatype.sisu.inject/cglib/2.2.1-v20090111/7ce5e983fd0e6c78346f4c9cbfa39d83049dda2/cglib-2.2.1-v20090111.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils/1.7.0/5675fd96b29656504b86029551973d60fb41339b/commons-beanutils-1.7.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-i18n/2.0.0-M15/71c61c84683152ec2a6a65f3f96fe534e304fa22/apacheds-i18n-2.0.0-M15.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-asn1-api/1.0.0-M20/5e6486ffa3125ba44dc410ead166e1d6ba8ac76d/api-asn1-api-1.0.0-M20.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-util/1.0.0-M20/a871abf060b3cf83fc6dc4d7e3d151fce50ac3cb/api-util-1.0.0-M20.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.fusesource.leveldbjni/leveldbjni-all/1.8/707350a2eeb1fa2ed77a32ddb3893ed308e941db/leveldbjni-all-1.8.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice/2.5.2/e31679646334eda7ab10b73ef02d97c082fd5db4/hadoop-yarn-server-applicationhistoryservice-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/jline/jline/0.9.94/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/2.0.3/5871fb60dc68d67da54a663c3fd636a10a532948/jsr305-2.0.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/stax/stax-api/1.0.1/49c100caf72d658aca8e58bd74a4ba90fa2b0d70/stax-api-1.0.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.2.5/666e26e76f2e87d84e4f16acb546481ae1b8e9a6/httpclient-4.2.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/io.netty/netty/3.7.0.Final/7a8c35599c68c0bf383df74469aa3e03d9aca87/netty-3.7.0.Final.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.2.4/3b7f38df6de5dd8b500e602ae8c2dd5ee446f883/httpcore-4.2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.6/b7f0fc8f61ecadeb3695f0b9464755eee44374d4/commons-codec-1.6.jar
2016-05-17 22:25:03,992 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:25:04,214 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:25:04,215 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 22:25:04,276 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:25:04,397 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:04,398 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:04,469 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 25AA151A40D946059E4C03A85D0F219A
2016-05-17 22:25:04,595 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-17 22:25:04,606 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-17 22:25:04,608 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:04,608 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:04,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:04,829 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2016-05-17 22:25:04,829 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2016-05-17 22:25:04,829 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:25:04,830 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2016-05-17 22:25:04,870 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:04,871 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:04,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:25:04,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 22:25:04,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:04,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:04,969 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:05,024 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2016-05-17 22:25:05,026 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] parallel execution of flows is enabled: false
2016-05-17 22:25:05,026 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] executing total flows: 1
2016-05-17 22:25:05,026 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] allocating management threads: 1
2016-05-17 22:25:05,027 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2016-05-17 22:25:05,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] at least one sink is marked for delete
2016-05-17 22:25:05,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:05,046 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/FE90FC149F3947F7AD6C68FBC7C295C3/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:05,074 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2016-05-17 22:25:05,074 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2016-05-17 22:25:05,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping all jobs
2016-05-17 22:25:05,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:05,104 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-50/first-nondeter...] getDagStatus returned null
2016-05-17 22:25:05,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopped all jobs
2016-05-17 22:25:05,105 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2016-05-17 22:25:05,105 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2016-05-17 22:25:05,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] completed in: 16938:22:25:05.103
2016-05-17 22:25:05,108 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2016-05-17 22:25:05,109 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2016-05-17 22:25:05,143 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:05,143 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:05,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 22:25:05,207 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-17 22:25:05,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:05,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:05,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:05,257 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2016-05-17 22:25:05,258 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:05,259 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] executing total flows: 1
2016-05-17 22:25:05,259 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-17 22:25:05,260 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2016-05-17 22:25:05,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:05,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:05,265 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/7BEBCC0CC7354839BD323EDC52F3F292/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:05,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting
2016-05-17 22:25:05,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:05,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2016-05-17 22:25:05,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:05,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executing total steps: 1
2016-05-17 22:25:05,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-17 22:25:05,308 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:05,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:05,357 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2016-05-17 22:25:05,358 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2016-05-17 22:25:05,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping all jobs
2016-05-17 22:25:05,359 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:05,360 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-100/first-nondete...] getDagStatus returned null
2016-05-17 22:25:05,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopped all jobs
2016-05-17 22:25:05,368 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:05,582 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:05,617 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0001
2016-05-17 22:25:05,618 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:05,637 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/7BEBCC0CC7354839BD323EDC52F3F292/C8719BA03FA3493AACEF9102050A3F01/.tez/application_1463523898025_0001 doesn't exist and is created
2016-05-17 22:25:05,828 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0001, dagName=[7BEBCC0CC7354839BD323EDC52F3F292/C8719BA03FA3493AACEF9102050A3F01] race-100/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-17 22:25:06,106 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0001/
2016-05-17 22:25:06,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] submitted tez dag to app master: application_1463523898025_0001, with dag id: dag_1463523898025_0001_1
2016-05-17 22:25:06,306 INFO client.TimelineReaderFactory (TimelineReaderFactory.java:tokenDelegationSupported(381)) - Could not find class required for token delegation, will fallback to pseudo auth
2016-05-17 22:25:06,314 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2016-05-17 22:25:06,315 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2016-05-17 22:25:06,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] completed in: 00:00.054
2016-05-17 22:25:06,317 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2016-05-17 22:25:06,318 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2016-05-17 22:25:06,346 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:06,347 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:06,421 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:25:06,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:25:06,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:06,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:06,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:06,473 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2016-05-17 22:25:06,477 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:06,478 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] executing total flows: 1
2016-05-17 22:25:06,478 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-17 22:25:06,479 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2016-05-17 22:25:06,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:06,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:06,483 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/276F5933C30341C09DEB60C603D9B5C1/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:06,523 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting
2016-05-17 22:25:06,523 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:06,523 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2016-05-17 22:25:06,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:06,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executing total steps: 1
2016-05-17 22:25:06,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-17 22:25:06,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:06,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:06,550 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:06,623 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2016-05-17 22:25:06,625 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2016-05-17 22:25:06,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping all jobs
2016-05-17 22:25:06,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:06,626 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-150/first-nondete...] getDagStatus returned null
2016-05-17 22:25:06,667 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:06,668 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopped all jobs
2016-05-17 22:25:06,670 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0002
2016-05-17 22:25:06,670 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:06,690 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/276F5933C30341C09DEB60C603D9B5C1/A93C0FF7F772482EA68D551253920608/.tez/application_1463523898025_0002 doesn't exist and is created
2016-05-17 22:25:06,791 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0002, dagName=[276F5933C30341C09DEB60C603D9B5C1/A93C0FF7F772482EA68D551253920608] race-150/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-17 22:25:06,798 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0002/
2016-05-17 22:25:06,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] submitted tez dag to app master: application_1463523898025_0002, with dag id: dag_1463523898025_0002_1
2016-05-17 22:25:06,943 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2016-05-17 22:25:06,944 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2016-05-17 22:25:06,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] completed in: 00:00.102
2016-05-17 22:25:06,947 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2016-05-17 22:25:06,947 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2016-05-17 22:25:07,014 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:07,015 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:07,142 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 22:25:07,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-17 22:25:07,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:07,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:07,227 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2016-05-17 22:25:07,228 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:07,228 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] executing total flows: 1
2016-05-17 22:25:07,228 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-17 22:25:07,230 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2016-05-17 22:25:07,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:07,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:07,238 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/6FA1B76E46AA43919A21FA379ACBC76C/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:07,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting
2016-05-17 22:25:07,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:07,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2016-05-17 22:25:07,277 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:07,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executing total steps: 1
2016-05-17 22:25:07,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-17 22:25:07,279 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:07,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:07,304 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:07,427 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2016-05-17 22:25:07,428 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2016-05-17 22:25:07,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping all jobs
2016-05-17 22:25:07,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:07,429 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-200/first-nondete...] getDagStatus returned null
2016-05-17 22:25:07,439 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:07,440 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0003
2016-05-17 22:25:07,441 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:07,468 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/6FA1B76E46AA43919A21FA379ACBC76C/DBC8312C8A1B4626AB1DAEB9472B9CD6/.tez/application_1463523898025_0003 doesn't exist and is created
2016-05-17 22:25:07,570 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0003, dagName=[6FA1B76E46AA43919A21FA379ACBC76C/DBC8312C8A1B4626AB1DAEB9472B9CD6] race-200/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-17 22:25:07,577 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0003/
2016-05-17 22:25:07,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] submitted tez dag to app master: application_1463523898025_0003, with dag id: dag_1463523898025_0003_1
2016-05-17 22:25:07,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopped all jobs
2016-05-17 22:25:07,725 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2016-05-17 22:25:07,725 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2016-05-17 22:25:07,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] completed in: 00:00.152
2016-05-17 22:25:07,728 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2016-05-17 22:25:07,729 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2016-05-17 22:25:07,777 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:07,778 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:07,840 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:25:07,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 22:25:07,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:07,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:07,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:07,915 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2016-05-17 22:25:07,916 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:07,916 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] executing total flows: 1
2016-05-17 22:25:07,917 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-17 22:25:07,918 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2016-05-17 22:25:07,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:07,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:07,923 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/230EAB2127154D6BA13CC6057CEF9E07/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:07,962 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting
2016-05-17 22:25:07,962 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:07,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2016-05-17 22:25:07,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:07,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executing total steps: 1
2016-05-17 22:25:07,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-17 22:25:07,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:07,997 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:08,003 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:08,145 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:08,148 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0004
2016-05-17 22:25:08,148 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:08,165 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2016-05-17 22:25:08,166 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2016-05-17 22:25:08,166 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping all jobs
2016-05-17 22:25:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:08,167 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-250/first-nondete...] getDagStatus returned null
2016-05-17 22:25:08,168 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/230EAB2127154D6BA13CC6057CEF9E07/F4201F43D63E479F940A067E2610126C/.tez/application_1463523898025_0004 doesn't exist and is created
2016-05-17 22:25:08,253 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0004, dagName=[230EAB2127154D6BA13CC6057CEF9E07/F4201F43D63E479F940A067E2610126C] race-250/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-17 22:25:08,466 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0004/
2016-05-17 22:25:08,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopped all jobs
2016-05-17 22:25:08,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] submitted tez dag to app master: application_1463523898025_0004, with dag id: dag_1463523898025_0004_1
2016-05-17 22:25:08,611 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2016-05-17 22:25:08,611 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] completed in: 00:00.204
2016-05-17 22:25:08,612 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2016-05-17 22:25:08,611 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2016-05-17 22:25:08,613 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2016-05-17 22:25:08,653 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:08,654 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:08,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 22:25:08,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:25:08,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:08,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:08,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:08,778 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2016-05-17 22:25:08,779 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:08,779 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] executing total flows: 1
2016-05-17 22:25:08,781 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-17 22:25:08,782 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2016-05-17 22:25:08,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:08,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:08,789 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/8E3F41257971417B8464C8CBE51ADD70/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:08,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting
2016-05-17 22:25:08,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:08,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2016-05-17 22:25:08,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:08,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executing total steps: 1
2016-05-17 22:25:08,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-17 22:25:08,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:08,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:08,851 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:08,985 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:08,987 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0005
2016-05-17 22:25:08,987 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:09,013 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/8E3F41257971417B8464C8CBE51ADD70/E4DA4B71F16F4F0BA619270F23479584/.tez/application_1463523898025_0005 doesn't exist and is created
2016-05-17 22:25:09,077 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2016-05-17 22:25:09,079 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2016-05-17 22:25:09,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping all jobs
2016-05-17 22:25:09,080 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:09,080 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-300/first-nondete...] getDagStatus returned null
2016-05-17 22:25:09,121 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0005, dagName=[8E3F41257971417B8464C8CBE51ADD70/E4DA4B71F16F4F0BA619270F23479584] race-300/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-17 22:25:09,131 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0005/
2016-05-17 22:25:09,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopped all jobs
2016-05-17 22:25:09,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] submitted tez dag to app master: application_1463523898025_0005, with dag id: dag_1463523898025_0005_1
2016-05-17 22:25:09,320 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2016-05-17 22:25:09,320 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2016-05-17 22:25:09,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] completed in: 00:00.254
2016-05-17 22:25:09,323 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2016-05-17 22:25:09,323 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2016-05-17 22:25:09,361 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:09,361 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:09,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:25:09,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:25:09,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:09,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:09,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:09,487 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2016-05-17 22:25:09,488 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:09,488 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] executing total flows: 1
2016-05-17 22:25:09,488 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-17 22:25:09,489 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2016-05-17 22:25:09,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:09,490 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:09,494 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/2080D6C185DC46D487CBE631C6E276EF/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:09,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting
2016-05-17 22:25:09,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:09,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2016-05-17 22:25:09,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:09,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executing total steps: 1
2016-05-17 22:25:09,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-17 22:25:09,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:09,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:09,590 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:09,747 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:09,755 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0006
2016-05-17 22:25:09,755 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:09,775 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/2080D6C185DC46D487CBE631C6E276EF/AE302EEBED0047C1A30753BCC094B03F/.tez/application_1463523898025_0006 doesn't exist and is created
2016-05-17 22:25:09,837 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2016-05-17 22:25:09,839 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2016-05-17 22:25:09,839 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping all jobs
2016-05-17 22:25:09,839 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:09,840 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-350/first-nondete...] getDagStatus returned null
2016-05-17 22:25:09,883 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0006, dagName=[2080D6C185DC46D487CBE631C6E276EF/AE302EEBED0047C1A30753BCC094B03F] race-350/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-17 22:25:09,890 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0006/
2016-05-17 22:25:10,125 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopped all jobs
2016-05-17 22:25:10,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] submitted tez dag to app master: application_1463523898025_0006, with dag id: dag_1463523898025_0006_1
2016-05-17 22:25:10,134 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2016-05-17 22:25:10,134 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2016-05-17 22:25:10,137 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] completed in: 00:00.286
2016-05-17 22:25:10,137 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2016-05-17 22:25:10,137 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2016-05-17 22:25:10,176 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:10,177 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:10,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-17 22:25:10,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-17 22:25:10,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:10,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:10,317 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:10,364 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2016-05-17 22:25:10,366 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:10,367 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] executing total flows: 1
2016-05-17 22:25:10,367 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-17 22:25:10,372 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2016-05-17 22:25:10,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:10,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:10,385 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/2AC0881727444A938673C0A1545DE00C/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:10,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting
2016-05-17 22:25:10,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:10,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2016-05-17 22:25:10,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:10,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executing total steps: 1
2016-05-17 22:25:10,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-17 22:25:10,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:10,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:10,456 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:10,692 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:10,695 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0007
2016-05-17 22:25:10,695 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:10,728 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/2AC0881727444A938673C0A1545DE00C/F699D63A204744AFB5B14D0E271FD670/.tez/application_1463523898025_0007 doesn't exist and is created
2016-05-17 22:25:10,764 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2016-05-17 22:25:10,766 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2016-05-17 22:25:10,767 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping all jobs
2016-05-17 22:25:10,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:10,773 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-400/first-nondete...] getDagStatus returned null
2016-05-17 22:25:10,972 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0007, dagName=[2AC0881727444A938673C0A1545DE00C/F699D63A204744AFB5B14D0E271FD670] race-400/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-17 22:25:10,979 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0007/
2016-05-17 22:25:11,233 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopped all jobs
2016-05-17 22:25:11,234 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] submitted tez dag to app master: application_1463523898025_0007, with dag id: dag_1463523898025_0007_1
2016-05-17 22:25:11,243 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2016-05-17 22:25:11,244 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2016-05-17 22:25:11,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] completed in: 00:00.337
2016-05-17 22:25:11,247 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2016-05-17 22:25:11,247 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2016-05-17 22:25:11,286 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:11,287 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:11,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-17 22:25:11,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-17 22:25:11,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:11,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:11,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:11,448 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2016-05-17 22:25:11,450 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:11,450 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] executing total flows: 1
2016-05-17 22:25:11,451 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-17 22:25:11,451 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2016-05-17 22:25:11,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:11,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:11,457 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/58606D606B1E4E9E8DE669A07DDA93B1/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:11,562 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting
2016-05-17 22:25:11,562 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:11,562 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2016-05-17 22:25:11,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:11,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executing total steps: 1
2016-05-17 22:25:11,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-17 22:25:11,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:11,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:11,625 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:11,777 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:11,781 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0008
2016-05-17 22:25:11,781 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:11,806 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/58606D606B1E4E9E8DE669A07DDA93B1/EC1572FA6E6A4A3EA0F81DF3F6E20934/.tez/application_1463523898025_0008 doesn't exist and is created
2016-05-17 22:25:11,899 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2016-05-17 22:25:11,904 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2016-05-17 22:25:11,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping all jobs
2016-05-17 22:25:11,905 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:25:11,905 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-450/first-nondete...] getDagStatus returned null
2016-05-17 22:25:12,055 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0008, dagName=[58606D606B1E4E9E8DE669A07DDA93B1/EC1572FA6E6A4A3EA0F81DF3F6E20934] race-450/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-17 22:25:12,061 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0008/
2016-05-17 22:25:12,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopped all jobs
2016-05-17 22:25:12,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] submitted tez dag to app master: application_1463523898025_0008, with dag id: dag_1463523898025_0008_1
2016-05-17 22:25:12,223 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2016-05-17 22:25:12,223 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2016-05-17 22:25:12,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] completed in: 00:00.342
2016-05-17 22:25:12,225 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2016-05-17 22:25:12,225 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2016-05-17 22:25:12,312 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:12,313 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:12,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:25:12,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-17 22:25:12,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:12,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:12,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:12,501 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2016-05-17 22:25:12,502 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:25:12,502 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] executing total flows: 1
2016-05-17 22:25:12,503 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-17 22:25:12,503 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2016-05-17 22:25:12,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] at least one sink is marked for delete
2016-05-17 22:25:12,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:12,511 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/90B33649472D4360B482C110D9DD7463/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:12,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting
2016-05-17 22:25:12,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:12,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2016-05-17 22:25:12,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:25:12,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executing total steps: 1
2016-05-17 22:25:12,603 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-17 22:25:12,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:12,643 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] tez session mode enabled: false
2016-05-17 22:25:12,649 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:12,911 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:12,913 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0009
2016-05-17 22:25:12,914 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:12,935 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/90B33649472D4360B482C110D9DD7463/F8B99CF13F5A4A48996C88B0F71284F9/.tez/application_1463523898025_0009 doesn't exist and is created
2016-05-17 22:25:13,001 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2016-05-17 22:25:13,015 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2016-05-17 22:25:13,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping all jobs
2016-05-17 22:25:13,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:25:13,022 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-500/first-nondete...] getDagStatus returned null
2016-05-17 22:25:13,083 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0009, dagName=[90B33649472D4360B482C110D9DD7463/F8B99CF13F5A4A48996C88B0F71284F9] race-500/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-17 22:25:13,089 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0009/
2016-05-17 22:25:13,243 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopped all jobs
2016-05-17 22:25:13,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] submitted tez dag to app master: application_1463523898025_0009, with dag id: dag_1463523898025_0009_1
2016-05-17 22:25:13,251 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2016-05-17 22:25:13,252 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2016-05-17 22:25:13,253 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] completed in: 00:00.415
2016-05-17 22:25:13,253 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2016-05-17 22:25:13,254 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2016-05-17 22:25:13,254 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2016-05-17 22:25:13,256 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2016-05-17 22:25:13,258 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2016-05-17 22:25:13,259 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2016-05-17 22:25:13,261 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2016-05-17 22:25:13,262 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2016-05-17 22:25:13,264 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2016-05-17 22:25:13,265 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2016-05-17 22:25:13,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2016-05-17 22:25:13,268 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2016-05-17 22:25:13,270 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2016-05-17 22:25:13,327 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:13,327 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:13,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-17 22:25:13,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:25:13,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:13,508 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:13,509 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:13,597 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 22:25:13,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-17 22:25:13,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:13,714 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:13,714 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:13,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 22:25:13,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-17 22:25:13,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:13,896 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:13,897 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:13,962 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-17 22:25:13,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:25:13,984 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:25:13,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:14,070 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:25:14,070 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:14,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-17 22:25:14,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-17 22:25:14,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-05-17 22:25:14,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-05-17 22:25:14,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:25:14,602 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2016-05-17 22:25:14,613 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] parallel execution of flows is enabled: true
2016-05-17 22:25:14,613 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] executing total flows: 5
2016-05-17 22:25:14,613 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] allocating management threads: 5
2016-05-17 22:25:14,619 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2016-05-17 22:25:14,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] at least one sink is marked for delete
2016-05-17 22:25:14,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:14,628 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2016-05-17 22:25:14,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] at least one sink is marked for delete
2016-05-17 22:25:14,628 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:25:14,628 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/6AEA09B500C1419695104CA3EA5AF9B1/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:14,654 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/9FBB9E214FE74779BB67CC1A2C623F37/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:25:14,762 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting
2016-05-17 22:25:14,763 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:14,763 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-05-17 22:25:14,763 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] parallel execution of steps is enabled: true
2016-05-17 22:25:14,763 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executing total steps: 1
2016-05-17 22:25:14,764 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] allocating management threads: 1
2016-05-17 22:25:14,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting
2016-05-17 22:25:14,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:25:14,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-05-17 22:25:14,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] parallel execution of steps is enabled: true
2016-05-17 22:25:14,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executing total steps: 1
2016-05-17 22:25:14,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] allocating management threads: 1
2016-05-17 22:25:14,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2016-05-17 22:25:14,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2016-05-17 22:25:14,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] tez session mode enabled: false
2016-05-17 22:25:14,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] tez session mode enabled: false
2016-05-17 22:25:14,899 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:14,901 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:25:15,244 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:15,247 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:25:15,253 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0011
2016-05-17 22:25:15,254 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:15,255 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0010
2016-05-17 22:25:15,255 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:25:15,284 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/6AEA09B500C1419695104CA3EA5AF9B1/F173BE4A4C124CBFB7B88FA0B7BD0528/.tez/application_1463523898025_0010 doesn't exist and is created
2016-05-17 22:25:15,286 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/9FBB9E214FE74779BB67CC1A2C623F37/ECDC8BF3BDF440E08E37452065CFE0D3/.tez/application_1463523898025_0011 doesn't exist and is created
2016-05-17 22:25:15,582 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0010, dagName=[6AEA09B500C1419695104CA3EA5AF9B1/F173BE4A4C124CBFB7B88FA0B7BD0528] first2/(1/1) ...atform/testCascade/first2
2016-05-17 22:25:15,662 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0011, dagName=[9FBB9E214FE74779BB67CC1A2C623F37/ECDC8BF3BDF440E08E37452065CFE0D3] first1/(1/1) ...atform/testCascade/first1
2016-05-17 22:25:15,690 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0011/
2016-05-17 22:25:15,790 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0010/
2016-05-17 22:25:16,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] submitted tez dag to app master: application_1463523898025_0011, with dag id: dag_1463523898025_0011_1
2016-05-17 22:25:16,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] submitted tez dag to app master: application_1463523898025_0010, with dag id: dag_1463523898025_0010_1
2016-05-17 22:25:30,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0001_01_000002 is : 143
2016-05-17 22:25:31,512 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0001_01_000002
2016-05-17 22:25:31,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0002_01_000002 is : 143
2016-05-17 22:25:32,842 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0002_01_000002
2016-05-17 22:25:52,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0003_01_000002 is : 143
2016-05-17 22:25:53,394 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0003_01_000002
2016-05-17 22:25:53,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0004_01_000002 is : 143
2016-05-17 22:25:54,924 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0004_01_000002
2016-05-17 22:26:12,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0005_01_000002 is : 143
2016-05-17 22:26:15,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0006_01_000002 is : 143
2016-05-17 22:26:34,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0007_01_000002 is : 143
2016-05-17 22:26:35,021 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0007_01_000002
2016-05-17 22:26:37,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0008_01_000002 is : 143
2016-05-17 22:26:38,720 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0008_01_000002
2016-05-17 22:26:53,850 INFO counters.Limits (Limits.java:ensureInitialized(59)) - Counter limits initialized with parameters: GROUP_NAME_MAX=128, MAX_GROUPS=500, COUNTER_NAME_MAX=64, MAX_COUNTERS=1200
2016-05-17 22:26:53,855 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2/_temporary
2016-05-17 22:26:53,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] completed in: 01:39.053, using cpu time: 00:02.640
2016-05-17 22:26:53,856 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2016-05-17 22:26:53,857 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2016-05-17 22:26:53,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] at least one sink is marked for delete
2016-05-17 22:26:53,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:26:53,859 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/084BC96A521C43FAB73E56E89D89F57A/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:26:53,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting
2016-05-17 22:26:53,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-05-17 22:26:53,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-05-17 22:26:53,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] parallel execution of steps is enabled: true
2016-05-17 22:26:53,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executing total steps: 1
2016-05-17 22:26:53,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] allocating management threads: 1
2016-05-17 22:26:53,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2016-05-17 22:26:53,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] tez session mode enabled: false
2016-05-17 22:26:53,904 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:26:53,991 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:26:53,992 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0012
2016-05-17 22:26:53,992 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:26:54,003 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/084BC96A521C43FAB73E56E89D89F57A/B12D7F830EF840B8A342422E9B39EEB8/.tez/application_1463523898025_0012 doesn't exist and is created
2016-05-17 22:26:54,059 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0012, dagName=[084BC96A521C43FAB73E56E89D89F57A/B12D7F830EF840B8A342422E9B39EEB8] second2/(1/1) ...tform/testCascade/second2
2016-05-17 22:26:54,062 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0012/
2016-05-17 22:26:54,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] submitted tez dag to app master: application_1463523898025_0012, with dag id: dag_1463523898025_0012_1
2016-05-17 22:26:55,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0009_01_000002 is : 143
2016-05-17 22:26:56,048 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0009_01_000002
2016-05-17 22:26:58,866 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0010_01_000002 is : 143
2016-05-17 22:26:59,844 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0010_01_000002
2016-05-17 22:27:09,515 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1/_temporary
2016-05-17 22:27:09,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] completed in: 01:54.752, using cpu time: 00:02.810
2016-05-17 22:27:09,517 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2016-05-17 22:27:09,518 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2016-05-17 22:27:09,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] at least one sink is marked for delete
2016-05-17 22:27:09,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:27:09,520 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/FC3708C28AEC445391C8ACBD3443B9BE/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:27:09,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting
2016-05-17 22:27:09,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-05-17 22:27:09,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-05-17 22:27:09,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] parallel execution of steps is enabled: true
2016-05-17 22:27:09,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executing total steps: 1
2016-05-17 22:27:09,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] allocating management threads: 1
2016-05-17 22:27:09,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2016-05-17 22:27:09,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] tez session mode enabled: false
2016-05-17 22:27:09,563 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:27:09,639 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:27:09,640 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0013
2016-05-17 22:27:09,640 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:27:09,649 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/FC3708C28AEC445391C8ACBD3443B9BE/BCC5B466E72447A6A9D551D5C51708BC/.tez/application_1463523898025_0013 doesn't exist and is created
2016-05-17 22:27:09,704 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0013, dagName=[FC3708C28AEC445391C8ACBD3443B9BE/BCC5B466E72447A6A9D551D5C51708BC] second1/(1/1) ...tform/testCascade/second1
2016-05-17 22:27:09,707 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0013/
2016-05-17 22:27:09,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] submitted tez dag to app master: application_1463523898025_0013, with dag id: dag_1463523898025_0013_1
2016-05-17 22:27:13,807 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2/_temporary
2016-05-17 22:27:13,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] completed in: 00:19.923, using cpu time: 00:03.020
2016-05-17 22:27:13,809 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2016-05-17 22:27:14,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0011_01_000002 is : 143
2016-05-17 22:27:18,830 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0012_01_000002 is : 143
2016-05-17 22:27:29,074 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1/_temporary
2016-05-17 22:27:29,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] completed in: 00:19.529, using cpu time: 00:02.600
2016-05-17 22:27:29,076 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2016-05-17 22:27:29,076 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2016-05-17 22:27:29,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] at least one sink is marked for delete
2016-05-17 22:27:29,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:27:29,080 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:52258/user/teamcity/.staging/CC9519F6FC6749758914C34F2B5A5178/cascading-hadoop2-tez-3.1.0.jar
2016-05-17 22:27:29,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-17 22:27:29,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-05-17 22:27:29,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-05-17 22:27:29,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/third"]
2016-05-17 22:27:29,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-17 22:27:29,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 1
2016-05-17 22:27:29,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 1
2016-05-17 22:27:29,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2016-05-17 22:27:29,117 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tez session mode enabled: false
2016-05-17 22:27:29,120 INFO client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-05-17 22:27:29,204 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-17 22:27:29,205 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1463523898025_0014
2016-05-17 22:27:29,206 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:52258/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-17 22:27:29,215 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:52258/user/teamcity/.staging/CC9519F6FC6749758914C34F2B5A5178/B27779EA190048CF86E22D5BA0ACE506/.tez/application_1463523898025_0014 doesn't exist and is created
2016-05-17 22:27:29,276 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1463523898025_0014, dagName=[CC9519F6FC6749758914C34F2B5A5178/B27779EA190048CF86E22D5BA0ACE506] lhs*rhs/(1/1) ...latform/testCascade/third
2016-05-17 22:27:29,279 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-123-148-208:55793/proxy/application_1463523898025_0014/
2016-05-17 22:27:29,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted tez dag to app master: application_1463523898025_0014, with dag id: dag_1463523898025_0014_1
2016-05-17 22:27:34,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523898025_0013_01_000002 is : 143
2016-05-17 22:27:35,083 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463523898025_0013_01_000002
2016-05-17 22:27:43,264 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/third/_temporary
2016-05-17 22:27:43,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:14.162, using cpu time: 00:06.570
2016-05-17 22:27:43,267 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2016-05-17 22:27:43,346 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/third
2016-05-17 22:27:43,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/second2
2016-05-17 22:27:43,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/second1
2016-05-17 22:27:43,367 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/first2
2016-05-17 22:27:43,371 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/first1